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 संभालता है

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

Python में Apache Airflow परिचय

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

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

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

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

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

@dag(start_date=datetime(2026,4,1))
def etl_example():
    # Chain extract, transform, and load, assigning the result
    ____ = load(____(extract()))
    # Run send_report after the ETL tasks
    etl_result ____ ____()
    
etl_example()

कोड संपादित करें और चलाएँ