CommencezCommencez gratuitement

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 :

  1. Dans la vue Dags, trouvez sales_producer et sales_consumer, puis activez-les à l'aide de l'interrupteur.
  2. Déclenchez sales_producer en cliquant sur l'icône de lecture, en sélectionnant Single Run, puis Trigger.
  3. Attendez la fin de l'exécution du producteur (toutes les tâches en vert).
  4. Vérifiez si sales_consumer a é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

Voir le cours

Exercice interactif pratique

Passez de la théorie à l’action grâce à l’un de nos exercices interactifs

Commencer l’exercice