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

अभ्यास

और @tasks

अपने वर्कफ़्लो को आगे बढ़ाने के लिए, आपको डाउनलोड की गई फ़ाइल के बदलावों को पार्स करके सेव करने का एक और स्टेप जोड़ना है। Dag process_sales परिभाषित है और उसमें pull_file टास्क पहले से जोड़ा गया है। इस केस में, Python फंक्शन आपके लिए पहले से परिभाषित है: parse_file(inputfile, outputfile).

ध्यान दें कि Airflow टास्क लागू करते समय, अक्सर आपको दिए गए हर स्टेप का पूरा मतलब समझ में आए, यह ज़रूरी नहीं होता। जब तक आप समझते हैं कि इन स्टेप्स को Airflow की संरचना में कैसे लपेटना है, आप मनचाहा वर्कफ़्लो लागू कर पाएँगे.

निर्देश

100 XP
  • parse_file मेथड का उपयोग करके एक Airflow टास्क बनाएँ.
  • टास्क को ज़रूरी आर्ग्युमेंट्स के साथ कॉल करें.