Crear un Dag sencillo
Has dedicado un tiempo a revisar los componentes de Airflow y te apetece probar tus propios flujos de trabajo. Para empezar, decides definir los parámetros predeterminados y crear un objeto Dag para tu flujo.
El objeto datetime ya se ha importado por ti.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Importa el objeto Dag de Airflow; ten en cuenta que distingue mayúsculas y minúsculas.
- Define el decorador Dag y ponle al Dag el nombre
example_etl. - Ejecuta la función del Dag al final del archivo de código.
ejercicio interactivo práctico
Prueba este ejercicio completando este código de ejemplo.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()