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

Backfill історичних даних

Дані, що надходять із запізненням, — це реальність. Ваш Dag daily_sales_load працював справно, але дані замовлень за 20–22 квітня потрапили в raw_orders лише сьогодні, тож у daily_summary залишилися три прогалини. Виправлення — це backfill. Dag уже активний, тож ви побачите сьогоднішній запуск scheduled поруч із запуском backfill, який ви створите.

  1. Запустіть у терміналі airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1.
  2. Зачекайте приблизно 30 секунд, доки запуски backfill завершаться.
  3. Запустіть airflow dags list-runs daily_sales_load, щоб побачити всі запуски.

Подивіться на стовпчик run_id у виводі. З якого префікса починаються запуски backfill?

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

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

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

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

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

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