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.
- Uruchom
airflow dags trigger daily_sales_load --logical-date 2026-04-20w terminalu, aby wyzwolić przebieg dla konkretnej daty. - Poczekaj około 30 sekund, aż ręczny przebieg się zakończy.
- 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
Interaktywne ćwiczenie praktyczne
Przekształć teorię w praktykę dzięki jednemu z naszych interaktywnych ćwiczeń
Rozpocznij ćwiczenie