airflow - 如何在工作日上午 9 点到下午 4 点每 10 分钟运行一次气流

Question

我有一个 DAG，需要安排在工作日（周一至周五）上午 9 点至下午 4 点之间每 10 分钟运行一次。我如何在气流中做到这一点。

Answer 1

使用 cron 表达式设置您的 DAG：*/10 9-16 * * 1-5这意味着在从 Monday 到 Friday 的每一天从 9 到 16 的每个小时的每 10 分钟。请参阅crontab 大师。

dag = DAG(
    dag_id='my_dag',
    schedule_interval='*/10 9-16 * * 1-5',
    start_date=datetime(2021, 1, 1),
)