CommencerCommencez gratuitement

Traiter plusieurs endpoints avec expand

Votre équipe récupère des données depuis plusieurs endpoints d'API qui évoluent dans le temps, et coder une tâche distincte pour chacun vous oblige à modifier le Dag à chaque ajout ou suppression d'endpoint. Dans cet exercice, vous allez rendre ce pipeline flexible et piloté par les données : avec expand(), Airflow lit la liste des endpoints à l'exécution et lance une instance de tâche par élément, ce qui permet au pipeline de s'adapter automatiquement aux changements du nombre d'endpoints.

Cet exercice fait partie du cours

<cours>Créer des pipelines de données avec Airflow</cours>
Voir le cours

Exercice interactif pratique

Transformez la théorie en action avec l’un de nos exercices interactifs

Commencer l’exercice