Apache Airflow #10 : 🔄 XCom dans Airflow - Communication entre Tâches Simplifiée ! 🚀
NetSecDev
0:00 / 0:00
Apache Airflow #10 : 🔄 XCom dans Airflow - Communication entre Tâches Simplifiée ! 🚀
503 просмотра · 1 год назад
NetSecDev
1,06 тыс. подписчиков
503 просмотра · 1 год назад
📌 Les tâches dans Airflow ne vivent pas seules ! Elles doivent souvent échanger des données pour exécuter un workflow fluide et efficace. Aujourd’hui, on découvre XCom, le mécanisme qui permet de partager des informations entre tâches.
🎯 Dans cette vidéo, vous apprendrez :
✅ Ce qu’est XCom et comment il fonctionne.
✅ Comment utiliser xcom_push() et xcom_pull() pour envoyer et récupérer des données entre tâches.
✅ L’importance de ti (TaskInstance) pour interagir avec les tâches et accéder aux XComs.
✅ Une astuce géniale : Utiliser return dans un PythonOperator pour stocker des données directement dans XCom !
📌 Exemples pratiques inclus :
✔️ Stocker un message dans XCom et le récupérer dans une autre tâche.
✔️ Gérer l’exécution d’une tâche en fonction des données stockées en XCom.
✔️ Éviter les erreurs courantes et optimiser l'utilisation de XCom.
🚀 Bonus : Alternatives et bonnes pratiques !
💡 Astuce geek : Toujours éviter de stocker de gros objets dans XCom, préférez une base de données ou un stockage cloud.
🔔 Abonnez-vous pour plus de contenu sur Apache Airflow et l'automatisation !
💬 Dites-moi en commentaire : Avez-vous déjà utilisé XCom dans vos DAGs ? 👇