Más PythonOperators

Para seguir implementando tu flujo de trabajo, tienes que añadir otro paso para analizar y guardar los cambios del archivo descargado. El DAG process_sales_dag está definido y tiene la tarea pull_file ya añadida. En este caso, la función Python ya está definida para ti, parse_file(inputfile, outputfile).

Ten en cuenta que, a menudo, cuando ejecutes tareas de Airflow, no entenderás necesariamente los pasos individuales que te den. Mientras entiendas cómo envolver los pasos dentro de la estructura de Airflow, podrás implementar el flujo de trabajo que desees.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Instrucciones de ejercicio

Define la tarea Python a la variable parse_file_task con el id parse_file.
Añade el parse_file(inputfile, outputfile) al Operador.
Define los argumentos que se pasarán a la llamada.

Ejercicio interactivo práctico

Pruebe este ejercicio completando este código de muestra.

# Add another Python task
____ = ____(
    task_id=____,
    # Set the function to call
    ____
    # Add the arguments
    ____={'inputfile':'latestsales.json', 'outputfile':'parsedfile.json'},
)

Editar y ejecutar código