Créer un Dag simple
Vous avez passé un peu de temps à revoir les composants d'Airflow et vous souhaitez maintenant mettre vos propres flux de travaux à l'essai. Pour commencer, vous décidez de définir les paramètres par défaut et de créer un objet Dag pour votre flux de travaux.
L'objet datetime a déjà été importé pour vous.
Cette activité fait partie du cours
Introduction à Apache Airflow en Python
Instructions de l’exercice
- Importez l'objet Dag d'Airflow; notez que la casse doit être respectée.
- Définissez le décorateur Dag et nommez le Dag
example_etl. - Exécutez la fonction du Dag à la fin du fichier de code.
Exercice interactif pratique
Essayez cet exercice en complétant ce code d’exemple.
# Import the dag object
from ____ import dag
# Define the Dag attributes
____(
____='example_etl',
start_date=datetime(2026, 3, 1),
)
def example_etl():
pass
# Run the Dag
____()