Bakåtfyllnad av historiska data
Försenat inkommande data är en realitet. Din daily_sales_load-dag har fungerat bra, men orderdata för 20–22 april landade i raw_orders först idag – vilket lämnade tre luckor i daily_summary. Lösningen är en bakåtfyllnad. Dagen är redan aktiv, så du kommer att se en scheduled-körning för dagens datum tillsammans med de bakåtfyllnadskörningar du skapar.
- Kör
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1i terminalen. - Vänta ungefär 30 sekunder tills bakåtfyllnadskörningarna är klara.
- Kör
airflow dags list-runs daily_sales_loadför att se alla körningar.
Titta på kolumnen run_id i utdata. Vilket prefix börjar bakåtfyllnadskörningarna med?
Den här övningen är en del av kursen
Bygg datapipelines med Airflow
Interaktiv övning med praktiskt arbete
Gör teori till handling med en av våra interaktiva övningar
Starta övningen