EmailOperator y dependencias
Ahora que ya has definido correctamente los PythonOperator de tu flujo de trabajo, tu responsable quiere recibir por correo una copia del archivo JSON procesado cuando finalice el flujo. Las tareas anteriores siguen definidas y el DAG process_sales_dag ya está configurado. Ten en cuenta que esta tarea utiliza el método antiguo de definición de DAG y se ha añadido por ti.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Importa la clase para enviar correos electrónicos.
- Define el Operator y añade los argumentos correspondientes (
to,subject,files). - Establece el orden de las tareas para que se ejecuten de forma secuencial (primero descargar el archivo, luego parsearlo y, por último, enviar el correo a tu responsable).
Ejercicio interactivo práctico
Prueba este ejercicio y completa el código de muestra.
# Import the Operator
from ____ import ____
# Define the task
email_manager_task = ____(
task_id='email_manager',
____='[email protected]',
____='Latest sales JSON',
html_content='Attached is the latest sales JSON file as requested.',
____='parsedfile.json',
dag=process_sales_dag
)
# Set the order of tasks
pull_file_task ____ parse_file_task ____ email_manager_task