Apache NiFi - โปรเซสเซอร์ที่กำหนดเอง

Apache NiFi เป็นแพลตฟอร์มโอเพ่นซอร์สและช่วยให้นักพัฒนามีตัวเลือกในการเพิ่มโปรเซสเซอร์ที่กำหนดเองในไลบรารี NiFi ทำตามขั้นตอนเหล่านี้เพื่อสร้างโปรเซสเซอร์แบบกำหนดเอง

• ดาวน์โหลด Maven เวอร์ชันล่าสุดจากลิงค์ด้านล่าง

  https://maven.apache.org/download.cgi

• เพิ่มตัวแปรสภาพแวดล้อมชื่อ M2_HOME และตั้งค่าเป็นไดเร็กทอรีการติดตั้งของ maven

• ดาวน์โหลด Eclipse IDE จากลิงค์ด้านล่าง

  https://www.eclipse.org/downloads/download.php

• เปิดพรอมต์คำสั่งและดำเนินการคำสั่ง Maven Archetype

> mvn archetype:generate

• ค้นหาประเภท nifi ในโครงการต้นแบบ

• เลือก org.apache.nifi: nifi-processor-bundle-archetype project

• จากรายการเวอร์ชันให้เลือกเวอร์ชันล่าสุดคือ 1.7.1 สำหรับบทช่วยสอนนี้

• ป้อน groupId, artifactId, version, package และ artifactBaseName เป็นต้น

• จากนั้นโครงการ maven จะถูกสร้างขึ้นโดยต้องมีไดเรกทอรี

  • nifi-<artifactBaseName>-processors

  • nifi-<artifactBaseName>-nar

• รันคำสั่งด้านล่างในไดเร็กทอรี nifi- <artifactBaseName> -processors เพื่อเพิ่มโปรเจ็กต์ใน eclipse

mvn install eclipse:eclipse

• เปิด eclipse และเลือกอิมพอร์ตจากเมนูไฟล์

• จากนั้นเลือก“ โปรเจ็กต์ที่มีอยู่ลงในพื้นที่ทำงาน” และเพิ่มโปรเจ็กต์จากไดเร็กทอรี nifi- <artifactBaseName> -processors ใน eclipse

• เพิ่มโค้ดของคุณในฟังก์ชัน onTrigger (บริบท ProcessContext, เซสชัน ProcessSession) ที่เป็นโมฆะสาธารณะซึ่งจะทำงานเมื่อโปรเซสเซอร์ถูกกำหนดให้รัน

• จากนั้นแพ็กเกจโค้ดเป็นไฟล์ NAR โดยเรียกใช้คำสั่งที่กล่าวถึงด้านล่าง

mvn clean install

• ไฟล์ NAR จะถูกสร้างขึ้นที่ nifi- ไดเร็กทอรี -nar / target

• คัดลอกไฟล์ NAR ไปยังโฟลเดอร์ lib ของ Apache NiFi และรีสตาร์ท NiFi

• หลังจากรีสตาร์ท NiFi สำเร็จให้ตรวจสอบรายการโปรเซสเซอร์สำหรับโปรเซสเซอร์ที่กำหนดเองใหม่

• สำหรับข้อผิดพลาดโปรดตรวจสอบไฟล์. /logs/nifi.log