Планирование на основе ассетов в действии
В интерфейс Airflow загружены оба DAG — sales_producer и sales_consumer — из предыдущих упражнений. Производитель записывает данные о продажах и обновляет ассет s3://data-lake/sales/daily.csv. Потребитель запланирован на основе этого ассета.
Выполните следующие шаги:
- В представлении DAG найдите оба DAG —
sales_producerиsales_consumer— и активируйте их с помощью переключателя. - Запустите
sales_producer: нажмите на иконку воспроизведения, выберите Single Run, затем Trigger. - Дождитесь завершения запуска производителя (все задачи должны стать зелёными).
- Проверьте, был ли
sales_consumerзапущен автоматически — без каких-либо действий с вашей стороны.
Что происходит с sales_consumer после завершения запуска sales_producer?
Это упражнение является частью курса
Построение пайплайнов данных с Airflow
Практическое интерактивное упражнение
Превратите теорию в практику с помощью одного из наших интерактивных упражнений
Начать упражнение