Correction d’un problème de XCom mal utilisé

Scénario

Contexte : Deux tâches doivent échanger des données intermédiaires dans un DAG. Le Problème : Les données échangées via XCom sont trop volumineuses, provoquant une surcharge de la base Airflow. Extrait logique actuelle : task_instance.xcom_push(key="data", value=large_dataframe) Contraintes : Limiter l’usage de XCom aux métadonnées légères. Stocker les données volumineuses dans un stockage externe. Livrable attendu : Proposer une correction garantissant un échange de données efficace sans surcharger la base Airflow.

Compétences ciblées