Citirea unei variabile în Python

Ai realizat că folosirea Variabilelor în DAG-urile tale îți oferă un control mai bun asupra configurației în diverse medii, inclusiv pe serverele Airflow de dezvoltare și testare. Pentru a nu fi nevoit să actualizezi codul DAG-ului pentru fiecare mediu în parte, decizi să implementezi o variabilă Output_Path care să stocheze locația de pe server unde sunt păstrate diversele fișiere.

Obiectele dag și task au fost importate pentru tine, împreună cu datetime.

Acest exercițiu face parte din cursul

Introducere în Apache Airflow în Python

Vezi cursul

Instrucțiuni pentru exercițiu

Importă biblioteca necesară pentru a lucra cu Variabile.
Citește variabila Output_Path din Airflow.
Specifică valoarea de rezervă /home în cazul în care Output_Path nu este definită.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# 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()

Editează și rulează codul