開始使用免費開始

在分割資產上進行排程

現在上游會發出分割的 daily_sales 事件,下游的報表 Dag 就能自動回應,只針對剛刷新的一個分割執行,而不是重新處理所有日期。上游會輸出完整的時間戳,但報表只在意行事曆的日期;將該鍵標準化正是 StartOfDayMapper 的用途。在這個練習中,你會把下游報表排程在該分割資產上,並把每個事件對應到它的那一天。

為了提供脈絡,檔案中已預先填入上游程式碼。你會在下一個練習看到兩個 Dag 如何協同運作。

本練習屬於課程

使用 Airflow 建置資料管線

檢視課程

動手互動練習

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

開始練習