Apache NiFi - Prosesor Khusus
Apache NiFi adalah platform sumber terbuka dan memberi pengembang opsi untuk menambahkan prosesor kustom mereka di pustaka NiFi. Ikuti langkah-langkah ini untuk membuat prosesor kustom.
Unduh Maven versi terbaru dari tautan yang diberikan di bawah ini.
https://maven.apache.org/download.cgi
Tambahkan variabel lingkungan bernama M2_HOME dan tetapkan nilai sebagai direktori instalasi maven.
Unduh Eclipse IDE dari tautan di bawah ini.
https://www.eclipse.org/downloads/download.php
Buka command prompt dan jalankan perintah Maven Archetype.
> mvn archetype:generate
Cari tipe nifi dalam proyek arketipe.
Pilih org.apache.nifi: proyek nifi-processor-bundle-archetype.
Kemudian dari daftar versi pilih versi terbaru yaitu 1.7.1 untuk tutorial ini.
Masukkan groupId, artifactId, versi, paket, dan artifactBaseName dll.
Kemudian proyek maven akan dibuat dengan direktori.
nifi-<artifactBaseName>-processors
nifi-<artifactBaseName>-nar
Jalankan perintah di bawah ini di direktori nifi- <artifactBaseName> -processors untuk menambahkan proyek di eclipse.
mvn install eclipse:eclipse
Buka eclipse dan pilih impor dari menu file.
Kemudian pilih "Proyek yang Ada ke dalam ruang kerja" dan tambahkan proyek dari direktori nifi- <artifactBaseName> -processors di eclipse.
Tambahkan kode Anda dalam fungsi public void onTrigger (konteks ProsesContext, sesi ProsesSesi), yang berjalan kapan pun prosesor dijadwalkan untuk dijalankan.
Kemudian paketkan kode ke file NAR dengan menjalankan perintah yang disebutkan di bawah ini.
mvn clean install
File NAR akan dibuat di nifi-
-nar / target direktori. Salin file NAR ke folder lib Apache NiFi dan mulai ulang NiFi.
Setelah NiFi berhasil dimulai ulang, periksa daftar prosesor untuk prosesor kustom baru.
Untuk kesalahan apa pun, periksa file ./logs/nifi.log.