Planung für partitionierte Assets

Da der Upstream jetzt partitionierte daily_sales-Events ausgibt, kann der Reporting-Dag automatisch darauf reagieren und nur für die Partition laufen, die gerade aktualisiert wurde, statt jedes Datum neu zu verarbeiten. Der Upstream gibt einen vollständigen Zeitstempel aus, der Bericht interessiert sich jedoch nur für das Kalenderdatum; genau dafür ist StartOfDayMapper da, um diesen Schlüssel zu normalisieren. In dieser Übung planst du den Downstream-Bericht auf dem partitionierten Asset und ordnest jedes Event seinem Tag zu.

Der Upstream ist der Orientierung halber in der Datei bereits ausgefüllt, und in der nächsten Übung siehst du beide Dags zusammenarbeiten.