一天安排气流 2 次

Question

我是 Airflow 的新手，想问一下如何在一天内安排 2 次 Airflow 工作流程，例如我需要从 2022 年 3 月 24 日起在 10:00 am 和 7:00 pm 安排 airflow dag，所以经过一些研究我认为它会像

interval='0 10,19 * * *'
date='2022-03-23'
schedule_interval=interval
start_date=date

我的理解对吗？

提前致谢，

Answer 1

是的。您需要将 DAG 对象创建为：

from datetime import datetime
from airflow import DAG
dag = DAG(dag_id='my_dag',
          schedule_interval='0 10,19 * * *',
          start_date=datetime(2022, 3, 23),
          catchup=False)

注意：如果您希望您的第一个运行在 2022-03-24 在 10:00 开始，那么您的 start_date 需要 datetime(2022, 3, 23, 19, 0) 这是因为 Airflow 计划在间隔结束时运行。有关详细信息，请参阅此。

一天安排气流 2 次

schedule airflow 2 times in a day

airflow

airflow-scheduler