Планировщик воздушного потока каждые 15 секунд - PullRequest
0 голосов
/ 19 марта 2020

Я хочу написать DAG, которая будет запускать API REST каждые 15 секунд. Но cron, указанный в schedule_interval, имеет формат (* * * * *), где минимальное измерение может быть задано в минутах. Есть ли альтернативный способ решить эту проблему?

При написании DAG я предоставляю параметр schedule_interval, который принимает выражение cron, как показано ниже:

dag = DAG ('trigger_api', description = 'TriggerAPI 15 se c interval ', schedule_interval =' * * * * * ', start_date = datetime (2020, 1, 1), catchup = False)

Выше DAG будет запускаться каждую минуту, но я хочу планируйте это каждые 15 секунд.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...