Lire une variable en Python

Vous avez réalisé que l’utilisation de Variables dans vos Dags vous permettra de mieux contrôler la configuration selon les environnements, y compris vos serveurs Airflow de développement et de test. Pour éviter d’avoir à modifier le code de votre Dag à chaque fois, vous décidez d’implémenter une variable Output_Path pour stocker l’emplacement sur votre serveur où sont conservés les différents fichiers.

Les objets dag et task ont été importés pour vous, ainsi que datetime.

Cet exercice fait partie du cours

<cours>Introduction à Apache Airflow en Python</cours>

Voir le cours

Instructions de l’exercice

Importez la bibliothèque nécessaire pour travailler avec les Variables.
Lisez la variable Output_Path depuis Airflow.
Fournissez une valeur de repli /home si Output_Path n’est pas définie.

Exercice interactif pratique

Essayez cet exercice en complétant ce code d’exemple.

# Import the proper library to read Variables
from airflow.____ import ____

@dag(dag_id='process_sales', start_date=datetime(2026, 4, 15))
def process_sales():
    @task()
    def parse_file():
        # Get the output file location, otherwise default to "/home"
        output_path = ____.____("Output_Path", ____="/home")      
        # Logging only currently - processing to be added later
        print(f"File parsed and saved to {output_path}/sales_report.pdf")
    
    parse_file()
process_sales()

Modifier et exécuter le code