Apache NiFi - Пользовательский процессор
Apache NiFi - это платформа с открытым исходным кодом, которая дает разработчикам возможность добавить свой собственный процессор в библиотеку NiFi. Выполните следующие действия, чтобы создать собственный процессор.
Загрузите последнюю версию Maven по приведенной ниже ссылке.
https://maven.apache.org/download.cgi
Добавьте переменную среды с именем M2_HOME и установите значение в качестве каталога установки maven.
Загрузите Eclipse IDE по ссылке ниже.
https://www.eclipse.org/downloads/download.php
Откройте командную строку и выполните команду Maven Archetype.
> mvn archetype:generate
Найдите тип nifi в архетипических проектах.
Выберите проект org.apache.nifi: nifi-processor-bundle-archetype.
Затем из списка версий выберите последнюю версию, то есть 1.7.1 для этого руководства.
Введите groupId, artifactId, версию, пакет, artifactBaseName и т. Д.
Затем будет создан проект maven с каталогами.
nifi-<artifactBaseName>-processors
nifi-<artifactBaseName>-nar
Выполните приведенную ниже команду в каталоге nifi- <artifactBaseName> -processors, чтобы добавить проект в eclipse.
mvn install eclipse:eclipse
Откройте eclipse и выберите импорт в меню файла.
Затем выберите «Существующие проекты в рабочую область» и добавьте проект из каталога nifi- <artifactBaseName> -processors в eclipse.
Добавьте свой код в функцию public void onTrigger (контекст ProcessContext, сеанс ProcessSession), которая запускается всякий раз, когда запланирован запуск процессора.
Затем упакуйте код в файл NAR, выполнив указанную ниже команду.
mvn clean install
Файл NAR будет создан в nifi-
-nar / целевой каталог. Скопируйте файл NAR в папку lib Apache NiFi и перезапустите NiFi.
После успешного перезапуска NiFi проверьте список процессоров на наличие нового пользовательского процессора.
На наличие ошибок проверьте файл ./logs/nifi.log.