Airflow: планирование задачи несколько раз в день

Я получаю информацию от пользователя о расписании задач. Я хочу запускать задачу несколько раз в день. Как это возможно с помощью Airflow?


airflow airflow-scheduler
person Bhavik Thakkar    schedule 19.06.2018    source источник
comment
Может ли пользователь выбрать разное время? это бесплатная форма или вы даете фиксированный список вариантов на выбор? Возможно, снимок экрана поможет разобраться в вашей проблеме.   -  person skozz    schedule 19.06.2018
comment
@skozz, Пользователь может выбрать любые пять временных записей.   -  person Bhavik Thakkar    schedule 21.06.2018

Ответы (1)


arrow_upward
2
arrow_downward

Вы можете запланировать запуск группы DAG несколько раз в день, используя аргумент schedule_interval в вашей группе DAG следующим образом:

dag = DAG(
    dag_id='fake_dag',
    schedule_interval="* * * * *"
    )

schedule_interval использует формат CRON. Это может помочь вам понять формат CRON.

Пример: если вы хотите, чтобы ваш DAG запускался каждые 4 часа в течение дня, ваш DAG будет выглядеть следующим образом:

dag = DAG(
    dag_id='fake_dag',
    schedule_interval="* 0-23/4 * * *"
    )
person Zack    schedule 19.06.2018
comment
Разве это не запускало бы даг каждую минуту каждые 4 часа? - person Bigmoose70; 08.04.2020
comment
@ Bigmoose70 Ха-ха, да, вы правы! 0 0-23/4 * * *, вероятно, более точно соответствует примеру, который я собирался использовать. - person Zack; 08.04.2020