Čtení proměnné v Pythonu

Uvědomil/a sis, že použití proměnných (Variables) v DAGzích ti dá větší kontrolu nad konfigurací v různých prostředích – včetně vývojového a testovacího Airflow serveru. Abys nemusel/a upravovat kód DAGu pro každé prostředí zvlášť, rozhodneš se implementovat proměnnou Output_Path, která bude uchovávat cestu na serveru, kde jsou uloženy různé soubory.

Objekty dag a task jsou už naimportované, stejně jako datetime.

Toto cvičení je součástí kurzu

Úvod do Apache Airflow v Pythonu

Zobrazit kurz

Pokyny k cvičení

Naimportuj knihovnu potřebnou pro práci s Variables.
Načti proměnnou Output_Path z Airflow.
Jako záložní hodnotu nastav /home pro případ, že Output_Path není definovaná.

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

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

Upravit a spustit kód