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.