Créer un Dag simple
Vous avez passé un peu de temps à revoir les composants d’Airflow et vous souhaitez tester vos propres workflows. Pour commencer, vous décidez de définir les paramètres par défaut et de créer un objet Dag pour votre workflow.
L’objet datetime a été importé pour vous.
Cet exercice fait partie du cours
<cours>Introduction à Apache Airflow en Python</cours>Instructions de l’exercice
- Importez l’objet Dag d’Airflow ; notez que la casse est importante.
- 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
____()