Planifică un Dag prin Python
Ai învățat destul de multe despre crearea Dag-urilor, dar acum vrei să planifici un anumit Dag pentru o zi specifică din săptămână, la o anumită oră. Ai vrea ca aceste informații să fie incluse direct în cod, în cazul în care un coleg trebuie să reinstaleze Dag-ul pe un server diferit.
Obiectul dag din Airflow și metodele datetime necesare au fost deja importate pentru tine.
Acest exercițiu face parte din cursul
Introducere în Apache Airflow în Python
Instrucțiuni pentru exercițiu
- Setează data de început a Dag-ului la 1 noiembrie 2025.
- Folosește sintaxa cron pentru a configura o planificare în fiecare miercuri la ora 12:30.
Exercițiu interactiv practic
Încearcă acest exercițiu completând acest cod de exemplu.
@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()