Genereer en mail een rapport

Airflow biedt de mogelijkheid om bijna elke soort workflow te automatiseren. Je wilt een rapport van Airflow ontvangen zodra taken zijn voltooid, zonder de UI of logbestanden voortdurend te hoeven controleren. Je besluit de e-mailfunctionaliteit in Airflow te gebruiken om dit bericht te versturen.

Alle gebruikelijke Airflow-componenten zijn al voor je geïmporteerd en er is al een DAG gedefinieerd als report_dag.

Deze oefening maakt deel uit van de cursus

Introductie tot Apache Airflow in Python

Cursus bekijken

Oefeninstructies

Definieer de juiste operator voor de taak email_report.
Vul de ontbrekende details in voor de Operator. Gebruik het bestand monthly_report.pdf.
Laat de taak email_report plaatsvinden ná de taak generate_report.

Praktische interactieve oefening

Probeer deze oefening eens door deze voorbeeldcode in te vullen.

# 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

Code bewerken en uitvoeren