重新启动spring批处理作业

Question

我有一个spring批处理作业，从CSV文件读取并写入数据库。我想让它重新启动。例如，如果在读取文件或写入db时出现异常，导致作业失败，则应从失败的同一点/块重新开始，而不是从头开始读取整个文件。

我正在从一个endpoint触发作业启动器，并在我的控制器中配置了它。

目前，我正在通过控制器将参数jobid（这是一个唯一的标识符/数字）传递给作业参数，以运行新的作业实例。如果作业失败，我将使用与GET请求中的params相同的jobid再次触发它，它将按照预期从上次作业ID失败的地方重新启动作业。这种方法的问题是我必须手动维护一个单独的jobId参数列表。即使必须运行新的作业实例，我也不想提供自己的jobId参数。此外，如果在GET请求中没有传递jobidparam的任何值，则此方法将失败，因此也将无法重新启动该作业实例。

我希望是否有一种方法可以在没有任何自己的参数的情况下为每个新的作业实例触发endpoint，如果作业失败，我希望通过使用spring批处理元数据表的job_execution_id或job_instance_id重新启动它。

控制器：

@Autowired
JobLauncher jobLauncher;

@Autowired
Job demoJob;

@GetMapping("/demo")
public BatchStatus runDemoJob(@RequestParam(name = "jobId", required = false) String jobId) 
throws JobParametersInvalidException, JobExecutionAlreadyRunningException, JobRestartException, JobInstanceAlreadyCompleteException 
{
        JobParameters p = new JobParameters();

        if (!jobId.isEmpty()) {
            p = new JobParametersBuilder().addString("jobId", jobId).toJobParameters();
        }

        JobExecution j = jobLauncher.run(demoJob, p);

        return j.getStatus();

    }
}

Answer 1

我不得不一次又一次地读取相同的文件，因为其中的数据发生了变化

批处理是关于固定数据集的。具有更改内容的单个文件不是固定的数据集。流式解决方案可能更适合您的用例。spring批处理作业实例应该表示一个固定的数据集（通过标识作业参数来标识）。这对可重启性至关重要。