如何配置Airflow DAG从每小时第2分钟开始每5分钟执行一次？

对应的cron表达式为：2/5 * * * *

表达式解析： #

• 分钟位：2/5 表示从每小时的第2分钟开始，之后每隔5分钟触发一次，完全匹配你需要的12:02、12:07、12:12...的执行节奏
• 小时位：* 表示每小时都生效
• 日/月/星期位：* 表示不限制日期、月份和星期，每天都会按规则执行

Airflow DAG 配置示例： #

在定义DAG时，直接将该表达式赋值给schedule参数即可：

from airflow import DAG
from datetime import datetime

with DAG(
    dag_id="your_dag_id",
    start_date=datetime(2024, 1, 1),
    schedule="2/5 * * * *",  # 这里使用目标cron表达式
    catchup=False
) as dag:
    # 你的任务定义...

内容的提问来源于stack exchange，提问作者Thilina