Planifier un Dag via Python
Vous avez déjà bien appris à créer des Dags, mais vous souhaitez maintenant planifier un Dag précis, un jour de la semaine précis, à une heure donnée. Vous voulez que le code inclue ces informations au cas où un collègue devrait réinstaller le Dag sur un autre serveur.
L’objet Airflow dag et les méthodes datetime appropriées ont été importés pour vous.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Définissez la date de début du Dag au 1er novembre 2025.
- Utilisez la syntaxe cron pour configurer une planification chaque mercredi à 12:30.
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
@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()