Erstelle einen Bericht und sende ihn per E-Mail
Airflow bietet die Möglichkeit, fast jede Art von Arbeitsablauf zu automatisieren. Du möchtest einen Bericht von Airflow erhalten, wenn Aufgaben erledigt sind, ohne dass du die UI oder die Protokolldateien ständig überwachen musst. Du entscheidest dich, die E-Mail-Funktion in Airflow zu nutzen, um diese Nachricht zu übermitteln.
Alle typischen Airflow-Komponenten wurden für dich importiert, und eine DAG ist bereits als report_dag
definiert.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow in Python
Anleitung zur Übung
- Bestimme den richtigen Operator für die Aufgabe
email_report
. - Fülle die fehlenden Angaben für den Betreiber aus. Verwende die Datei mit dem Namen
monthly_report.pdf
. - Lege die Aufgabe
email_report
so fest, dass sie nach der Aufgabegenerate_report
stattfindet.
Interaktive Übung
Versuche dich an dieser Übung, indem du diesen Beispielcode vervollständigst.
# Define the email task
email_report = ____(
task_id='email_report',
to='[email protected]',
subject='Airflow Monthly Report',
html_content="""Attached is your monthly workflow report - please refer to it for more detail""",
files=[____],
____=report_dag
)
# Set the email task to run after the report is generated
email_report ____ generate_report