Začněte nyníZačněte zdarma

Doplnění historických dat (backfill)

Zpožděná data jsou v praxi běžná věc. Tvůj DAG daily_sales_load fungoval bez problémů, ale data objednávek za 20.–22. dubna dorazila do raw_orders až dnes – v daily_summary tak vznikly tři mezery. Řešením je backfill. DAG je už aktivní, takže vedle backfill běhů, které vytvoříš, uvidíš i scheduled běh pro dnešní den.

  1. Spusť v terminálu příkaz airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1.
  2. Počkej přibližně 30 sekund, než backfill běhy dokončí zpracování.
  3. Spusť airflow dags list-runs daily_sales_load a zobraz všechny běhy.

Podívej se na sloupec run_id ve výstupu. Jakým prefixem začínají backfill běhy?

Toto cvičení je součástí kurzu

Tvorba datových pipeline s Airflow

Zobrazit kurz

Interaktivní praktické cvičení

Proměňte teorii v praxi s jedním z našich interaktivních cvičení

Začít cvičení