EmpezarEmpieza gratis

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

Ver curso

ejercicio interactivo práctico

Convierte la teoría en práctica con uno de nuestros ejercicios interactivos

Empezar ejercicio