如何配置Airflow dag在每天的特定时间运行？

Question

如何将Airflow dag配置为每天在指定时间执行,无论发生什么,都像crons一样.

我知道使用TimeSensor可以获得类似的行为,但在这种情况下,它取决于传感器任务,并且可能与dag执行时间冲突.

示例:使用传感器方法,如果我有传感器在0小时15分钟运行但是如果稍后执行dag则我的任务被延迟,所以即使对于传感器方法,我需要确保Dag在正确的时间执行.

那么如何确保Dag在指定时间执行？

Answer 1

例如,每天早上2:30开始DAG,您可以执行以下操作:

DAG(
   dag_id='dag_id',
   # start date:28-03-2017
   start_date= datetime(year=2017, month=3, day=28),
   # run this dag at 2 hours 30 min interval from 00:00 28-03-2017
   schedule_interval='30 2 * * *')

在配置调度之前,可以在此处验证和测试对cron间隔的解释:https://crontab.guru/