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.