Transmettre des données avec XCom

Vous êtes en train de mettre à jour un workflow ETL pour utiliser un XCom afin de suivre plus facilement les informations. Vous devez donc mettre à jour les dépendances entre les tâches de votre Dag.

Quatre tâches sont déjà définies et utilisables comme suit :

extract() - Renvoie order_data
transform(order_data) - Renvoie des données synthétisées
load(summary_data) - Ne renvoie pas d’informations XCom
send_report() - Une tâche non XCom qui gère les notifications

Cet exercice fait partie du cours

Introduction à Apache Airflow en Python

Afficher le cours

Instructions

Insérez la tâche transform entre extract() et load() pour compléter la chaîne.
Affectez le résultat à une variable appelée etl_result.
Définissez send_report pour qu’elle s’exécute après la variable etl_result.

Exercice interactif pratique

Essayez cet exercice en complétant cet exemple de code.

@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