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

Cette activité fait partie du cours

Introduction à Apache Airflow en Python

Voir le cours

Instructions de l’exercice

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.

Exercice interactif pratique

Essayez cet exercice en complétant ce code d’exemple.

@dag(start_date=datetime(2026,4,1))
def etl_example():
    # Chain extract, transform, and load, assigning the result
    ____ = load(____(extract()))
    # Run send_report after the ETL tasks
    etl_result ____ ____()
    
etl_example()

Modifier et exécuter le code