EmailOperator en afhankelijkheden
Nu je de PythonOperators voor je workflow succesvol hebt gedefinieerd, wil je manager bij voltooiing van de workflow een kopie van het geparste JSON-bestand per e-mail ontvangen. De eerdere taken zijn nog steeds gedefinieerd en de DAG process_sales_dag is geconfigureerd. Let op: deze taak gebruikt de oudere methode voor het definiëren van een DAG en is alvast voor je toegevoegd.
Deze oefening maakt deel uit van de cursus
Introductie tot Apache Airflow in Python
Oefeninstructies
- Importeer de klasse om e-mails te versturen.
- Definieer de Operator en voeg de juiste argumenten toe (
to,subject,files). - Stel de taakvolgorde in zodat de taken achter elkaar draaien (eerst het bestand ophalen, dan het bestand parsen, daarna je manager e-mailen).
Praktische interactieve oefening
Probeer deze oefening eens door deze voorbeeldcode in te vullen.
# 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