我需要在周一至周四晚上 7 点安排工作,周五我需要在晚上 11 点安排工作。我正在使用 Airflow 并且需要 cron 制表符,例如
0 19 * * 周一至周四
欢迎任何建议。
谢谢
问候, CJ
我需要在周一至周四晚上 7 点安排工作,周五我需要在晚上 11 点安排工作。我正在使用 Airflow 并且需要 cron 制表符,例如
0 19 * * 周一至周四
欢迎任何建议。
谢谢
问候, CJ
您可以将 dag 创建为:
dag = DAG("Your_dag", default_args=default_args, schedule_interval="0 19 * * 1-4")
你可以这样做:
schedules = {
'M-Th': '0 19 * * 1-4',
'F': '0 23 * * 5',
}
for name, schedule in schedules.items():
globals()[name] = DAG('<base_dag_name.' + name, default_args=default_args, schedule_interval=schedule)
这将从单个文件创建两个 DAG。DAG 需要在全球范围内才能被 Airflow 识别。