python - 如何在特定日期的特定时间运行 Airflow？

Question

我尝试在每月 2 日上午 11 点运行 Airflow，但未能成功。我的设置是:

default_args = {
    'owner': 'airflow',
    'depends_on_past': False,
    'start_date': today_date,
    'email': ['mymail'],
    'email_on_failure': True,
    'email_on_retry': True,
    'retries': 1,
    'retry_delay': timedelta(minutes=7),
}

dag = DAG('my_dag', default_args=default_args, schedule_interval='00 11 02 * *')

当我每天运行 DAG 时，Airflow 工作完美:

schedule_interval='00 11 * * *'

但我似乎无法使其按月运行:(

谢谢!

Answer 1

如果您想在每月 2 日上午 11 点运行您的 dag。您可以使用此代码。

schedule_interval = '0 11 2 * *'

dag_name = DAG(
    'DAG_ID',
    default_args=default_args,
    schedule_interval=schedule_interval,
)

在计划间隔中，0 指分钟，11 指小时，2 指月中的某一天，* 指任何月份，下一个 * 指一周中的任何一天。

有关更多调度程序信息，请查看此网站。 https://crontab.guru/#0_11_2_ _