वैरिएबल्स पूरी तरह सही नहीं
आपके बॉस ने आपसे यह जाँचने को कहा है कि सेल्स रिपोर्ट जेनरेट क्यों नहीं हो रही. आपने हाल ही में अपने एक Dag (process_sales) में वैरिएबल्स इम्प्लीमेंट किए हैं, जो assorted सेल्स डेटा प्रोसेस करता है और वही रिपोर्ट लिखता है जिसके बारे में आपके बॉस पूछ रहे हैं. लॉग देखते समय, आपको एहसास होता है कि यह इच्छित लोकेशन पर नहीं, बल्कि डिफ़ॉल्ट लोकेशन पर लिख रहा है.
रिपोर्ट प्रोसेस करने वाला टास्क यह करता है:
@task()
def parse_file():
output_path = Variable.get("Output_Path", default="/home")
output_fn = Variable.get("Output_Filename", default="sales_report.pdf")
save_file("{output_path}/{output_fn}")
फाइल को इस रूप में स्टोर होना चाहिए: /data/sales/sales_report.pdf.
लॉग आउटपुट देखने के लिए airflow dags test process_sales कमांड चलाने की कोशिश करें.
निम्न में से त्रुटि का कारण क्या है, और आप इसे कैसे ठीक करेंगे?
यह अभ्यास पाठ्यक्रम का हिस्सा है
Python में Apache Airflow परिचय
इंटरैक्टिव व्यावहारिक अभ्यास
हमारे इंटरैक्टिव अभ्यासों में से किसी एक के साथ सिद्धांत को व्यवहार में बदलें
अभ्यास शुरू करें