Procesar varios endpoints con expand
Tu equipo extrae datos de varios endpoints de API que cambian con el tiempo, y crear una tarea diferente para cada uno implica editar el Dag cada vez que se añade o elimina un endpoint. En este ejercicio, vas a convertir esa canalización rígida en una basada en datos: con expand(), Airflow lee la lista de endpoints en tiempo de ejecución y lanza una instancia de tarea por elemento, de modo que la canalización se ajusta automáticamente a medida que cambia el número de endpoints.
Este ejercicio forma parte del curso
Creación de canalizaciones de datos con Airflow
ejercicio interactivo práctico
Convierte la teoría en práctica con uno de nuestros ejercicios interactivos
Empezar ejercicio