Backfill історичних даних
Дані, що надходять із запізненням, — це реальність. Ваш Dag daily_sales_load працював справно, але дані замовлень за 20–22 квітня потрапили в raw_orders лише сьогодні, тож у daily_summary залишилися три прогалини. Виправлення — це backfill. Dag уже активний, тож ви побачите сьогоднішній запуск scheduled поруч із запуском backfill, який ви створите.
- Запустіть у терміналі
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1. - Зачекайте приблизно 30 секунд, доки запуски backfill завершаться.
- Запустіть
airflow dags list-runs daily_sales_load, щоб побачити всі запуски.
Подивіться на стовпчик run_id у виводі. З якого префікса починаються запуски backfill?
Ця вправа є частиною курсу
Створення конвеєрів даних з Airflow
Практична інтерактивна вправа
Перетворіть теорію на практику за допомогою однієї з наших інтерактивних вправ
Почати вправу