Gerar e enviar um relatório por e-mail
O Airflow oferece a capacidade de automatizar praticamente qualquer estilo de fluxo de trabalho. Você gostaria de receber um relatório do Airflow quando as tarefas forem concluídas, sem precisar de monitoramento constante do site UI ou dos arquivos de registro. Você decide usar a funcionalidade de e-mail do Airflow para fornecer essa mensagem.
Todos os componentes típicos do Airflow foram importados para você, e um DAG já está definido como report_dag.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções de exercício
- Defina o operador adequado para a tarefa
email_report. - Preencha os detalhes que faltam para o Operador. Use o arquivo chamado
monthly_report.pdf. - Defina a tarefa
email_reportpara ocorrer após a tarefagenerate_report.
Exercício interativo prático
Experimente este exercício preenchendo este código de exemplo.
# 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