Apache Airflow परिचय

Python में Apache Airflow परिचय

Mike Metzger

Data Engineer

Workflow क्या है?

  • Workflow - किसी दिए गए डेटा इंजीनियरिंग प्रोसेस को पूरा करने के चरणों का सेट

 

  • उदाहरण: फ़ाइलें डाउनलोड करें, डेटा कॉपी करें, जानकारी फ़िल्टर करें, और डेटाबेस में लिखें

डाउनलोड से डेटाबेस में लिखने तक क्रमिक डेटा इंजीनियरिंग चरणों का वर्कफ़्लो डायग्राम

Python में Apache Airflow परिचय

Airflow क्या है?

Airflow - वर्कफ़्लो ऑर्केस्ट्रेट करने का प्लेटफ़ॉर्म:

  • Create
  • Schedule
  • Monitor

 

Apache Airflow लोगो

   

वर्कफ़्लो को बनाना, शेड्यूल करना, और मॉनिटर करना दर्शाते आइकन

Python में Apache Airflow परिचय

Airflow क्या है?

  • किसी भी भाषा के प्रोग्राम चला सकता है, पर वर्कफ़्लो Python में लिखे जाते हैं
  • वर्कफ़्लो को Dags के रूप में लागू करता है
  • वेब इंटरफ़ेस, कोड, कमांड-लाइन, या REST API से एक्सेस करें
  • ETL पाइपलाइन, ML वर्कफ़्लो, ऑटोमेशन आदि के लिए उपयोग होता है

 

Apache Airflow लोगो

Python में Apache Airflow परिचय

Dags का त्वरित परिचय

Dag - एक मॉडल जो वर्कफ़्लो चलाने के लिए ज़रूरी सब कुछ दर्शाता है.

  • टास्क और उनकी निर्भरताओं से बना होता है
  • नाम, ईमेल, मालिक आदि विवरण से बनाया जाता है

निर्भरता तीरों से जुड़े टास्क का उदाहरण Dag

Python में Apache Airflow परिचय

Airflow के कॉम्पोनेंट्स

  • Scheduler - शेड्यूल्ड वर्कफ़्लो ट्रिगर करता है, टास्क सबमिट करता है
  • API Server - Airflow प्लेटफ़ॉर्म तक सुरक्षित, सुसंगत एक्सेस देता है
  • Dag processor - शेड्यूलर पढ़ता है ताकि कौन से टास्क कब चलाने हैं, तय कर सके
  • Metadata database - Dags और टास्क की स्थिति स्टोर करता है

Airflow कॉम्पोनेंट्स का डायग्राम: scheduler, API server, Dag processor, और metadata database

Python में Apache Airflow परिचय

Airflow UI में वर्कफ़्लो चलाना

Airflow Dags व्यू जिसमें दो लोडेड Dags और इंटरैक्शन विकल्प दिख रहे हैं

Python में Apache Airflow परिचय

Airflow UI में वर्कफ़्लो चलाना

Airflow Dags व्यू, जिसमें ट्रिगर प्ले बटन हाइलाइट है

Python में Apache Airflow परिचय

Airflow UI में वर्कफ़्लो चलाना

Airflow ट्रिगर Dag पॉपअप, डिफ़ॉल्ट रन विकल्प और Trigger बटन के साथ

Python में Apache Airflow परिचय

Airflow UI में वर्कफ़्लो चलाना

Airflow Dags व्यू, जिसमें सफल लेटेस्ट रन हरे टिक से चिन्हित है

Python में Apache Airflow परिचय

Airflow UI में वर्कफ़्लो चलाना

Airflow Dag रन टास्क व्यू, जिसमें generate_random_number जैसे व्यक्तिगत टास्क विवरण सूचीबद्ध हैं

Python में Apache Airflow परिचय

अभ्यास करते हैं!

Python में Apache Airflow परिचय

Preparing Video For Download...