Bölümlenmiş varlıklarda zamanlama

Artık upstream bölümlenmiş daily_sales olayları yayımladığına göre, raporlama Dag'i bunlara otomatik olarak tepki verebilir ve her tarihi yeniden işlemek yerine yalnızca az önce yenilenen bölüm için çalışır. Upstream tam bir zaman damgası yayar, ancak rapor yalnızca takvim tarihini umursar; bu anahtarı normalize etmek tam olarak StartOfDayMapper'ın işidir. Bu egzersizde, aşağı akış raporunu bölümlenmiş varlık üzerinde zamanlayacak ve her olayı kendi gününe eşleyeceksin.

Bağlam için upstream dosyada önceden doldurulmuştur ve bir sonraki egzersizde her iki Dag'in birlikte çalıştığını göreceksin.