EmailOperator e dependências
Agora que você definiu com êxito os PythonOperators para o seu fluxo de trabalho, seu gerente gostaria de receber uma cópia do arquivo JSON analisado por e-mail quando o fluxo de trabalho for concluído. As tarefas anteriores ainda estão definidas e o site DAG process_sales_dag está configurado. Observe que essa tarefa usa o método de definição DAG mais antigo e é adicionada para você.
Este exercício faz parte do curso
Introdução ao Apache Airflow em Python
Instruções do exercício
- Importe a classe para enviar e-mails.
- Defina o Operador e adicione os argumentos apropriados (
to,subject,files). - Defina a ordem das tarefas para que sejam executadas sequencialmente (puxe o arquivo, analise o arquivo e envie um e-mail ao seu gerente).
Exercício interativo prático
Experimente este exercício completando este código de exemplo.
# 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