開始使用免費開始

實際觀察資產為基礎的排程

前面練習中的 sales_producersales_consumer 兩個 Dag 都已載入 Airflow UI。生產端會寫入銷售資料,並更新資產 s3://data-lake/sales/daily.csv。消費端則是依該資產來排程。

請依下列步驟操作:

  1. 在 Dags 檢視中找到 sales_producersales_consumer,用切換開關將它們啟用。
  2. 按下播放圖示觸發 sales_producer,選取 Single Run,再點 Trigger
  3. 等待生產端的執行完成(所有任務呈現綠色)。
  4. 檢查 sales_consumer 是否在你未點擊任何東西的情況下自動被觸發。

sales_producer 的執行完成後,sales_consumer 會發生什麼事?

本練習屬於課程

使用 Airflow 建置資料管線

檢視課程

動手互動練習

將理論付諸實踐,立即體驗我們的互動練習

開始練習