时间戳

首页 > 解决方案 > 安排 DAG 在 Airflow 中每 45 分钟运行一次

airflow - 安排 DAG 在 Airflow 中每 45 分钟运行一次

问题描述

我有一个 DAG 需要安排为每 45 分钟运行一次（00:00、00:45、1:30、2:15 等）我如何在 Airflow 中执行此操作。简单的 cron 条目如下所示：

0,45 0-23/3 * * *

30 1-23/3 * * *

15 2-23/3 * * *

如何使用上述 cron 条目安排 DAG。

谢谢

标签： airflowairflow-scheduler

解决方案

schedule_interval只支持一个 cron 表达式。

我看到两个选项：

  • 有 3 个 DAG，每个 cron 表达式一个。DAG 可以通过迭代 cron 表达式来动态创建。
  • 每 15 分钟运行一次 DAG 并使用PythonBranchOperator（气流文档）来确定时间是否与 3 个 cron 表达式之一匹配。我过去使用croniter包来匹配气流execution_date与不同的 cron 表达式

推荐阅读