ÎncepețiÎncepe gratuit

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.

  1. 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.
  2. Așteaptă aproximativ 30 de secunde ca rulările de backfill să se finalizeze.
  3. Rulează airflow dags list-runs daily_sales_load pentru 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

Vezi cursul

Exercițiu interactiv practic

Transformă teoria în practică cu unul dintre exercițiile noastre interactive

Începe exercițiul