Crear un pipeline particionado
Un evento de asset simple les dice a los consumidores posteriores que "algo cambió", pero no qué porción de datos. En la práctica, los equipos de reporting y analítica suelen necesitar reprocesar solo la partición que realmente cambió, como un único día, en lugar de volver a ejecutar todo. Las particiones de assets llevan esa clave de partición aguas abajo para que los consumidores reaccionen exactamente a la porción correcta. En este ejercicio, programarás tu pipeline de ventas con un calendario de particiones diarias y emitirás un evento particionado daily_sales en cada ejecución.
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