Lire une variable en Python
Vous avez constaté que l'utilisation de Variables dans vos Dags vous permet d'exercer un certain contrôle sur 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 pour chacun, vous décidez d'implanter 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.
Cette activité fait partie du cours
Introduction à Apache Airflow en Python
Instructions de l’exercice
- Importez la bibliothèque nécessaire pour travailler avec les Variables.
- Lisez la variable
Output_Pathdepuis Airflow. - Fournissez une valeur de repli de
/homesiOutput_Pathn'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()