Як працює планування на основі активів
Обидва 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?
Ця вправа є частиною курсу
Створення конвеєрів даних з Airflow
Практична інтерактивна вправа
Перетворіть теорію на практику за допомогою однієї з наших інтерактивних вправ
Почати вправу