Voir la planification basée sur les Assets 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'asset s3://data-lake/sales/daily.csv. Le consommateur est programmé sur cet asset.
Suivez ces étapes :
- Dans la vue Dags, trouvez
sales_produceretsales_consumeret 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 que l'exécution du producteur se termine (toutes les tâches en vert).
- Vérifiez si
sales_consumera été déclenché automatiquement sans que vous n'ayez cliqué sur quoi que ce soit.
Après l'exécution de sales_producer, que se passe-t-il pour sales_consumer ?
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