Обидва Dags — sales_producer і sales_consumer — з попередніх вправ завантажено в інтерфейс Airflow. Продюсер записує дані про продажі та оновлює актив s3://data-lake/sales/daily.csv. Споживач розкладений на цей актив.

Виконайте такі кроки:

У поданні Dags знайдіть sales_producer і sales_consumer та активуйте їх за допомогою перемикача.
Запустіть sales_producer, натиснувши піктограму відтворення, оберіть Single Run, потім Trigger.
Дочекайтеся завершення запуску продюсера (усі завдання позначені зеленим).
Перевірте, чи sales_consumer запустився автоматично без ваших кліків.

Що відбувається зі sales_consumer після завершення запуску sales_producer?

Планування з урахуванням даних за допомогою Assets

Create Your Free Account