что означают выполнение_даты и засыпка в потоке воздуха

Question

Я новичок в воздушном потоке, и я пытаюсь понять, что означает execution_date в контексте воздушного потока.Я прочитал страницу учебника из документации airflow, в которой говорится, что

Дата, указанная в этом контексте, является execute_date, который имитирует планировщик, выполняющий вашу задачу или dag на определеннойдата + время:

Я пытался запустить задачу из учебника, используя следующую команду.

airflow test tutorial print_date 2015-06-01

Я ожидал, что она напечатает execution_date, но задача печатает фактическуюдата в моей локальной системе, как это.

[2018-05-26 20:36:13,880] {bash_operator.py:101} INFO - Sat May 26 20:36:13 IST 2018

Я думал, что планировщик будет моделироваться в данный момент времени.Так что я запутался здесь, понимая о execution_date param.Может ли кто-нибудь помочь мне понять это?Благодаря.

Answer 1

Печатает текущее время в вашем журнале, потому что оно действительно было выполнено в это время.

Дата выполнения - это параметр запуска DAG.Задачи могут использовать его, чтобы иметь ссылку на дату, отличную от того, когда задача будет фактически выполнена.

Пример: скажем, вы заинтересованы в хранении курсов валют один раз в день.Вы хотите получать тарифы с 2010 года. В вашей группе DAG будет задана задача вызвать API, который будет возвращать курс валюты за день.Можно создать группу обеспечения доступности баз данных с датой начала 2010-01-01 с расписанием один раз в день.Даже если вы создадите его сейчас, в 2018 году, он будет работать каждый день, начиная с даты начала, и благодаря дате выполнения у вас будут правильные данные.