Generar y enviar por email un informe
Airflow permite automatizar prácticamente cualquier tipo de flujo de trabajo. Te gustaría recibir un informe de Airflow cuando las tareas terminen, sin tener que estar vigilando constantemente la UI o los archivos de registro. Decides usar la funcionalidad de correo electrónico de Airflow para enviar este mensaje.
Todos los componentes típicos de Airflow ya se han importado por ti y ya hay un DAG definido 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 detalles que faltan para el Operator. Usa el archivo
monthly_report.pdf. - Haz que la tarea
email_reportse ejecute después de la tareagenerate_report.
Ejercicio interactivo práctico
Prueba este ejercicio y completa 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