Générer et envoyer un rapport par e‑mail

Airflow permet d’automatiser pratiquement tous les types de workflows. Vous souhaitez recevoir un rapport d’Airflow lorsque les tâches se terminent, sans devoir surveiller en permanence l’interface ou les fichiers journaux. Vous décidez d’utiliser la fonctionnalité d’envoi d’e‑mails d’Airflow pour transmettre ce message.

Tous les composants Airflow classiques ont été importés pour vous, et un DAG est déjà défini sous le nom 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.
Renseignez les informations manquantes pour l’Operator. Utilisez le fichier nommé monthly_report.pdf.
Faites en sorte que la tâche email_report s’exécute 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