Renvoyer des données depuis une fonction TaskFlow
Votre équipe stocke la configuration du pipeline dans une tâche séparée afin qu'elle puisse être réutilisée dans les étapes en aval. Centraliser la configuration de cette manière est courant en production : une tâche définit les paramètres, et toutes les autres lisent les mêmes valeurs au lieu de les coder en dur. La tâche get_config renvoie déjà le dictionnaire de configuration, et run_pipeline est prête à l'utiliser.
Cet exercice fait partie du cours
<cours>Créer des pipelines de données avec Airflow</cours>Exercice interactif pratique
Transformez la théorie en action avec l’un de nos exercices interactifs
Commencer l’exercice