我有一个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表达一个。DAG可以通过对cron表达式进行迭代来动态创建
- 每15分钟运行一次DAG,并使用
PythonBranchOperator
(Airflow Documentation(来确定时间是否与3个cron表达式中的一个匹配。我过去使用过croniter软件包来匹配不同cron表达的气流execution_date