Odczytywanie zmiennej w Pythonie

Używanie zmiennych w DAG-ach daje pewną kontrolę nad konfiguracją w różnych środowiskach, w tym na serwerach Airflow przeznaczonych do programowania i testowania. Żeby nie musieć aktualizować kodu DAG-a dla każdego z nich osobno, zdecydujesz się wprowadzić zmienną Output_Path, która będzie przechowywać ścieżkę na serwerze, gdzie przechowywane są różne pliki.

Obiekty dag i task zostały już zaimportowane razem z datetime.

To ćwiczenie jest częścią kursu

Wprowadzenie do Apache Airflow w Pythonie

Zobacz kurs

Instrukcje do ćwiczenia

Zaimportuj bibliotekę potrzebną do pracy ze zmiennymi.
Odczytaj zmienną Output_Path z Airflow.
Podaj wartość zastępczą /home, jeśli zmienna Output_Path nie jest zdefiniowana.

Interaktywne ćwiczenie praktyczne

Spróbuj tego ćwiczenia, uzupełniając ten przykładowy kod.

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

Edytuj i uruchom kod