Pas le temps de lire l'article ? Voici ce qu'il faut retenir.
Airflow introduit le Dynamic Task Mapping pour générer des structures de tâches dynamiques dans ses DAGs.
1
Dynamic Task Mapping — Airflow propose deux mécanismes pour générer des structures de tâches dynamiques : la génération au parse-time et le dynamic task mapping.
2
Génération au parse-time — Ce mécanisme crée des tâches au moment où l'orchestrateur lit le fichier, mais cela peut entraîner des problèmes si les sources de données changent.
3
Dynamic Task Mapping — Ce mécanisme déporte la décision à l'exécution, permettant de calculer la liste de tâches pendant l'exécution et de déployer des instances mappées.
💡
Pourquoi c'est important : Le Dynamic Task Mapping permet aux utilisateurs d'Airflow de créer des structures de tâches dynamiques plus flexibles et robustes, adaptées à des cas où les sources de données changent.