Apache NiFi - Özel İşlemci

Apache NiFi, açık kaynaklı bir platformdur ve geliştiricilere kendi özel işlemcilerini NiFi kitaplığına ekleme seçenekleri sunar. Özel bir işlemci oluşturmak için aşağıdaki adımları izleyin.

• Maven'in son sürümünü aşağıda verilen bağlantıdan indirin.

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

• M2_HOME adlı bir ortam değişkeni ekleyin ve değeri maven kurulum dizini olarak ayarlayın.

• Eclipse IDE'yi aşağıdaki bağlantıdan indirin.

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

• Komut istemini açın ve Maven Archetype komutunu çalıştırın.

> mvn archetype:generate

• Arketip projelerinde nifi türünü arayın.

• Org.apache.nifi: nifi-işlemci-paket-arketip projesi seçin.

• Ardından sürüm listesinden en son sürümü, yani bu eğitim için 1.7.1'i seçin.

• GroupId, artifactId, version, package ve artifactBaseName vb. Girin.

• Daha sonra dizinler içeren bir maven projesi oluşturulacaktır.

  • nifi-<artifactBaseName>-processors

  • nifi-<artifactBaseName>-nar

• Projeyi tutulmaya eklemek için nifi- <artifactBaseName> -processors dizininde aşağıdaki komutu çalıştırın.

mvn install eclipse:eclipse

• Tutulmayı açın ve dosya menüsünden içe aktarmayı seçin.

• Daha sonra “Existing Projects into workspace” i seçin ve nifi- <artifactBaseName> -processors dizininden projeyi eclipse'e ekleyin.

• Kodunuzu, bir işlemcinin çalışması planlandığında çalışan genel void onTrigger (ProcessContext bağlamı, ProcessSession oturumu) işlevine ekleyin.

• Ardından, aşağıda belirtilen komutu çalıştırarak kodu bir NAR dosyasına paketleyin.

mvn clean install

• Nifi- adresinde bir NAR dosyası oluşturulacak -nar / hedef dizin.

• NAR dosyasını Apache NiFi'nin lib klasörüne kopyalayın ve NiFi'yi yeniden başlatın.

• NiFi'nin başarılı bir şekilde yeniden başlatılmasından sonra, yeni özel işlemci için işlemci listesini kontrol edin.

• Herhangi bir hata için ./logs/nifi.log dosyasını kontrol edin.