Tworzenie prostego DAG-a
Zapoznałeś się już z komponentami Airflow i chcesz przetestować własne przepływy pracy. Na początek definiujesz domyślne parametry i tworzysz obiekt DAG dla swojego przepływu.
Obiekt datetime został już zaimportowany.
To ćwiczenie jest częścią kursu
Wprowadzenie do Apache Airflow w Pythonie
Instrukcje do ćwiczenia
- Zaimportuj obiekt DAG z Airflow – pamiętaj, że nazwa jest wrażliwa na wielkość liter.
- Zdefiniuj dekorator DAG i nadaj DAG-owi nazwę
example_etl. - Wywołaj funkcję DAG na końcu pliku z kodem.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
# 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
____()