Planification sur des assets partitionnés

Maintenant que l'amont émet des événements daily_sales partitionnés, le Dag de reporting peut y réagir automatiquement : il ne s'exécute que pour la partition qui vient d'être actualisée, au lieu de retraiter toutes les dates. L'amont émet un horodatage complet, mais le rapport ne s'intéresse qu'à la date calendaire ; normaliser cette clé est précisément le rôle de StartOfDayMapper. Dans cet exercice, vous allez planifier le rapport aval sur l'asset partitionné et faire correspondre chaque événement à son jour.

L'amont est prérempli dans le fichier pour le contexte, et vous verrez les deux Dags fonctionner ensemble dans l'exercice suivant.