Apache NiFi - कस्टम प्रोसेसर
Apache NiFi एक ओपन सोर्स प्लेटफॉर्म है और डेवलपर्स को NiFi लाइब्रेरी में अपने कस्टम प्रोसेसर को जोड़ने का विकल्प देता है। कस्टम प्रोसेसर बनाने के लिए इन चरणों का पालन करें।
नीचे दिए गए लिंक से मावेन नवीनतम संस्करण डाउनलोड करें।
https://maven.apache.org/download.cgi
M2_HOME नामक एक पर्यावरण चर जोड़ें और मावेन की स्थापना निर्देशिका के रूप में मान सेट करें।
नीचे दिए गए लिंक से ग्रहण आईडीई डाउनलोड करें।
https://www.eclipse.org/downloads/download.php
ओपन कमांड प्रॉम्प्ट और मावेन आर्केचेप कमांड को निष्पादित करें।
> mvn archetype:generate
आर्कटिक प्रोजेक्ट्स में nifi टाइप के लिए सर्च करें।
Org.apache.nifi को चुनें: nifi-processor-बंडल-आर्कहाइट प्रोजेक्ट।
फिर संस्करणों की सूची से इस ट्यूटोरियल के लिए नवीनतम संस्करण अर्थात 1.7.1 का चयन करें।
GroupId, विरूपण साक्ष्य, संस्करण, पैकेज और कलावाचन नाम दर्ज करें आदि।
तब निर्देशिकाओं के लिए एक मावेन परियोजना बनाई जाएगी।
nifi-<artifactBaseName>-processors
nifi-<artifactBaseName>-nar
नीचे दिए गए कमांड को nifi- <विरूपण साक्ष्यसेनैम> -प्रोसेसर निर्देशिका में जोड़ें ताकि प्रोजेक्ट को ग्रहण में जोड़ा जा सके।
mvn install eclipse:eclipse
ग्रहण खोलें और फ़ाइल मेनू से आयात का चयन करें।
फिर "मौजूदा प्रोजेक्ट्स को कार्यक्षेत्र में" चुनें और प्रोजेक्ट को nifi- <विरूपण साक्ष्यसेनमेले> -प्रोसेसर को ग्रहण में जोड़ें।
सार्वजनिक शून्य onTrigger (ProcessContext संदर्भ, ProcessSession सत्र) फ़ंक्शन में अपना कोड जोड़ें, जो कभी भी प्रोसेसर को चलाने के लिए निर्धारित होता है।
फिर नीचे बताए गए कमांड को चलाकर कोड को एक NAR फ़ाइल में पैकेज करें।
mvn clean install
NAR पर एक NAR फ़ाइल बनाई जाएगी-
-नर / लक्ष्य निर्देशिका। Apache NiFi के काम के फ़ोल्डर में NAR फाइल कॉपी करें और NiFi पुनः आरंभ करें।
NiFi के सफल पुनरारंभ के बाद, नए कस्टम प्रोसेसर के लिए प्रोसेसर सूची की जाँच करें।
किसी भी त्रुटि के लिए, ./logs/nifi.log फ़ाइल देखें।