如何在同一 DAG 中安排午夜任务和每小时其他任务

Question

我想知道是否可以在单个 DAG 中使用不同的调度程序，我解释一下我的用例：每天午夜执行的任务 创建文件 （每天一个新文件）其他任务将每小时执行一次，以 将数据 追加到文件中。

如你所见，我有两个 scheduler_interval

0 0 * * *（每天午夜）=> 创建一个新文件

0 * * * *（每小时）=>追加数据

有解决此问题的想法吗？

Answer 1

您可以使用python分支运算符来解决您的问题。此 python 分支运算符将检查当前时间是否为午夜，然后转到创建文件任务，否则转到将数据附加到文件的任务。调度程序应该是每小时一次。