Einen Bericht erstellen und per E-Mail versenden
Airflow ermöglicht es dir, nahezu jede Art von Workflow zu automatisieren. Du möchtest einen Bericht von Airflow erhalten, wenn Aufgaben abgeschlossen sind, ohne die UI oder Logdateien ständig überwachen zu müssen. Du entscheidest dich, die E-Mail-Funktionalität in Airflow zu nutzen, um diese Nachricht zu senden.
Alle typischen Airflow-Komponenten wurden bereits für dich importiert, und ein DAG ist bereits als report_dag definiert.
Diese Übung ist Teil des Kurses
Einführung in Apache Airflow mit Python
Anleitung zur Übung
- Definiere den passenden Operator für die Aufgabe
email_report. - Fülle die fehlenden Details für den Operator aus. Verwende die Datei
monthly_report.pdf. - Setze die Aufgabe
email_reportso, dass sie nach der Aufgabegenerate_reportausgeführt wird.
Interaktive Übung
Vervollständige den Beispielcode, um diese Übung erfolgreich abzuschließen.
# 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