Учебники

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.

Ищите тип 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 / целевой каталог.

Скопируйте файл NAR в папку lib Apache NiFi и перезапустите NiFi.

После успешного перезапуска NiFi проверьте список процессоров для нового пользовательского процессора.

На наличие ошибок проверьте файл ./logs/nifi.log.