Lendo uma variável em Python

Você percebeu que usar Variables nos seus Dags permite ter um pouco de controle sobre a configuração em diferentes ambientes, incluindo seus servidores Airflow de desenvolvimento e teste. Para evitar ter que atualizar o código do seu Dag em cada um deles, você decide implementar uma variável Output_Path para armazenar o local no seu servidor onde os vários arquivos são mantidos.

Os objetos dag e task já foram importados para você, junto com datetime.

Este exercicio faz parte do curso

Introdução ao Apache Airflow em Python

Ver curso

Instruções do exercicio

Importe a biblioteca necessária para trabalhar com Variables.
Leia a variável Output_Path do Airflow.
Forneça um valor de fallback de /home caso Output_Path não esteja definida.

exercicio interativo prático

Tente este exercicio completando este código de exemplo.

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

Editar e Executar Código