ПочатиПочніть безкоштовно

Як працює планування на основі активів

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

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

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

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

Ця вправа є частиною курсу

Створення конвеєрів даних з Airflow

Переглянути курс

Практична інтерактивна вправа

Перетворіть теорію на практику за допомогою однієї з наших інтерактивних вправ

Почати вправу