ComenzarEmpieza gratis

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 compuesto por muchos objetos, incluidos sensores y operadores. A tu jefe le interesa que este flujo se automatice y permita generar informes de SLA, ya que ofrece una ventaja adicional para cerrar un acuerdo en el que trabaja el equipo de ventas. El cliente potencial ha indicado que, en cuanto vea actualizaciones de forma automatizada, está dispuesto a contratar el servicio de datos indicado.

Por lo que sabes del proceso, hay datos de ventas que se cargarán en el sistema. Cuando se suban los datos, debería crearse un nuevo archivo para iniciar todo el procesamiento, pero algo no está funcionando bien.

Consulta el código fuente del DAG para determinar si hay que añadir algo más.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Ejercicio interactivo práctico

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

Empezar ejercicio