FileSensor बनाना

FileSensors के बारे में पढ़ने के बाद, आप एक बेसिक FileSensor बनाकर यह समझना चाहते हैं कि इनके साथ कौन-कौन से पैरामीटर इस्तेमाल होते हैं. यह FileSensor इस तरह डिज़ाइन होगा कि आगे बढ़ने से पहले एक विशेष डेटा फ़ाइल मौजूद होना सुनिश्चित करे.

FileSensor नियमित अंतराल पर फ़ाइल को पोल करता है और timeout सेकंड बीत जाने पर इंतज़ार करना बंद कर देता है. mode='reschedule' होने पर, हर पोल के बीच वर्कर स्लॉट रिलीज़ हो जाता है.

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

Python में Apache Airflow परिचय

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

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

FileSensor इस्तेमाल करने के लिए उपयुक्त लाइब्रेरी इम्पोर्ट करें.
precheck रेफ़रेंस को FileSensor ऑब्जेक्ट पर सेट करें.
FileSensor को "salesdata_ready.csv" फ़ाइल ढूँढने के लिए कॉन्फ़िगर करें.
timeout को 5 मिनट पर सेट करें.

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

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

# Import the FileSensor class
from airflow.providers.standard.sensors.filesystem import ____

# Set the file sensor to an alias
precheck = ____(
  task_id='check_for_datafile',
  # Wait for this file to exist before continuing
  filepath='____',
  timeout=____,
  mode="reschedule"
)

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