Een variabele uitlezen in Python

Je hebt gemerkt dat het gebruik van Variables binnen je Dags je wat controle geeft over de configuratie in verschillende omgevingen, waaronder je ontwikkel- en test-Airflow-servers. Om te voorkomen dat je je Dag-code voor elke omgeving moet aanpassen, besluit je een variabele Output_Path te implementeren om de locatie op je server op te slaan waar de verschillende bestanden worden bewaard.

De objecten dag en task zijn al voor je geïmporteerd, samen met datetime.

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Bekijk cursus

Oefeninstructies

Importeer de bibliotheek die nodig is om met Variables te werken.
Lees de variabele Output_Path uit Airflow.
Geef een terugvalwaarde van /home als Output_Path niet is gedefinieerd.

Interactieve oefening met praktijkervaring

Probeer deze oefening door deze voorbeeldcode aan te vullen.

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

Code bewerken en uitvoeren