Genera e invia un report via email
Airflow offre la possibilità di automatizzare quasi qualsiasi tipo di workflow. Vorresti ricevere un report da Airflow quando i task si completano, senza dover controllare continuamente l'interfaccia o i file di log. Decidi quindi di usare la funzionalità email di Airflow per inviare questo messaggio.
Tutti i componenti tipici di Airflow sono già stati importati per te e un DAG è già definito come report_dag.
Questo esercizio fa parte del corso
Introduzione ad Apache Airflow in Python
Istruzioni dell'esercizio
- Definisci l'operatore corretto per il task
email_report. - Compila i dettagli mancanti dell'Operator. Usa il file chiamato
monthly_report.pdf. - Imposta il task
email_reportin modo che avvenga dopo il taskgenerate_report.
Esercizio pratico interattivo
Prova a risolvere questo esercizio completando il codice di esempio.
# 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