Apache NiFi - niestandardowy procesor

Apache NiFi to platforma typu open source, która daje programistom możliwość dodania własnego procesora do biblioteki NiFi. Wykonaj poniższe czynności, aby utworzyć niestandardowy procesor.

  • Pobierz najnowszą wersję Maven z linku podanego poniżej.

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

  • Dodaj zmienną środowiskową o nazwie M2_HOME i ustaw wartość jako katalog instalacyjny maven.

  • Pobierz Eclipse IDE z poniższego łącza.

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

  • Otwórz wiersz poleceń i wykonaj polecenie Maven Archetype.

> mvn archetype:generate
  • Wyszukaj typ nifi w projektach archetypów.

  • Wybierz projekt org.apache.nifi: nifi-procesor-bundle-archetype.

  • Następnie z listy wersji wybierz najnowszą wersję tj. 1.7.1 dla tego samouczka.

  • Wprowadź identyfikator grupy, identyfikator artefaktu, wersję, pakiet i nazwę artefaktuBaseName itp.

  • Następnie zostanie utworzony projekt mavena zawierający katalogi.

    • nifi-<artifactBaseName>-processors

    • nifi-<artifactBaseName>-nar

  • Uruchom poniższe polecenie w katalogu nifi- <artifactBaseName> -processors, aby dodać projekt w zaćmieniu.

mvn install eclipse:eclipse
  • Otwórz eclipse i wybierz import z menu pliku.

  • Następnie wybierz opcję „Istniejące projekty w obszarze roboczym” i dodaj projekt z katalogu nifi- <artifactBaseName> -processors w eclipse.

  • Dodaj swój kod w funkcji public void onTrigger (kontekst ProcessContext, sesja ProcessSession), która jest uruchamiana zawsze, gdy planowane jest uruchomienie procesora.

  • Następnie spakuj kod do pliku NAR, uruchamiając poniższe polecenie.

mvn clean install
  • Plik NAR zostanie utworzony pod adresem nifi- -nar / katalog docelowy.

  • Skopiuj plik NAR do folderu lib w Apache NiFi i uruchom ponownie NiFi.

  • Po pomyślnym ponownym uruchomieniu NiFi sprawdź listę procesorów dla nowego niestandardowego procesora.

  • Poszukaj błędów w pliku ./logs/nifi.log.