带有不同参数的春季批次运行相同的工作

Question

我的春季批处理作业在传递某些作业参数时运行。现在，我想实现的是一个超级作业，它构建了作业参数列表，并使用不同的作业参数执行此批处理作业。

我正在使用Joblauncher使用不同参数触发

作业

java.lang.IllegalStateException: Existing transaction detected in JobRepository. Please fix this and try again (e.g. remove @Transactional annotations from client).

。

fun runJobs(jobParams: List<JobParameters>): List<JobExecution> =
      jobParams.map { jobParam ->
        jobLauncher.run(someJob, jobParam)
      }

批处理

Answer 1

此错误意味着您正在尝试在交易范围内启动作业，情况并非如此。似乎fun runjobs（）用@transactional或建议以另一种方式进行交易。

是否有一个示例可以通过编程方式触发不同的作业参数？

这是一个快速示例：

JobParameters jobParameters1 = new JobParametersBuilder()
        .addString("name", "foo")
        .toJobParameters();
JobParameters jobParameters2 = new JobParametersBuilder()
        .addString("name", "bar")
        .toJobParameters();
jobLauncher.run(job, jobParameters1);
jobLauncher.run(job, jobParameters2);

Answer 2

我能够使用 JobStep 。

private fun jobSteps(jobParams: List<JobParams>): List<Step> =
      jobParams.map { jobParam ->
        jobStep(
            JobParametersBuilder()
                .addString("param1", jobParam.param1)
                .addString("param2", jobParam.param2))
      }

private fun jobStep(jobParameters: JobParameters): Step =
      stepBuilderFactory
          .get("step-{some-unique-name-to-identify-each-job}")
          .job(<Job which needs to be executed for different params>)
          .parametersExtractor { _: Job, _: StepExecution -> jobParameters } // Here we are passing parameters for each job.
          .build()

首先创建作业步骤。现在，我们将有一个步骤列表。它们是工作步骤的步骤，需要将它们连接到超级工作，并且它们独立于每个工作。

private fun superJob(steps: List<Step>): Job {
    val jobBuilder: JobFlowBuilder =
jobBuilderFactory["superJob"].flow(<put a dummy start step here>)

    return steps
        .fold(jobBuilder) { builder: FlowBuilder<FlowJobBuilder>, step: Step ->
          builder.on("*").to(step)
        }
        .end()
        .build()
  }

条件：

1. 这将确保从作业启动器启动超级作业时，为不同的参数运行相同的作业。
2. 这将依次启动工作步骤。如果您正在寻找并行运行它们，请关注（ https：//stackoverflow.com/a/a/375499696/7275579 ）。
3. 超级作业需要从唯一的作业参数开始，例如当前时间毫秒 /日期，因此在下一步运行中，它不应返回，因为abos已经存在或已完成< / code>。