在分区资产上进行调度
现在上游会发出带分区的 daily_sales 事件,下游的报表 Dag 可以自动响应它们,只针对刚刚刷新的那个分区运行,而不是重新处理每个日期。上游发出的是完整的时间戳,但报表只关心日历日期;规范化该键正是 StartOfDayMapper 的用途。在本练习中,您将把下游报表调度到这个分区资产上,并将每个事件映射到其对应的日期。
为便于理解,文件中已预填了上游部分。您将在下一个练习中看到两个 Dag 如何协同工作。
本练习是课程的一部分
现在上游会发出带分区的 daily_sales 事件,下游的报表 Dag 可以自动响应它们,只针对刚刚刷新的那个分区运行,而不是重新处理每个日期。上游发出的是完整的时间戳,但报表只关心日历日期;规范化该键正是 StartOfDayMapper 的用途。在本练习中,您将把下游报表调度到这个分区资产上,并将每个事件映射到其对应的日期。
为便于理解,文件中已预填了上游部分。您将在下一个练习中看到两个 Dag 如何协同工作。
本练习是课程的一部分