【发布时间】:2021-06-20 04:00:16
【问题描述】:
我想知道是否可以在单个 DAG 中使用不同的调度程序,我解释一下我的用例:每天午夜执行的任务以创建一个文件(每个天),其他任务将每小时执行一次以追加数据到文件中。
如你所见,我有两个scheduler_interval
0 0 * * *(每天午夜)=> 创建一个新文件
0 * * * *(每小时)=> 追加数据
有解决这个问题的办法吗?
【问题讨论】:
我想知道是否可以在单个 DAG 中使用不同的调度程序,我解释一下我的用例:每天午夜执行的任务以创建一个文件(每个天),其他任务将每小时执行一次以追加数据到文件中。
如你所见,我有两个scheduler_interval
0 0 * * *(每天午夜)=> 创建一个新文件
0 * * * *(每小时)=> 追加数据
有解决这个问题的办法吗?
【问题讨论】:
您可以使用 python 分支运算符来解决您的问题。这个 python 分支操作符将检查当前时间是否是午夜然后去创建一个文件任务,否则去任务将数据附加到文件中。调度程序应该是每小时一次。
【讨论】: