EmailOperator e dependências
Agora que você definiu com sucesso os PythonOperators para o seu fluxo de trabalho, seu gerente gostaria de receber por e-mail uma cópia do arquivo JSON processado quando o fluxo terminar. As tarefas anteriores ainda estão definidas e o DAG process_sales_dag já está configurado. Observe que esta tarefa usa o método antigo de definição de DAG e foi 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 Operator e adicione os argumentos apropriados (
to,subject,files). - Defina a ordem das tarefas para que sejam executadas em sequência (Baixar o arquivo, processar o arquivo e, em seguida, enviar o 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