НачатьНачать бесплатно

Планирование на основе ассетов в действии

В интерфейс Airflow загружены оба DAG — sales_producer и sales_consumer — из предыдущих упражнений. Производитель записывает данные о продажах и обновляет ассет s3://data-lake/sales/daily.csv. Потребитель запланирован на основе этого ассета.

Выполните следующие шаги:

  1. В представлении DAG найдите оба DAG — sales_producer и sales_consumer — и активируйте их с помощью переключателя.
  2. Запустите sales_producer: нажмите на иконку воспроизведения, выберите Single Run, затем Trigger.
  3. Дождитесь завершения запуска производителя (все задачи должны стать зелёными).
  4. Проверьте, был ли sales_consumer запущен автоматически — без каких-либо действий с вашей стороны.

Что происходит с sales_consumer после завершения запуска sales_producer?

Это упражнение является частью курса

Построение пайплайнов данных с Airflow

Посмотреть курс

Практическое интерактивное упражнение

Превратите теорию в практику с помощью одного из наших интерактивных упражнений

Начать упражнение