Naplánování DAGu přes Python
Už toho víš o vytváření DAGů docela dost – teď ale chceš naplánovat konkrétní DAG na určitý den v týdnu a přesnou hodinu. Zároveň chceš mít tyto informace přímo v kódu, aby je měl kolega po ruce v případě, že bude DAG přeinstalovat na jiný server.
Objekt dag z Airflow a příslušné metody datetime jsou již naimportované.
Toto cvičení je součástí kurzu
Úvod do Apache Airflow v Pythonu
Pokyny k cvičení
- Nastav datum spuštění DAGu na 1. listopadu 2025.
- Pomocí syntaxe cronu nakonfiguruj plán tak, aby se DAG spouštěl každou středu ve 12:30.
Interaktivní cvičení na vyzkoušení si v praxi
Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.
@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()