EmailOperator et dépendances
Maintenant que vous avez défini avec succès les PythonOperator pour votre workflow, votre manager souhaite recevoir par e-mail une copie du fichier JSON analysé lorsque le workflow se termine. Les tâches précédentes sont toujours définies et le DAG process_sales_dag est configuré. Veuillez noter que cette tâche utilise l’ancienne méthode de définition d’un DAG et a été ajoutée pour vous.
Cet exercice fait partie du cours
Introduction à Apache Airflow en Python
Instructions
- Importez la classe permettant d’envoyer des e-mails.
- Définissez l’Operator et renseignez les arguments appropriés (
to,subject,files). - Définissez l’ordre des tâches pour qu’elles s’exécutent séquentiellement (récupérer le fichier, analyser le fichier, puis envoyer l’e-mail à votre manager).
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