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.
- 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. - Počkej přibližně 30 sekund, než backfill běhy dokončí zpracování.
- Spusť
airflow dags list-runs daily_sales_loada 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
Interaktivní praktické cvičení
Proměňte teorii v praxi s jedním z našich interaktivních cvičení
Začít cvičení