EmailOperator und Abhängigkeiten
Nachdem du nun erfolgreich die PythonOperatoren für deinen Workflow definiert hast, möchte dein Manager eine Kopie der geparsten JSON Datei per E-Mail erhalten, wenn der Workflow abgeschlossen ist. Die vorherigen Aufgaben sind noch definiert und die DAG process_sales_dag ist konfiguriert. Bitte beachte, dass diese Aufgabe die ältere DAG Definitionsmethode verwendet und für dich hinzugefügt wurde.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow in Python
Anleitung zur Übung
- Importiere die Klasse, um E-Mails zu versenden.
- Definiere den Operator und füge die entsprechenden Argumente hinzu (
to,subject,files). - Lege die Aufgabenreihenfolge so fest, dass die Aufgaben nacheinander ausgeführt werden (ziehe die Datei, analysiere die Datei und sende dann eine E-Mail an deinen Manager).
Interaktive Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# 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