Backfill dei dati storici
I dati in ritardo capitano. Il tuo Dag daily_sales_load sta funzionando bene, ma i dati degli ordini del 20-22 aprile sono arrivati in raw_orders solo oggi, lasciando tre buchi in daily_summary. La soluzione è un backfill. Il Dag è già attivo, quindi vedrai un'esecuzione scheduled per oggi accanto alle esecuzioni di backfill che creerai.
- Esegui
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1nel terminale. - Attendi circa 30 secondi che le esecuzioni di backfill finiscano.
- Esegui
airflow dags list-runs daily_sales_loadper vedere tutte le esecuzioni.
Guarda la colonna run_id nei risultati. Con quale prefisso iniziano le esecuzioni di backfill?
Questo esercizio fa parte del corso
Creare data pipeline con Airflow
esercizio interattivo pratico
Trasforma la teoria in pratica con uno dei nostri esercizi interattivi
Inizia esercizio