Воздушный поток с использованием Cronitier

17.11.2020Рубрика: ВопросыАвтор: admin

Я пытаюсь использовать Cronitier, чтобы запланировать задание, которое будет выполняться ежемесячно каждые 2 вторника. Я пробовал ниже Это мой частичный сценарий.

из croniter импорт croniter

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

dag = DAG (‘recurring_job’, catchup = False, default_args = default_args, schedule_interval = cron) Но это не сработало. Не могли бы вы помочь мне или дайте ссылку.

Не могли бы вы предоставить сообщение об ошибке? — person Murali Krishna schedule 18.11.2020

Post Views: 136

См. также: Как запланировать запуск двух групп DAG в двух разных schedule_interval, но второй запускается только после завершения первого

2 airflow airflow-scheduler

Комментарии: 2

Murali Krishna 17.11.2020 в 00:00
Airflow также поддерживает объект datetime.timedelta для schedule_interval, см. Планирование и триггеры </ а>:
Каждая группа обеспечения доступности баз данных может иметь или не иметь расписание, в котором указывается, как создаются запуски группы доступности баз данных. schedule_interval определяется как аргументы DAG и предпочтительно получает выражение cron как объект str, или datetime.timedelta.

Вместе с 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))
Ответить
Murali Krishna 18.11.2020 в 00:00
Вы можете просто указать строку cron напрямую:
```
dag = DAG('recurring_job', schedule_interval="00 21 * * 2#2")
```
Airflow переведет это с помощью croniter внутри.
Ответить

Добавить комментарий