從 CLI 觸發一條 pipeline
大多數時候,排程器會替你執行 Dag,但有時你需要自己執行,例如指定某一天或快速重跑一次。daily_sales_load 這個 Dag 已經啟用,且排程器已產生一個 scheduled 執行。你將從 CLI 觸發第二次執行,並比較 Airflow 如何為兩者加上標記。
- 在終端機執行
airflow dags trigger daily_sales_load --logical-date 2026-04-20,觸發指定日期的執行。 - 等待約 30 秒,讓手動執行完成。
- 執行
airflow dags list-runs daily_sales_load檢視所有執行。
執行 airflow dags list-runs 後,你會看到兩次執行。查看 run_id 欄位。你手動觸發的那次執行,其前綴為何?
本練習屬於課程
