JobParameter在SpringBatch中傳遞給處理器類

我正在嘗試在資料庫中存盤 6 個 CSV 檔案資料。在這里，我將 CSV 資料轉換為另一個物件并保存它。

要創建物件，我需要來自其余端點的另一個欄位作為請求正文并將其作為 JobParameter 傳遞。

我需要在我的處理器類中訪問該引數。我嘗試了不同的方法。但我收到以下錯誤。任何解決方案都將不勝感激。

EL1008E: Property or field 'jobParameters' cannot be found on object of type 'org.springframework.beans.factory.config.BeanExpressionContext' - maybe not public or not valid?

這是我的休息終點：

@PostMapping
public void save(@RequestBody DownloadFileRequestDto downloadFileRequestDto) throws IOException {
    JobParameters JobParameters = new JobParametersBuilder()
            .addString("myParam", downloadFileRequestDto.getMyParam())
            .toJobParameters();
    try {
        JobExecution run = jobLauncher.run(job, JobParameters);

    } catch (JobExecutionAlreadyRunningException e) {
        throw new RuntimeException(e);
    } catch (JobRestartException e) {
        throw new RuntimeException(e);
    } catch (JobInstanceAlreadyCompleteException e) {
        throw new RuntimeException(e);
    } catch (JobParametersInvalidException e) {
        throw new RuntimeException(e);
    }
}

這是我的 Spring Batch 配置類：

@Configuration
@EnableBatchProcessing
@AllArgsConstructor

public class SpringBatchConfig {

    private JobBuilderFactory jobBuilderFactory;
    private StepBuilderFactory stepBuilderFactory;
    private UserRepository userRepository;


    @Bean
    public FlatFileItemReader<InputUser> reader() {
        FlatFileItemReader<InputUser> itemReader = new FlatFileItemReader<>();
        itemReader.setResource(new FileSystemResource("src/main/resources/users.csv"));
        itemReader.setName("csvReader");
        itemReader.setLinesToSkip(1);
        itemReader.setLineMapper(lineMapper());
        return itemReader;
    }

    private LineMapper<InputUser> lineMapper() {
        DefaultLineMapper<InputUser> lineMapper = new DefaultLineMapper<>();
        DelimitedLineTokenizer lineTokenizer = new DelimitedLineTokenizer();
        lineTokenizer.setDelimiter(",");
        lineTokenizer.setStrict(false);
        lineTokenizer.setNames("name", "salary");

        BeanWrapperFieldSetMapper<InputUser> fieldSetMapper = new BeanWrapperFieldSetMapper<>();
        fieldSetMapper.setTargetType(InputUser.class);
        lineMapper.setLineTokenizer(lineTokenizer);
        lineMapper.setFieldSetMapper(fieldSetMapper);
        return lineMapper;
    }
    
    @Bean
    public Processor processors() {
        return new Processor();
    }

    public RepositoryItemWriter<User> writer(){
        RepositoryItemWriter<User> writer = new RepositoryItemWriter<User>();
        writer.setRepository(userRepository);
        writer.setMethodName("save");
        return writer;
    }

    @Bean
    public Step step1(){
        return stepBuilderFactory.get("csv-step").<InputUser, User>chunk(500)
                .reader(reader())
                .processor(processors())
                .writer(writer())
                .taskExecutor(taskExecutor())
                .build();
    }


    @Bean
    public Job job(){
        return jobBuilderFactory.get("importUsers")
                .flow(step1())
                .end().build();
    }
    
    public TaskExecutor taskExecutor(){
        SimpleAsyncTaskExecutor simpleAsyncTaskExecutor = new SimpleAsyncTaskExecutor();
        simpleAsyncTaskExecutor.setConcurrencyLimit(50);
        return simpleAsyncTaskExecutor;
    }
}

這是我的處理器類，我需要訪問我的作業引數。

@Component
    @Scope("step")
public class Processor implements ItemProcessor<InputUser, User> {

    @Value("#{jobParameters['myParam']}")
    private String fileName;


    public Processor() {
    }

    public void setFileName(String fileName) {
        this.fileName = fileName;
    }

    @Override
    public User process(InputUser item) throws Exception {
        
        Random random = new Random();
        return new User(random.nextInt(), item.getName(), item.getSalary());
    }
}

uj5u.com熱心網友回復：

從類中洗掉@Component和。在配置中只宣告bean@ScopeProcessor

@Bean
@StepScope
public Processor processors(@Value("#jobParameters['myParam']}") String myParam) {
    return new Processor(myParam);
}

Processor在接受字串的類中添加一個建構式。

正如您在配置類中創建兩個Processor型別的bean，一個在配置類中創建一個，@Component但是在定義步驟時，您在配置中使用的方法不是步驟范圍，我認為spring 無法在其中注入值。

標籤：爪哇 春天 弹簧批

上一篇：如何使用curl發送帶有命令或腳本結果的發布請求？

下一篇：JSON中的嵌套JSON