Crearea unui DAG simplu
Ai petrecut ceva timp explorând componentele Airflow și ești curios să îți testezi propriile fluxuri de lucru. Pentru început, decizi să definești parametrii impliciți și să creezi un obiect DAG pentru fluxul tău de lucru.
Obiectul datetime a fost deja importat pentru tine.
Acest exercițiu face parte din cursul
Introducere în Apache Airflow în Python
Instrucțiuni pentru exercițiu
- Importă obiectul DAG din Airflow; reține că este sensibil la majuscule.
- Definește decoratorul DAG și numește DAG-ul
example_etl. - Apelează funcția DAG la sfârșitul fișierului de cod.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
# 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
____()