airflow

6गर्मी

1उत्तर

निर्भर कार्य के लिए एयरफ्लो पास पैरामीटर

एयरफ्लो में निर्भर कार्यों में पैरामीटर पास करने का तरीका क्या है? मेरे पास बहुत सारी झाड़ियों की फाइलें हैं, और मैं इस दृष्टिकोण को एयरफ्लो में माइग्रेट करने का प्रयास कर रहा हूं, लेकिन मुझे नहीं पता

7गर्मी

2उत्तर

लैंडिंग समय एयरफ्लो में क्या मतलब है?

एयरफ्लो के वेब कंसोल पर डीएजी व्यू में "लैंडिंग टाइम" नामक एक अनुभाग है। An example screen shot taken from airbnb's blog: लेकिन यह क्या मतलब है? दस्तावेज़ों में या उनके भंडार में अब कोई परिभाषा नहीं ह

5गर्मी

3उत्तर

CeleryExecutor

मैं Airbnb हवा का प्रवाह कॉन्फ़िगर करने के लिए इस तरह CeleryExecutor इस्तेमाल करने की कोशिश के साथ काम करने वायु प्रवाह को विन्यस्त: मैं CeleryExecutor को SequentialExecutor से airflow.cfg में execute

25गर्मी

2उत्तर

बैकफिलिंग डैग रन से एयरफ्लो को कैसे रोकें?

कहें कि आपके पास एयरफ्लो डीएजी है जो बैकफिल को समझ में नहीं आता है, जिसका अर्थ है कि, इसे एक बार चलाने के बाद, इसे बाद में चलाने से पूरी तरह से व्यर्थ हो जाएगा। उदाहरण के लिए, यदि आप कुछ स्रोत से डेटा

12गर्मी

4उत्तर

टर्मिनल से एयरफ्लो डीएजी को ट्रिगर करना

मैं एक विशिष्ट वर्कफ़्लो को परिभाषित करने के लिए एयरफ्लो का उपयोग करने का प्रयास कर रहा हूं जिसे मैं कमांड लाइन से मैन्युअल रूप से ट्रिगर करना चाहता हूं। मैं डीएजी बनाता हूं और कार्यों का एक समूह जोड़

15गर्मी

2उत्तर

एयरफ्लो में डीएजी के बीच निर्भरताओं को कैसे सेट करें?

मैं बैच नौकरियों को निर्धारित करने के लिए Airflow का उपयोग कर रहा हूं। मेरे पास एक डीएजी (ए) है जो हर रात चलता है और एक और डीएजी (बी) जो प्रति माह एक बार चलता है। बी सफलतापूर्वक पूरा होने पर निर्भर कर

14गर्मी

2उत्तर

जबकि एयरफ्लो initdb, ImportError: नाम आयात नहीं कर सकता है HiveOperator

मैंने हाल ही में अपने वर्कफ़्लो के लिए airflow इंस्टॉल किया है। airflow initdb जो निम्नलिखित त्रुटि दिखाई:: अपने प्रोजेक्ट बनाते समय मैं निम्न आदेश निष्पादित [2016-08-15 11:17:00,314] {__init__.py:3

9गर्मी

2उत्तर

एयरफ्लो समांतरता

स्थानीय निष्पादक कार्यों को शेड्यूल करते समय नई प्रक्रियाओं को जन्म देता है। क्या यह प्रक्रियाओं की संख्या की सीमा है। मुझे इसे बदलने की जरूरत है। मुझे यह जानने की ज़रूरत है कि airflow.cfg में शेड्यूल

6गर्मी

2उत्तर

एयरफ्लो: एयरफ्लो

में एक डीएजी के लिए क्रोंटैब समय बदलना मेरे पास एक डीएजी है जो रोजाना 3:00 बजे चल रहा है, यह पिछले कुछ हफ्तों के लिए ठीक है। मैंने अब 7:00 बजे चलाने की तारीख अपडेट की है, लेकिन जाहिर है कि पिछले 2 दिन

8गर्मी

1उत्तर

एयरबर्न एयरफ्लो बनाम अपाचे निफ़ी

एयरफ्लो और निफ़ी वर्कफ़्लो पर एक ही काम करते हैं? प्रत्येक के लिए प्रो/कॉन क्या हैं? मुझे कुछ जेसन फाइलें पढ़ने की ज़रूरत है, इसमें अधिक कस्टम मेटाडेटा जोड़ें और इसे संसाधित करने के लिए एक कफका कतार म