शुरू करेंमुफ़्त में शुरू करें

SmtpNotifier लागू करना

अब जबकि आपने सफलतापूर्वक एक failure callback बना लिया है, आपके टीम लीड ने कहा है कि सभी सफल Dag runs एक टीम एलियस पर ईमेल से भेजे जाएँ. Airflow डॉक्यूमेंटेशन की समीक्षा करने के बाद, आप तय करते हैं कि Airflow के बिल्ट-इन notifier फ़्रेमवर्क का उपयोग करना सबसे अच्छा विकल्प है.

dag और task ऑब्जेक्ट पहले से import किए गए हैं, alert_on_failure callback फंक्शन और get_sales_data तथा process_sales_data टास्क आपके लिए पहले से परिभाषित हैं.

यह अभ्यास पाठ्यक्रम का हिस्सा है

Python में Apache Airflow परिचय

पाठ्यक्रम देखें

अभ्यास निर्देश

  • SMTP notifier ऑब्जेक्ट import करें.
  • Dag में एक success callback एट्रिब्यूट जोड़ें.
  • नोटिफिकेशन [email protected] पर भेजें.
  • एक subject शामिल करें.

इंटरैक्टिव व्यावहारिक अभ्यास

इस अभ्यास को इस नमूना कोड को पूरा करके आज़माएँ।

# 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()
कोड संपादित करें और चलाएँ