Completarea retrospectivă a datelor istorice
Datele care ajung cu întârziere sunt o realitate de neevitat. DAG-ul tău daily_sales_load a funcționat fără probleme, dar datele comenzilor din 20-22 aprilie au ajuns în raw_orders abia astăzi, lăsând trei goluri în daily_summary. Soluția este un backfill. DAG-ul este deja activ, așa că vei vedea o rulare scheduled pentru ziua de azi alături de rulările de backfill pe care le creezi.
- Rulează
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1în terminal. - Așteaptă aproximativ 30 de secunde ca rulările de backfill să se finalizeze.
- Rulează
airflow dags list-runs daily_sales_loadpentru a vedea toate rulările.
Uită-te la coloana run_id din rezultat. Cu ce prefix încep rulările de backfill?
Acest exercițiu face parte din cursul
Construirea pipeline-urilor de date cu Airflow
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul