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