在 Airflow 中每 45 分钟将 DAG 调度为 运行
Scheduling DAG to run every 45 minutes in Airflow
我有一个 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。
谢谢
schedule_interval只支持一个cron表达式。
我看到两个选项：
- 有 3 个 DAG，每个 cron 表达式一个。可以通过遍历 cron 表达式动态创建 DAG。
- 运行 DAG 每 15 分钟一次，使用
PythonBranchOperator（Airflow Documentation) to decide if the time matches one of the 3 cron expressions. I used croniter 包过去用于匹配气流 execution_date 针对不同的 cron 表达式
我有一个 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。
谢谢
schedule_interval只支持一个cron表达式。
我看到两个选项：
- 有 3 个 DAG，每个 cron 表达式一个。可以通过遍历 cron 表达式动态创建 DAG。
- 运行 DAG 每 15 分钟一次，使用
PythonBranchOperator（Airflow Documentation) to decide if the time matches one of the 3 cron expressions. I used croniter 包过去用于匹配气流execution_date针对不同的 cron 表达式