Leer una Variable en Python
Te has dado cuenta de que usar Variables dentro de tus Dags te permite controlar un poco la configuración en distintos entornos, incluidos tus servidores de desarrollo y pruebas de Airflow. Para no tener que actualizar el código de tu Dag en cada caso, decides implementar una variable Output_Path para guardar la ubicación en tu servidor donde se almacenan los distintos archivos.
Los objetos dag y task ya se han importado por ti, junto con datetime.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Importa la librería necesaria para trabajar con Variables.
- Lee la variable
Output_Pathdesde Airflow. - Indica un valor alternativo de
/homesiOutput_Pathno está definida.
ejercicio interactivo práctico
Prueba este ejercicio completando este código de ejemplo.
# 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()