议程作业，是否可以安排在前一个作业完成后触发作业？

Question

我在 nodejs 中使用agenda jobs。我想知道是否可以定义一个具有依赖关系的工作。 就我而言，我有 3 个作业，每个作业都执行整个逻辑的一部分，这非常大，这就是它们分开的原因。

1. 在Job 1 中，我从数据库中收集信息，对其进行转换并执行一些任务。
2. 在Job 2 中，我获取了之前由Job 1 处理的所有数据并执行新的转换..
3. 在Job 3 中，我再次获取了在Job 2 中处理过的所有数据并发送了一些报告。

我将这些任务安排为每 5 分钟执行一次。但问题是它们三个是同时调度的，因为它们是动态调度的。

job1.schedule("now");
job1.repeatEvery('5 minutes');

job2.schedule("now");
job2.repeatEvery('5 minutes');

job3.schedule("now");
job3.repeatEvery('5 minutes');

按照目前的配置，要处理一个需要完成 3 个作业的实例，最坏的情况是用户需要等待 15 分钟，这并不理想。

我想知道是否有一个选项来定义任务应该在前一个任务完成后立即执行。我知道一个可能的解决方法是安排具有几分钟差异的作业，但鉴于根据实例的数量，作业可能需要更多或更少的时间，这对我不起作用。

Answer 1

我做一件非常相似的事情的方式是，当前一个作业的主要功能完成时，我触发下一个作业，这样我可以将数据从一个作业馈送到另一个作业并按顺序运行它们。

所以我在job2的定义中触发job3，在job1的定义中触发job2：

// DEFINE JOBS
agenda.define('job1', (job) => {
    return myMainJob1Function(job.attrs.data)
      .then((data) => {
        for (const element of data) {
          agenda.now('job2', { // runs many instances of 'job2' job with distinct data
            // use output data from the "parent" job
            arg1: element.arg1,
            arg2: element.arg2,
            arg3: element.arg3,
            arg4: job.attrs.data.someArg, // this will propagate an argument we set for the "parent" job
          });
        }
      });
  });

agenda.define('job2', (job) => {
    return myMainJob2Function(job.attrs.data) // data supplied from 'job1'
      .then((data) => {
        for (const element of data) {
          agenda.now('job3', { // runs many instances of 'job3' job with distinct data
            // use output data from the "parent" job
            arg1: element.arg1,
            arg2: element.arg2,
            arg3: element.arg3,
            arg4: job.attrs.data.someArg, // this will propagate an argument we set for the "parent" job
          });
        }
      });
  });

agenda.define('job3', (job) => {
    return myMainJob3Function(job.attrs.data) // data supplied from 'job2'
      .then((data) => {
        // save data to database or do something else
      });
  });

// TRIGGER 'job1', WHICH TRIGGERS CHILD JOBS
agenda.now('job1', { someArg: 5 }); // we're providing some initial argument, that gets passed onto child jobs
const schedule = '0 0/5 0 ? * * *' // cron expression for every 5 minutes
agenda.every(schedule, 'job1', { someArg: 5 });

想到的另一件事是为complete 或success 或job1 使用触发器，但是当您使用不同的输入数据运行许多相同的作业时，您不能（我还没有找到一种方法) 监听与您想要的特定作业实例相关的事件。

话虽如此，你可以做到：

agenda.on('success:job1', (job) => {
  agenda.now('job2', { someArg: job.attrs.data.someArg });
});