使用Cronitier的气流

Question

我正在尝试使用Cronitier计划作业，每月作业运行2个星期二。我在下面尝试过，这是我的部分脚本。

从croniter导入croniter

cron = croniter("00 21 ** 2#2")

dag = DAG('recurring_job'，catchup=False，default_args=default_args，schedule_interval=cron)，但它不工作。你能帮助我或给我一些推荐信吗？

Answer 1

您可以直接指定cron字符串：

dag = DAG('recurring_job', schedule_interval="00 21 * * 2#2")

Airflow将在内部使用croniter进行转换。

Answer 2

Airflow还支持schedule_interval的datetime.timedelta对象，请参阅Scheduling & Triggers

每个DAG可能有计划，也可能没有计划，该计划通知如何创建DAG运行。schedule_interval被定义为DAG参数，并且最好接收作为str、或datetime.timedelta对象的cron表达式。

与start_date一起，它应该在不使用croniter的情况下工作：

dag = DAG('recurring_job', catchup=False, default_args=default_args, schedule_interval=datetime.timedelta(weeks=2), start_date = datetime(2020,11,3,21))