Перейти к содержимому

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 ? 👇