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

अभ्यास

XCom के साथ डेटा पास करना

आप एक ETL workflow को अपडेट कर रहे हैं ताकि जानकारी को आसान तरीके से track रखने के लिए XCom का इस्तेमाल किया जा सके. इस कारण, आपको अपने Dag में tasks के बीच dependencies अपडेट करनी हैं.

आपके पास चार tasks पहले से defined हैं, जिन्हें इस प्रकार उपयोग किया जा सकता है:

  • extract() - order_data रिटर्न करता है
  • transform(order_data) - summarized data रिटर्न करता है
  • load(summary_data) - XCom जानकारी रिटर्न नहीं करता
  • send_report() - एक non-XCom task जो notifications संभालता है

निर्देश

100 XP
  • चेन पूरी करने के लिए extract() और load() के बीच transform टास्क insert करें.
  • परिणाम को etl_result नाम के वैरिएबल में असाइन करें.
  • etl_result वैरिएबल के बाद send_report चलने के लिए सेट करें.