Más PythonOperators

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

Ten en cuenta que, al implementar tareas de Airflow, no siempre comprenderás cada uno de los pasos que te den. Mientras sepas cómo encapsular esos pasos dentro de la estructura de Airflow, podrás implementar el flujo de trabajo deseado.

Este ejercicio forma parte del curso

Introducción a Apache Airflow en Python

Ver curso

Instrucciones del ejercicio

Define la tarea de Python en la variable parse_file_task con el id parse_file.
Añade parse_file(inputfile, outputfile) al Operator.
Define los argumentos que se pasarán al callable.

Ejercicio interactivo práctico

Prueba este ejercicio y completa el 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