CommencerCommencez gratuitement

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 :

  1. Dans la vue Dags, trouvez sales_producer et sales_consumer et 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 que l'exécution du producteur se termine (toutes les tâches en vert).
  4. Vérifiez si sales_consumer a é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>
Voir le cours

Exercice interactif pratique

Transformez la théorie en action avec l’un de nos exercices interactifs

Commencer l’exercice