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

Connected

अभ्यास

Callback फ़ंक्शन लागू करना

हाल ही में आपको अपनी टीम द्वारा बनाए गए Dags में failure callbacks जोड़ने का काम मिला है. शुरुआत के लिए, आप एक सरल failure callback जोड़ना चाहते हैं जो sales_etl_dag के फेल होने पर audit log में एक मैसेज लिखे.

dag और task ऑब्जेक्ट पहले से इम्पोर्ट किए गए हैं और get_sales_data तथा process_sales_data टास्क बनाए जा चुके हैं.

निर्देश

100 XP
  • alert_on_failure नाम का एक callback फ़ंक्शन बनाएँ.
  • फ़ंक्शन को ऐसे परिभाषित करें कि Airflow जो भी ऑब्जेक्ट्स पास करे, वह उन्हें स्वीकार कर सके.
  • alert_on_failure फ़ंक्शन का इस्तेमाल करते हुए failure callback निर्दिष्ट करें.