Pianifica un Dag tramite Python
Hai imparato parecchio su come creare i Dag, ma ora vuoi pianificare un Dag specifico in un determinato giorno della settimana a un orario preciso. Vuoi che il codice includa queste informazioni nel caso in cui un collega debba reinstallare il Dag su un server diverso.
Gli oggetti dag di Airflow e i metodi datetime appropriati sono già stati importati per te.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Imposta la data di inizio del Dag al 1° novembre 2025.
- Usa la sintassi cron per configurare una pianificazione ogni mercoledì alle 12:30.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
@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()