EmpezarEmpieza gratis

DAGs de Airflow

En Airflow, una canalización se representa como un grafo acíclico dirigido o DAG. Los nodos del grafo representan las tareas que se ejecutan. Las conexiones dirigidas entre nodos representan las dependencias entre las tareas.

Representar una canalización de datos como un DAG tiene mucho sentido, ya que algunas tareas deben terminar antes de que otras puedan empezar. Puedes compararlo con una cadena de montaje en una fábrica de coches. Las tareas se van acumulando y cada una puede depender de que se hayan completado tareas anteriores. Un DAG ficticio podría tener este aspecto:

Example DAG

Primero se ensambla el chasis, después la carrocería y los neumáticos, y por último se pinta. Vamos a reproducir el ejemplo anterior en código.

Este ejercicio forma parte del curso

Introducción a la ingeniería de datos

Ver curso

ejercicio interactivo práctico

Prueba este ejercicio completando este código de ejemplo.

# Create the DAG
@dag(dag_id="car_factory_simulation",
     start_date=datetime(2024, 1, 1),
     schedule="____")
def car_factory_simulation():
    pass

# Run the DAG
car_factory_simulation()
Editar y ejecutar código