Planifier sur des actifs partitionnés

Maintenant que l'amont émet des événements daily_sales partitionnés, le Dag de rapports peut y réagir automatiquement et ne s'exécuter 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 du calendrier; normaliser cette clé, c'est précisément le rôle de StartOfDayMapper. Dans cet exercice, vous allez planifier le rapport en aval sur l'actif partitionné et faire correspondre chaque événement à sa journée.

L'amont est déjà rempli dans le fichier pour contexte, et vous verrez les deux Dags fonctionner ensemble dans le prochain exercice.