Python में Apache Airflow परिचय
Mike Metzger
Data Engineer

airflow.sdk.BaseSensorOperator से व्युत्पन्नmode - शर्त कैसे जाँची जाएmode='poke' - डिफ़ॉल्ट, बार-बार चलाएँmode='reschedule' - टास्क स्लॉट छोड़ें और बाद में फिर कोशिश करेंpoke_interval - जाँचों के बीच इंतज़ार का अंतरालtimeout - फेल होने से पहले कितनी देर तक इंतज़ार करेंairflow.providers.standard.sensors लाइब्रेरी का हिस्सा हैfrom airflow.providers.standard.sensors.filesystem import FileSensor
file_sensor_task = FileSensor(task_id='file_sense',
filepath='salesdata.csv',
poke_interval=300,
timeout=3000
)
init_sales_cleanup() >> file_sensor_task >> generate_report()
airflow.providers.*.sensors में और भी कईExternalTaskSensor - दूसरे Dag के टास्क के पूरा होने तक इंतज़ार करेंHttpSensor - वेब URL रिक्वेस्ट भेजें और कंटेंट चेक करेंSqlSensor - कंटेंट चेक करने के लिए SQL क्वेरी चलाता है

Python में Apache Airflow परिचय