Eine Variable in Python lesen

Du hast erkannt, dass der Einsatz von Variables in deinen Dags dir etwas Kontrolle über die Konfiguration in verschiedenen Umgebungen gibt – einschließlich deiner Entwicklungs- und Test-Airflow-Server. Damit du deinen Dag-Code nicht für jede Umgebung anpassen musst, entscheidest du dich, eine Variable Output_Path zu verwenden, die den Speicherort auf deinem Server enthält, an dem die verschiedenen Dateien liegen.

Die Objekte dag und task wurden zusammen mit datetime bereits für dich importiert.

Diese Übung ist Teil des Kurses

<Kurs>Einführung in Apache Airflow mit Python</Kurs>

Kurs ansehen

Übungsanweisungen

Importiere die Bibliothek, die für die Arbeit mit Variables benötigt wird.
Lies die Variable Output_Path aus Airflow.
Verwende einen Fallback-Wert von /home, falls Output_Path nicht definiert ist.

Interaktive praktische Übung

Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.

# 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 bearbeiten und ausführen