EmailOperator y dependencias
Ahora que has definido con éxito los PythonOperators para tu flujo de trabajo, a tu gestor le gustaría recibir una copia del archivo JSON analizado por correo electrónico cuando finalice el flujo de trabajo. Las tareas anteriores siguen definidas y DAG process_sales_dag está configurado. Ten en cuenta que esta tarea utiliza el antiguo método de definición DAG y se añade 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 Operador y añade los argumentos adecuados (
to,subject,files). - Establece el orden de las tareas para que se ejecuten secuencialmente (Extrae el archivo, analiza el archivo y, a continuación, envía un correo electrónico a tu gestor).
Ejercicio interactivo práctico
Prueba este ejercicio completando 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