Apache NiFi - Procesador personalizado

Apache NiFi es una plataforma de código abierto y ofrece a los desarrolladores las opciones para agregar su procesador personalizado en la biblioteca de NiFi. Siga estos pasos para crear un procesador personalizado.

> mvn archetype:generate
  • Busque el tipo nifi en los proyectos de arquetipo.

  • Seleccione org.apache.nifi: proyecto nifi-processor-bundle-archetype.

  • Luego, de la lista de versiones, seleccione la última versión, es decir, 1.7.1 para este tutorial.

  • Ingrese groupId, artifactId, versión, paquete y artifactBaseName, etc.

  • Luego, se creará un proyecto maven teniendo directorios.

    • nifi-<artifactBaseName>-processors

    • nifi-<artifactBaseName>-nar

  • Ejecute el siguiente comando en el directorio nifi- <artifactBaseName> -processors para agregar el proyecto en el eclipse.

mvn install eclipse:eclipse
  • Abra eclipse y seleccione importar en el menú de archivo.

  • Luego seleccione “Proyectos existentes en el espacio de trabajo” y agregue el proyecto desde el directorio nifi- <artifactBaseName> -processors en eclipse.

  • Agregue su código en la función public void onTrigger (contexto ProcessContext, sesión ProcessSession), que se ejecuta siempre que un procesador esté programado para ejecutarse.

  • Luego empaquete el código en un archivo NAR ejecutando el comando mencionado a continuación.

mvn clean install
  • Se creará un archivo NAR en nifi- -nar / directorio de destino.

  • Copie el archivo NAR en la carpeta lib de Apache NiFi y reinicie NiFi.

  • Después de un reinicio exitoso de NiFi, consulte la lista de procesadores para el nuevo procesador personalizado.

  • Para cualquier error, consulte el archivo ./logs/nifi.log.