Créer un pipeline partitionné
Un simple événement d'asset informe les consommateurs en aval que « quelque chose a changé », sans préciser quelle tranche de données. En pratique, les équipes reporting et analytics n'ont généralement besoin de retraiter que la partition réellement modifiée, comme une journée, plutôt que de tout relancer. Les partitions d'asset véhiculent cette clé de partition en aval, afin que les consommateurs réagissent exactement à la bonne tranche. Dans cet exercice, vous allez planifier votre pipeline de ventes sur un calendrier de partitions quotidiennes et émettre un événement daily_sales partitionné à chaque exécution.
Cet exercice fait partie du cours
<cours>Créer des pipelines de données avec Airflow</cours>Exercice interactif pratique
Transformez la théorie en action avec l’un de nos exercices interactifs
Commencer l’exercice