НачатьНачать бесплатно

Бэкфилл исторических данных

Данные, поступающие с опозданием, — обычное явление. Ваш DAG daily_sales_load работал без сбоев, однако данные о заказах за 20–22 апреля попали в raw_orders только сегодня, оставив три пробела в daily_summary. Решение — бэкфилл. DAG уже активен, поэтому вы увидите запуск scheduled за сегодня наряду с созданными вами запусками бэкфилла.

  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 секунд, пока запуски бэкфилла завершатся.
  3. Выполните команду airflow dags list-runs daily_sales_load, чтобы просмотреть все запуски.

Посмотрите на столбец run_id в выводе. С какого префикса начинаются запуски бэкфилла?

Это упражнение является частью курса

Построение пайплайнов данных с Airflow

Посмотреть курс

Практическое интерактивное упражнение

Превратите теорию в практику с помощью одного из наших интерактивных упражнений

Начать упражнение