2016-05-25 5 views
5

मैं अगर वहाँ बुलेटिन संदेशों (मूल रूप से त्रुटियों) कि Nifi यूआई पर प्रकट को पकड़ने और कुछ विशेषता/फ़ाइल में संग्रहीत इतना है कि यह देखा जा सकता है के लिए एक रास्ता है जानना चाहता हूँ में बुलेटिन संदेशों पर कब्जा करने के बाद में। स्क्रीन हर 5 मिनट में ताज़ा हो जाती है और यदि किसी भी प्रोसेसर में विफलता है तो मैं इसके कारण को जानना चाहता हूं।कैसे अपाचे nifi

मैं विशेष रूप से लॉगिंग हिस्से के बारे में बात नहीं कर रहा हूं।

उत्तर

5

कि आप जानते हैं, बुलेटिन संदेशों को पहले से ही लॉग ऑन हैं कि दर्शाते हैं। तो यह सारी सामग्री पहले से ही {NIFI_HOME} /logs/nifi-app.log में संग्रहीत है। हालांकि, अगर आप सीधे बुलेटिन का उपभोग करना चाहते हैं तो आपके पास कुछ अलग-अलग विकल्प हैं।

  • आप आरईएसटी एपीआई से बुलेटिन का उपभोग कर सकते हैं। बुलेटिन तक पहुंचने के लिए कुछ अंतराल हैं।

http [एस]: // {मेजबान}: {बंदरगाह}/nifi-api/नियंत्रक/प्रक्रिया समूहों/{प्रक्रिया-समूह-id}/स्थिति पुनरावर्ती = सच

यह अनुरोध निर्दिष्ट प्रक्रिया समूह के तहत सभी घटकों की स्थिति (बुलेटिन सहित) प्राप्त करेगा। आप मूल स्तर प्रक्रिया समूह के लिए उपनाम 'रूट' का उपयोग कर सकते हैं। रिकर्सिव फ्लैग इंगित करेगा कि उस प्रक्रिया समूह या सभी वंश घटकों के बच्चों को वापस लौटना है या नहीं।

http [एस]: // {मेजबान}: {बंदरगाह}/nifi-api/नियंत्रक/स्थिति

यह अनुरोध नियंत्रक स्तर घटकों के (बुलेटिन सहित) का दर्जा मिल जाएगा। इसमें नियंत्रक सेवाओं, रिपोर्टिंग कार्य, और निफ़ी फ्रेमवर्क स्वयं (क्लस्टरिंग संदेश इत्यादि) से किसी भी रिपोर्ट किए गए बुलेटिन शामिल हैं।

http [एस]: // {मेजबान}: {बंदरगाह}/nifi-api/नियंत्रक/बुलेटिन बोर्ड सीमा = n & sourceid = {id} & संदेश = {} str

यह अनुरोध सभी बुलेटिन तक पहुंच जाएगा और फ़िल्टरिंग आधारित घटकों, संदेश का समर्थन करेगा और बुलेटिन की संख्या को सीमित करेगा।

  • आप एक रिपोर्टिंग कार्य कार्यान्वयन भी बना सकते हैं जिसके पास बुलेटिन भंडार तक पहुंच है। रिपोर्टिंग कार्य एक विस्तार बिंदु हैं जो इस एनआईएफआई उदाहरण से विवरण की रिपोर्ट करने के लिए हैं। इसके लिए कुछ जावा कोड की आवश्यकता होगी लेकिन आपको बुलेटिन की रिपोर्ट करने की अनुमति होगी, हालांकि आपको पसंद है। यहां एक उदाहरण दिया गया है जो अंबारी [1] को मेट्रिक्स की रिपोर्ट करता है।

[1] https://github.com/apache/nifi/blob/master/nifi-nar-bundles/nifi-ambari-bundle/nifi-ambari-reporting-task/src/main/java/org/apache/nifi/reporting/ambari/AmbariReportingTask.java

+0

इन सुझावों के लिए धन्यवाद। जल्द ही उन्हें आज़माएं और यह बताएंगे कि यह काम करता है या नहीं। –