安排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。

感谢

schedule_interval只支持一个cron表达式。

我看到两个选项:

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

最新更新