Zacznij terazZacznij za darmo

Wyzwalanie pipeline'u z CLI

Zazwyczaj to harmonogram uruchamia twój DAG automatycznie, ale czasem trzeba zrobić to samodzielnie — na przykład dla jednorazowej daty lub gdy chcesz szybko ponownie przetworzyć dane. DAG daily_sales_load jest już aktywny, a harmonogram wykonał już jeden zaplanowany przebieg. Wyzwolisz teraz drugi przebieg z CLI i sprawdzisz, jak Airflow oznacza każdy z nich.

  1. Uruchom airflow dags trigger daily_sales_load --logical-date 2026-04-20 w terminalu, aby wyzwolić przebieg dla konkretnej daty.
  2. Poczekaj około 30 sekund, aż ręczny przebieg się zakończy.
  3. Uruchom airflow dags list-runs daily_sales_load, aby zobaczyć wszystkie przebiegi.

Po uruchomieniu airflow dags list-runs widzisz dwa przebiegi. Przyjrzyj się kolumnie run_id. Jakim prefiksem zaczyna się ręcznie wyzwolony przebieg?

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