Utilisation de listes avec des modèles
Une fois de plus, vous décidez d'apporter quelques modifications à la conception de votre flux de travail cleandata
. Cette fois, vous vous rendez compte que vous devez exécuter la commande cleandata.sh
avec l'argument date et l'argument fichier comme précédemment, sauf que vous avez maintenant une liste de 30 fichiers. Vous ne souhaitez pas créer 30 tâches, votre tâche consiste donc à modifier le code pour permettre l'exécution de l'argument pour 30 fichiers ou plus.
La liste des fichiers Python est déjà créée pour vous, simplement appelée filelist
.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Modifiez le site
templated_command
pour itérer sur une liste de noms de fichiers. - Transmettez l'adresse
filelist
à la commande modèle de l'opérateur.
Exercice interactif pratique
Passez de la théorie à la pratique avec l’un de nos exercices interactifs
