1. Learn
  2. /
  3. कोर्स
  4. /
  5. Python में Apache Airflow परिचय

Connected

अभ्यास

SmtpNotifier लागू करना

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

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

निर्देश

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