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.
Descargue la última versión de Maven desde el enlace que figura a continuación.
Agregue una variable de entorno llamada M2_HOME y establezca el valor como directorio de instalación de maven.
Descargue Eclipse IDE desde el siguiente enlace.
Abra el símbolo del sistema y ejecute el comando Maven Archetype.
> 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.