1. Apprendre
    2. /
  2. Cours
    3. /
  3. Introduction à Apache Airflow en Python
Connected

Exercice

Transmission de données avec XCom

Vous êtes en train de mettre à jour un flux ETL pour utiliser un XCom et ainsi suivre l'information plus facilement. Vous devez donc mettre à jour les dépendances entre les tâches de votre Dag.

Vous avez déjà quatre tâches définies et utilisables comme suit :

  • extract() : retourne order_data
  • transform(order_data) : retourne des données synthétisées
  • load(summary_data) : ne retourne aucune information XCom
  • send_report() : une tâche sans XCom qui gère les avis

Instructions

100 XP
  • Insérez la tâche transform entre extract() et load() pour compléter la chaîne.
  • Assignez le résultat à une variable appelée etl_result.
  • Faites exécuter send_report après la variable etl_result.