EmailOperator und Abhängigkeiten
Nachdem du die PythonOperators für deinen Workflow erfolgreich definiert hast, möchte deine Managerin bzw. dein Manager beim Abschluss des Workflows eine Kopie der geparsten JSON-Datei per E-Mail erhalten. Die vorherigen Tasks sind weiterhin definiert und der DAG process_sales_dag ist konfiguriert. Bitte beachte, dass diese Aufgabe die ältere DAG-Definitionsmethode nutzt und für dich hinzugefügt wurde.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow mit Python
Anleitung zur Übung
- Importiere die Klasse zum Versenden von E-Mails.
- Definiere den Operator und gib die passenden Argumente an (
to,subject,files). - Lege die Task-Reihenfolge fest, damit die Tasks nacheinander laufen (Datei ziehen, Datei parsen, dann deiner Führungskraft eine E-Mail senden).
Interaktive Übung
Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.
# 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