EmailOperator et dépendances
Maintenant que vous avez défini avec succès les PythonOperators pour votre flux de travail, votre gestionnaire souhaite recevoir une copie du fichier JSON analysé par courrier électronique lorsque le flux de travail est terminé. Les tâches précédentes sont encore définies et le site DAG process_sales_dag est configuré. Veuillez noter que cette tâche utilise l'ancienne méthode de définition DAG et qu'elle est ajoutée pour vous.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Importez la classe pour envoyer des courriels.
- Définissez l'opérateur et ajoutez les arguments appropriés (
to,subject,files). - Définissez l'ordre des tâches de manière à ce qu'elles s'exécutent de manière séquentielle (extrayez le fichier, analysez-le, puis envoyez un courrier électronique à votre responsable).
Exercice interactif pratique
Essayez cet exercice en complétant cet exemple de code.
# 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