Programar un Dag consumidor sobre un Asset
Ahora que el productor de ventas indica cuándo hay datos listos, necesitas un Dag consumidor que se ejecute automáticamente cada vez que se actualice el asset. Define el mismo asset (s3://data-lake/sales/daily.csv) y configura su planificación para que Airflow dispare el Dag tras cada actualizació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