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