Uzupełnianie historycznych danych (backfill)
Dane docierające z opóźnieniem to codzienność. Twój DAG daily_sales_load działał bez zarzutu, ale dane zamówień za 20–22 kwietnia trafiły do raw_orders dopiero dzisiaj — w daily_summary powstały trzy luki. Rozwiązaniem jest backfill. DAG jest już aktywny, więc obok uruchomień backfill zobaczysz też uruchomienie scheduled z dzisiaj.
- Uruchom w terminalu polecenie
airflow backfill create --dag-id daily_sales_load --from-date 2026-04-20 --to-date 2026-04-22 --max-active-runs 1. - Poczekaj około 30 sekund, aż uruchomienia backfill się zakończą.
- Uruchom
airflow dags list-runs daily_sales_load, aby zobaczyć wszystkie uruchomienia.
Przyjrzyj się kolumnie run_id w wynikach. Jakim prefiksem zaczynają się uruchomienia backfill?
To ćwiczenie jest częścią kursu
Budowanie potoków danych z Airflow
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie