Menghasilkan dan mengirim laporan melalui email

Airflow menyediakan kemampuan untuk mengotomatisasi hampir semua jenis alur kerja. Anda ingin menerima laporan dari Airflow saat tugas selesai tanpa perlu terus-menerus memantau UI atau berkas log. Anda memutuskan untuk menggunakan fungsi email dalam Airflow untuk menyampaikan pesan ini.

Semua komponen Airflow yang umum telah diimpor untuk Anda, dan sebuah DAG sudah didefinisikan sebagai report_dag.

Latihan ini adalah bagian dari kursus

Pengantar Apache Airflow dengan Python

Lihat Kursus

Petunjuk latihan

Tentukan operator yang tepat untuk tugas email_report.
Lengkapi detail yang hilang untuk Operator. Gunakan berkas bernama monthly_report.pdf.
Atur agar tugas email_report terjadi setelah tugas generate_report.

Latihan interaktif praktis

Cobalah latihan ini dengan menyelesaikan kode contoh berikut.

# 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

Edit dan Jalankan Kode