Creación de un pipeline de producción #1
Has aprendido mucho sobre cómo funciona Airflow; ahora toca llevar tu flujo de trabajo a un pipeline de producción con muchos objetos, incluidos sensores y operadores. A tu jefa le interesa que este flujo quede automatizado y que pueda ofrecer informes de SLA, ya que eso daría más margen para cerrar un acuerdo en el que está trabajando el equipo de ventas. El posible cliente ha indicado que, cuando vea actualizaciones automatizadas, estará dispuesto a contratar el servicio de datos indicado.
Por lo que sabes del proceso, hay datos de ventas que se subirán al sistema. Una vez subidos, debería crearse un nuevo archivo para iniciar el procesamiento completo, pero algo no está funcionando bien.
Consulta el código fuente del DAG para ver si hay que añadir algo más.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Ejercicio interactivo práctico
Pon en práctica la teoría con uno de nuestros ejercicios interactivos
Empezar ejercicio