Zugriff Auf Job-Parameter Spring Batch
Habe ich Schwierigkeiten mit dem Zugriff auf Job-Parameter des job-mit spring batch. Hier ist meine Implementierung so weit.
@Configuration
@EnableBatchProcessing
@PropertySource("classpath:batch.properties")
public class CSVBatchServiceImpl extends StepExecutionListenerSupport implements CSVBatchService {
private static final Logger LOGGER = LoggerFactory.getLogger(CSVBatchServiceImpl.class);
@Autowired
public JobBuilderFactory jobBuilderFactory;
@Autowired
public StepBuilderFactory stepBuilderFactory;
private QuestionReader questionReader = new QuestionReader();
@Bean(name = "importQuestionsJob")
public Job importQuestionsJob() {
return jobBuilderFactory.get("importQuestionsJob")
.incrementer(new RunIdIncrementer())
.flow(step1())
.end()
.build();
}
@Bean
public Step step1() {
return stepBuilderFactory.get("step1")
.<Question, Question>chunk(2)
.reader(questionReader.reader())
.processor(processor())
.build();
}
@Bean
public QuestionProcessor processor() {
return new QuestionProcessor();
}
}
class QuestionReader extends StepExecutionListenerSupport {
private static final Logger LOGGER = LoggerFactory.getLogger(QuestionReader.class);
//TODO: remove this
private static JsonNode getJsonNode(String str) {
try {
ObjectMapper mapper = new ObjectMapper();
return mapper.readTree(str);
} catch (IOException e) {
throw new RuntimeException(e);
}
}
@Bean
public FlatFileItemReader<Question> reader() {
FlatFileItemReader<Question> reader = new FlatFileItemReader<>();
//TODO get this as a parameter
reader.setResource(new ClassPathResource("duplicateLabels.csv"));
reader.setLinesToSkip(1);
reader.setLineMapper(new DefaultLineMapper<Question>() {{
setLineTokenizer((new DelimitedLineTokenizer() {{
setNames(new String[]{"label", "body", "real_answer"});
}}));
setFieldSetMapper(new QuestionFieldSetMapper());
}});
return reader;
}
private static class QuestionFieldSetMapper implements FieldSetMapper<Question> {
public Question mapFieldSet(FieldSet fieldSet) {
Question question = new Question();
question.setLabel(fieldSet.readString(0));
question.setBody(getJsonNode(fieldSet.readString(1)));
question.setRealAnswer(getJsonNode(fieldSet.readString(2)));
return question;
}
}
}
Rufe ich den job wie:
JobParameters parameters = new JobParametersBuilder()
.addLong("time", System.currentTimeMillis())
.addString("filePath", "file.csv")
.toJobParameters();
jobLauncher.run(importQuestionsJob, parameters);
Wie kann ich den Zugriff auf den filePath-parameter, die in reader-Funktion?
Du musst angemeldet sein, um einen Kommentar abzugeben.
Sollten Sie in der Lage, das zu tun ,
Im Falle von Fragen, können Sie versuchen Sie Ihre Leser in
@StepScope
.reader()
Methode, so dass Sie ändern können-reader Signatur wiereader(@Value("#{jobParameters['filePath']}") String filePath)
aber stellen Sie sicher, dass Sie kommentierenreader
mit@StepScope
. In Ihrem Schritt definition, die Sie übergeben könnennull
für diesen parameter wiequestionReader.reader(null)
.Können Sie
org.springframework.batch.core.listener.JobParameterExecutionContextCopyListener
zu Ihrem Schritt.TaskletStep step = stepBuilderFactory.get("my-best-step")
.<Item, Item>chunk(10)
.reader(myBestReader)
.writer(myBestWriter)
.listener(new JobParameterExecutionContextCopyListener())
.build();
Dieser Listener wird, kopieren Sie
JobParameters
zuExecutionContext
im ItemReader öffnen und update-Methoden