Convertir un Dag classique en TaskFlow
Votre équipe a décidé d'adopter l'API TaskFlow pour tous les nouveaux pipelines. Votre gestionnaire vous demande de réécrire un pipeline ETL existant qui utilisait PythonOperator avec un chaînage manuel >>.
La version classique originale est disponible comme référence dans dags/classic_etl.py. Une version amorcée avec TaskFlow est prête pour que vous la complétiez.
Cette activité fait partie du cours
Créer des pipelines de données avec Airflow
Exercice interactif pratique
Passez de la théorie à l’action grâce à l’un de nos exercices interactifs
Commencer l’exercice