Generar y enviar por correo electrónico un informe
Airflow ofrece la posibilidad de automatizar casi cualquier estilo de flujo de trabajo. Te gustaría recibir un informe de Airflow cuando se completen las tareas, sin necesidad de monitorizar constantemente el UI o los archivos de registro. Decides utilizar la funcionalidad de correo electrónico dentro de Airflow para proporcionar este mensaje.
Se han importado para ti todos los componentes típicos de Airflow, y ya se ha definido un DAG como report_dag.
Este ejercicio forma parte del curso
Introducción a Apache Airflow en Python
Instrucciones del ejercicio
- Define el operador adecuado para la tarea
email_report. - Rellena los datos que faltan del Operador. Utiliza el archivo
monthly_report.pdf. - Configura la tarea
email_reportpara que se produzca después de la tareagenerate_report.
Ejercicio interactivo práctico
Prueba este ejercicio completando el código de muestra.
# Define the email task
email_report = ____(
task_id='email_report',
to='[email protected]',
subject='Airflow Monthly Report',
html_content="""Attached is your monthly workflow report - please refer to it for more detail""",
files=[____],
____=report_dag
)
# Set the email task to run after the report is generated
email_report ____ generate_report