【发布时间】:2022-01-21 20:23:36
【问题描述】:
我有一个 DAG,需要安排在工作日(周一至周五)上午 9 点至下午 4 点之间每 10 分钟运行一次。我如何在 Airflow 中执行此操作。
【问题讨论】:
标签: airflow airflow-2.x airflow-webserver
我有一个 DAG,需要安排在工作日(周一至周五)上午 9 点至下午 4 点之间每 10 分钟运行一次。我如何在 Airflow 中执行此操作。
【问题讨论】:
标签: airflow airflow-2.x airflow-webserver
使用 cron 表达式设置您的 DAG:*/10 9-16 * * 1-5 这意味着在每周一到周五的每一天,从 9 点到 16 点,每个小时过去 10 分钟。见crontab guru。
dag = DAG(
dag_id='my_dag',
schedule_interval='*/10 9-16 * * 1-5',
start_date=datetime(2021, 1, 1),
)
【讨论】: