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