Harmonogramowanie DAG-a w Pythonie
Wiesz już całkiem sporo o tworzeniu DAG-ów, a teraz chcesz zaplanować uruchomienie konkretnego DAG-a w określonym dniu tygodnia o określonej godzinie. Zależy ci też, żeby ta informacja była widoczna w kodzie – na wypadek gdyby kolega lub koleżanka musiała zainstalować DAG-a na innym serwerze.
Obiekt dag Airflow oraz odpowiednie metody datetime zostały już zaimportowane.
To ćwiczenie jest częścią kursu
Wprowadzenie do Apache Airflow w Pythonie
Instrukcje do ćwiczenia
- Ustaw datę startową DAG-a na 1 listopada 2025 roku.
- Użyj składni cron, aby skonfigurować harmonogram: uruchamianie w każdą środę o 12:30.
Interaktywne ćwiczenie praktyczne
Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.
@dag(
dag_id='update_dataflows',
# Set to November 1, 2025
start_date=datetime(____),
# Every Wednesday at 12:30pm
schedule='____'
)
def update_dataflows():
@task
def pull_source_data():
pass
update_dataflows()