實際觀察資產為基礎的排程
前面練習中的 sales_producer 與 sales_consumer 兩個 Dag 都已載入 Airflow UI。生產端會寫入銷售資料,並更新資產 s3://data-lake/sales/daily.csv。消費端則是依該資產來排程。
請依下列步驟操作:
- 在 Dags 檢視中找到
sales_producer與sales_consumer,用切換開關將它們啟用。 - 按下播放圖示觸發
sales_producer,選取 Single Run,再點 Trigger。 - 等待生產端的執行完成(所有任務呈現綠色)。
- 檢查
sales_consumer是否在你未點擊任何東西的情況下自動被觸發。
當 sales_producer 的執行完成後,sales_consumer 會發生什麼事?
本練習屬於課程
