Vytvoření jednoduchého DAGu
Prošel/a sis komponenty Airflow a teď chceš vyzkoušet vlastní workflow. Jako první krok se rozhodneš definovat výchozí parametry a vytvořit objekt DAG pro svůj workflow.
Objekt datetime je už naimportován.
Toto cvičení je součástí kurzu
Úvod do Apache Airflow v Pythonu
Pokyny k cvičení
- Naimportuj objekt DAG z Airflow — pozor, záleží na velikosti písmen.
- Definuj dekorátor DAG a pojmenuj DAG
example_etl. - Na konci souboru zavolej funkci DAG.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
# 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
____()