開始使用免費開始

用 Asset outlet 發出資料可用的訊號

你的團隊有一條管線會把每日的銷售資料寫入 s3://data-lake/sales/daily.csv,而且有多條下游管線仰賴它。與其讓它們用計時器輪詢或猜測檔案何時就緒,你將加上一個 Asset outlet,讓這個任務在完成時立刻發出資料已更新的訊號。此訊號會讓其他 Dags 能夠直接依據該筆資料自行排程。

完成程式碼後,先執行該檔案,接著使用 Airflow CLI 驗證該資產已被註冊並且已更新。

本練習屬於課程

使用 Airflow 建置資料管線

檢視課程

動手互動練習

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

開始練習