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