Adicione parâmetro ao contexto do trabalho a partir da etapa do tasklet e use nas etapas posteriores no Spring Batch
Por enquanto, estou usando jobParameters para obter os nomes de arquivos para meus FlatFileItemReader e FlatFileItemWriter. Não há problema em testar meu lote, mas meu objetivo é ler um arquivo em algum diretório (existe apenas esse arquivo nesse diretório) e o nome do arquivo pode mudar. O nome do arquivo de saída deve depender do nome do arquivo de entrada.
Portanto, pensei em adicionar uma nova etapa ao meu trabalho, e essa etapa definirá os nomes dos arquivos de saída e de entrada pesquisando o bom diretório e procurando o arquivo nele. Eu liPassando dados para etapas futuras do Spring Doc eesta discussão da SO, mas não consigo fazê-lo funcionar, os arquivos são sempre "nulos".
Primeiro, eu defini o seguinte Tasklet
public class SettingFilenamesTasklet implements Tasklet {
private StepExecution stepExecution;
@Override
public RepeatStatus execute(StepContribution contribution, ChunkContext chunkContext) throws Exception {
// TODO Search folder and set real filenames
String inputFilename = "D:/TestInputFolder/dataFile.csv";
String outputFilename = "D:/TestOutputFolder/dataFile-processed.csv";
ExecutionContext stepContext = stepExecution.getExecutionContext();
stepContext.put("inputFile", inputFilename);
stepContext.put("outputFile", outputFilename);
return RepeatStatus.FINISHED;
}
@BeforeStep
public void saveStepExecution(StepExecution stepExec) {
stepExecution = stepExec;
}
}
Em seguida, adicionei o bean promotionListener
@Bean
public ExecutionContextPromotionListener promotionListener() {
ExecutionContextPromotionListener listener = new ExecutionContextPromotionListener();
listener.setKeys(new String[]{
"inputFile", "outputFile"
});
return listener;
}
Alterei jobParameters por jobExecutionContext na minha definição FlatFileItemWriter (não alterei uma única linha no próprio código)
@Bean
@StepScope
public FlatFileItemWriter<RedevableCRE> flatFileWriter(@Value("#{jobExecutionContext[outputFile]}") String outputFile) {
FlatFileItemWriter<Employee> flatWriter = new FlatFileItemWriter<Employee>();
FileSystemResource isr;
isr = new FileSystemResource(new File(outputFile));
flatWriter.setResource(isr);
DelimitedLineAggregator<RedevableCRE> aggregator = new DelimitedLineAggregator<RedevableCRE>();
aggregator.setDelimiter(";");
BeanWrapperFieldExtractor<RedevableCRE> beanWrapper = new BeanWrapperFieldExtractor<RedevableCRE>();
beanWrapper.setNames(new String[]{
"id", "firstName", "lastName", "phone", "address"
});
aggregator.setFieldExtractor(beanWrapper);
flatWriter.setLineAggregator(aggregator);
flatWriter.setEncoding("ISO-8859-1");
return flatWriter;
}
Adicionei meu bean Tasklet
@Bean
public SettingFilenamesTasklet settingFilenames() {
return new SettingFilenamesTasklet();
}
E eu criei uma nova etapa para adicionar na minha declaração de trabalho
@Bean
public Step stepSettings(StepBuilderFactory stepBuilderFactory, SettingFilenamesTasklet tasklet, ExecutionContextPromotionListener listener) {
return stepBuilderFactory.get("stepSettings").tasklet(tasklet).listener(listener).build();
}
Por enquanto, o FlatFileItemReader ainda usa o valor jobParameters. Quero fazer meu FlatFileItemWriter funcionar primeiro. Estou tendo o erro a seguir :
[...]
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [org.springframework.batch.item.file.FlatFileItemWriter]: Factory method 'flatFileWriter' threw exception; nested exception is java.lang.NullPointerException
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:189)
at org.springframework.beans.factory.support.ConstructorResolver.instantiateUsingFactoryMethod(ConstructorResolver.java:591)
... 87 common frames omitted
Caused by: java.lang.NullPointerException: null
at java.io.File.<init>(Unknown Source)
at batchTest.BatchConfiguration.flatFileWriter(BatchConfiguration.java:165)
at batchTest.BatchConfiguration$EnhancerBySpringCGLIB$5d415889.CGLIB$flatFileWriter$1(<generated>)
at batchTest.BatchConfiguration$EnhancerBySpringCGLIB$5d415889$FastClassBySpringCGLIB$969a8527.invoke(<generated>)
at org.springframework.cglib.proxy.MethodProxy.invokeSuper(MethodProxy.java:228)
at org.springframework.context.annotation.ConfigurationClassEnhancer$BeanMethodInterceptor.intercept(ConfigurationClassEnhancer.java:312)
at batchTest.BatchConfiguration$EnhancerBySpringCGLIB$5d415889.flatFileWriter(<generated>)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
at java.lang.reflect.Method.invoke(Unknown Source)
at org.springframework.beans.factory.support.SimpleInstantiationStrategy.instantiate(SimpleInstantiationStrategy.java:162)
... 88 common frames omitted
Tentei substituir a anotação @StepScope por @JobScope; colocar meus parâmetros diretamente em jobExecutionContext (+ JobExecutionListener) em vez de usar StepContext + promotionListener ... Nada funciona. O arquivo de recurso é sempre nulo quando tento criar o FlatFileItemWriter.
O que estou perdendo ?
Obrigado pela ajuda.