Zacznij terazZacznij za darmo

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.

  1. 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.
  2. Poczekaj około 30 sekund, aż uruchomienia backfill się zakończą.
  3. 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

Zobacz kurs

Interaktywne ćwiczenie praktyczne

Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń

Rozpocznij ćwiczenie