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.