Voir l'ordonnancement basé sur des actifs en action
Les Dags sales_producer et sales_consumer des exercices précédents ont été chargés dans l'interface Airflow. Le producteur écrit des données de ventes et met à jour l'actif s3://data-lake/sales/daily.csv. Le consommateur est planifié en fonction de cet actif.
Suivez ces étapes :
- Dans la vue Dags, trouvez
sales_produceretsales_consumer, puis activez-les à l'aide de l'interrupteur. - Déclenchez
sales_produceren cliquant sur l'icône de lecture, en sélectionnant Single Run, puis Trigger. - Attendez la fin de l'exécution du producteur (toutes les tâches en vert).
- Vérifiez si
sales_consumera été déclenché automatiquement sans que vous n'ayez à cliquer sur quoi que ce soit.
Après la fin de l'exécution de sales_producer, que se passe-t-il pour sales_consumer?
Cette activité fait partie du cours
Créer des pipelines de données avec Airflow
Exercice interactif pratique
Passez de la théorie à l’action grâce à l’un de nos exercices interactifs
Commencer l’exercice