Menerapkan SmtpNotifier
Setelah Anda berhasil membuat callback untuk kegagalan, atasan tim meminta agar semua run Dag yang berhasil dikirim melalui email ke alias tim. Setelah meninjau dokumentasi Airflow, Anda memutuskan bahwa menggunakan kerangka kerja notifier bawaan Airflow adalah opsi terbaik.
Objek dag dan task sudah diimpor, fungsi callback alert_on_failure serta task get_sales_data dan process_sales_data sudah disiapkan untuk Anda.
Latihan ini merupakan bagian dari kursus
Pengantar Apache Airflow dengan Python
Instruksi latihan
- Impor objek notifier SMTP.
- Tambahkan atribut callback sukses ke Dag.
- Kirim notifikasi ke [email protected].
- Sertakan subjek.
Latihan interaktif langsung praktik
Cobalah latihan ini dengan melengkapi kode contoh ini.
# Import the notifier
from airflow.providers.smtp.notifications.smtp import ____
# Add a success callback notifier
@dag(dag_id='sales_etl_dag',
on_failure_callback=alert_on_failure,
____=SmtpNotifier(
to="____",
from_email="[email protected]",
____="sales_etl_dag run succeeded!"
))
def sales_etl_dag():
get_sales_data() >> process_sales_data()
sales_etl_dag()