开始使用免费开始使用

在分区资产上进行调度

现在上游会发出带分区的 daily_sales 事件,下游的报表 Dag 可以自动响应它们,只针对刚刚刷新的那个分区运行,而不是重新处理每个日期。上游发出的是完整的时间戳,但报表只关心日历日期;规范化该键正是 StartOfDayMapper 的用途。在本练习中,您将把下游报表调度到这个分区资产上,并将每个事件映射到其对应的日期。

为便于理解,文件中已预填了上游部分。您将在下一个练习中看到两个 Dag 如何协同工作。

本练习是课程的一部分

使用 Airflow 构建数据流水线

查看课程

动手互动练习

通过我们的互动练习之一,将理论转化为实践

开始练习