Declanșarea unui pipeline din CLI
De cele mai multe ori, planificatorul rulează DAG-ul în locul tău, dar uneori trebuie să îl pornești manual – pentru o dată specifică sau o reprocesare rapidă. DAG-ul daily_sales_load este deja activ, iar planificatorul a produs o rulare scheduled. Vei declanșa o a doua rulare din CLI și vei compara cum etichetează Airflow fiecare rulare.
- Rulează
airflow dags trigger daily_sales_load --logical-date 2026-04-20în terminal pentru a declanșa o rulare pentru o dată specifică. - Așteaptă aproximativ 30 de secunde până când rularea manuală se finalizează.
- Rulează
airflow dags list-runs daily_sales_loadpentru a vedea toate rulările.
După ce rulezi airflow dags list-runs, vei vedea două rulări. Uită-te la coloana run_id. Cu ce prefix începe rularea declanșată manual?
Acest exercițiu face parte din cursul
Construirea pipeline-urilor de date cu Airflow
Exercițiu interactiv practic
Transformă teoria în practică cu unul dintre exercițiile noastre interactive
Începe exercițiul