Läsa en variabel i Python

Du har insett att användningen av variabler i dina DAG:ar ger dig lite mer kontroll över konfigurationen i olika miljöer, till exempel dina utvecklings- och testservrar i Airflow. För att slippa uppdatera din DAG-kod för varje miljö väljer du att implementera variabeln Output_Path för att lagra sökvägen på servern där de olika filerna finns.

Objekten dag och task har importerats åt dig, tillsammans med datetime.

Den här övningen är en del av kursen

Introduktion till Apache Airflow i Python

Visa kurs

Övningsinstruktioner

Importera det bibliotek som behövs för att arbeta med variabler.
Läs in variabeln Output_Path från Airflow.
Ange /home som reservvärde om Output_Path inte är definierad.

Interaktiv övning med praktiskt arbete

Testa den här övningen genom att slutföra den här exempelkoden.

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

Redigera och kör kod