【问题标题】:How to schedule a task at midnight and the other tasks every hour in the same DAG如何在同一个 DAG 中安排午夜的任务和每小时的其他任务
【发布时间】:2021-06-20 04:00:16
【问题描述】:

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

如你所见,我有两个scheduler_interval

0 0 * * *(每天午夜)=> 创建一个新文件

0 * * * *(每小时)=> 追加数据

有解决这个问题的办法吗?

【问题讨论】:

    标签: airflow-scheduler airflow


    【解决方案1】:

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

    【讨论】:

      猜你喜欢
      • 2016-08-08
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2012-04-29
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2016-11-27
      相关资源
      最近更新 更多