Spring Batchで複数のファイルをどのようにマージするか

2年 ago
夏樹, 風
1 minute

Spring Batchを使用して複数のファイルのマージを行う手順は次のとおりです。

  1. バッチ処理を有効にする
@Configuration
@EnableBatchProcessing
public class BatchConfig {

    @Autowired
    private JobBuilderFactory jobBuilderFactory;

    @Autowired
    private StepBuilderFactory stepBuilderFactory;

    @Autowired
    private ItemReader<File> fileReader;

    @Autowired
    private ItemProcessor<File, String> fileProcessor;

    @Autowired
    private ItemWriter<String> fileWriter;

    @Bean
    public Step mergeFilesStep() {
        return stepBuilderFactory.get("mergeFilesStep")
                .<File, String>chunk(10)
                .reader(fileReader)
                .processor(fileProcessor)
                .writer(fileWriter)
                .build();
    }

    @Bean
    public Job mergeFilesJob() {
        return jobBuilderFactory.get("mergeFilesJob")
                .start(mergeFilesStep())
                .build();
    }
}
  1. MultiResourceItemReader
@Bean
public MultiResourceItemReader<File> fileReader() {
    MultiResourceItemReader<File> reader = new MultiResourceItemReader<>();
    reader.setResources(new Resource[] {
        new FileSystemResource("file1.csv"),
        new FileSystemResource("file2.csv"),
        new FileSystemResource("file3.csv")
    });
    reader.setDelegate(new FlatFileItemReaderBuilder<File>()
        .name("fileItemReader")
        .delimited()
        .names("column1", "column2", "column3")
        .targetType(File.class)
        .build());
    return reader;
}
  1. ファイルを処理するためのItemProcessorを作成します。実際のニーズに応じてファイルを処理し、処理された結果を返します。
@Bean
public ItemProcessor<File, String> fileProcessor() {
    return file -> {
        // 处理文件逻辑，返回处理后的字符串
        return file.getName();
    };
}
  1. FlatFileItemWriter
@Bean
public ItemWriter<String> fileWriter() {
    FlatFileItemWriter<String> writer = new FlatFileItemWriter<>();
    writer.setResource(new FileSystemResource("mergedFile.csv"));
    writer.setLineAggregator(new PassThroughLineAggregator<>());
    return writer;
}
  1. バッチジョブを実行する
@Autowired
private JobLauncher jobLauncher;

@Autowired
private Job mergeFilesJob;

public void runBatchJob() throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException {
    JobParameters jobParameters = new JobParametersBuilder()
            .addLong("time", System.currentTimeMillis())
            .toJobParameters();
    jobLauncher.run(mergeFilesJob, jobParameters);
}

Spring Batchで複数のファイルを結合する基本的な手順は上記のとおりです。実際のニーズに応じて、適切な調整と拡張を行ってください。

bannerAds