Apache NiFi: creación de flujos

Apache NiFi ofrece una gran cantidad de componentes para ayudar a los desarrolladores a crear flujos de datos para cualquier tipo de protocolos o fuentes de datos. Para crear un flujo, un desarrollador arrastra los componentes de la barra de menú al lienzo y los conecta haciendo clic y arrastrando el mouse de un componente a otro.

Generalmente, una NiFi tiene un componente de escucha al inicio del flujo como getfile, que obtiene los datos del sistema de origen. En el otro extremo hay un componente transmisor como putfile y hay componentes intermedios que procesan los datos.

Por ejemplo, creemos un flujo, que toma un archivo vacío de un directorio y agrega algo de texto en ese archivo y lo coloca en otro directorio.

• Para empezar, arrastre el icono del procesador al lienzo de NiFi y seleccione el procesador GetFile de la lista.

• Crea un directorio de entrada como c:\inputdir.

• Haga clic derecho en el procesador y seleccione configurar y en la pestaña de propiedades agregar Input Directory (c:\inputdir) y haga clic en Aplicar y volver al lienzo.

• Arrastre el icono del procesador al lienzo y seleccione el procesador Reemplazar texto de la lista.

• Haga clic derecho en el procesador y seleccione configurar. En elproperties pestaña, agregue un texto como “Hello tutorialspoint.com” en el cuadro de texto de Valor de reemplazo y haga clic en Aplicar.

• Vaya a la pestaña de configuración, marque la casilla de verificación de falla en el lado derecho y luego regrese al lienzo.

• Conecte el procesador GetFIle a ReplaceText en relación con el éxito.

• Arrastre el icono del procesador al lienzo y seleccione el procesador PutFile de la lista.

• Crea un directorio de salida como c:\outputdir.

• Haga clic derecho en el procesador y seleccione configurar. En la pestaña de propiedades, agregueDirectory (c:\outputdir) y haga clic en Aplicar y volver al lienzo.

• Vaya a la pestaña de configuración y marque la casilla de verificación de falla y éxito en el lado derecho y luego vuelva al lienzo.

• Conecte el procesador ReplaceText a PutFile en relación con el éxito.

• Ahora inicie el flujo y agregue un archivo vacío en el directorio de entrada y verá que se moverá al directorio de salida y el texto se agregará al archivo.

Siguiendo los pasos anteriores, los desarrolladores pueden elegir cualquier procesador y otro componente NiFi para crear un flujo adecuado para su organización o cliente.