Lettura di una variabile in Python
Hai capito che usare le Variabili all'interno dei tuoi Dag ti permette di controllare un po' la configurazione nei vari ambienti, inclusi i server Airflow di sviluppo e test. Per evitare di dover aggiornare il codice del tuo Dag per ognuno, decidi di implementare una variabile Output_Path per memorizzare il percorso sul tuo server dove sono conservati i vari file.
Gli oggetti dag e task sono già stati importati per te, insieme a datetime.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Importa la libreria necessaria per lavorare con le Variabili.
- Leggi la variabile
Output_Pathda Airflow. - Fornisci un valore di riserva
/homeseOutput_Pathnon è definita.
esercizio interattivo pratico
Prova questo esercizio completando questo codice di esempio.
# 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()