Začněte nyníZačněte zdarma

Airflow DAGs

V Airflow je pipeline reprezentovaná jako Directed Acyclic Graph, neboli DAG (orientovaný acyklický graf). Uzly grafu představují úlohy, které se mají vykonat. Orientované spojnice mezi uzly představují závislosti mezi jednotlivými úlohami.

Znázornění datové pipeline jako DAG dává smysl, protože některé úlohy musí skončit dřív, než mohou začít jiné. Dá se to přirovnat k montážní lince v továrně na auta. Úlohy na sebe navazují a každá může záviset na dokončení těch předchozích. Fiktivní DAG by mohl vypadat nějak takto:

Example DAG

Nejdřív se sestaví rám, pak karoserie a pneumatiky a nakonec se auto nastříká barvou. Pojďme si tenhle příklad zopakovat v kódu.

Toto cvičení je součástí kurzu

Introduction to Data Engineering

Zobrazit kurz

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# 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()
Upravit a spustit kód