Générer un rapport et l'envoyer par courrier électronique

Airflow permet d'automatiser presque tous les types de flux de travail. Vous souhaitez recevoir un rapport d'Airflow lorsque les tâches sont terminées sans avoir à surveiller en permanence le site UI ou les fichiers journaux. Vous décidez d'utiliser la fonctionnalité email d'Airflow pour envoyer ce message.

Tous les composants typiques du flux d'air ont été importés pour vous et un site DAG est déjà défini comme report_dag.

Cet exercice fait partie du cours

Introduction à Apache Airflow en Python

Afficher le cours

Instructions

Définissez l'opérateur approprié pour la tâche email_report.
Complétez les informations manquantes pour l'opérateur. Utilisez le fichier nommé monthly_report.pdf.
Paramétrez la tâche email_report pour qu'elle se déroule après la tâche generate_report.

Exercice interactif pratique

Essayez cet exercice en complétant cet exemple de code.

# 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

Modifier et exécuter le code