EmpezarEmpieza gratis

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

Ver curso

ejercicio interactivo práctico

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

Empezar ejercicio