Apache NiFi - Relación de procesadores

En un flujo de datos Apache NiFi, los archivos de flujo se mueven de un procesador a otro a través de una conexión que se valida mediante una relación entre procesadores. Siempre que se crea una conexión, un desarrollador selecciona una o más relaciones entre esos procesadores.

Como puede ver en la imagen de arriba, las casillas de verificación en el rectángulo negro son relaciones. Si un desarrollador selecciona estas casillas de verificación, el archivo de flujo terminará en ese procesador en particular, cuando la relación sea exitosa o fracasada, o ambos.

Éxito

Cuando un procesador procesa con éxito un archivo de flujo como almacenar o recuperar datos de cualquier fuente de datos sin obtener ninguna conexión, autenticación o cualquier otro error, el archivo de flujo pasa a la relación de éxito.

Fracaso

Cuando un procesador no puede procesar un archivo de flujo sin errores como un error de autenticación o un problema de conexión, etc., el archivo de flujo pasa a una relación de falla.

Un desarrollador también puede transferir los archivos de flujo a otros procesadores mediante conexiones. El desarrollador puede seleccionarlo y también equilibrar la carga, pero el equilibrio de carga se acaba de lanzar en la versión 1.8, que no se tratará en este tutorial.

Como puede ver en la imagen de arriba la conexión marcada en rojo tiene relación de falla, lo que significa que todos los archivos de flujo con errores irán al procesador de la izquierda y respectivamente todos los archivos de flujo sin errores serán transferidos a la conexión marcada en verde.

Procedamos ahora con las otras relaciones.

falla de comunicación

Esta relación se cumple cuando no se pudo recuperar un Flowfile del servidor remoto debido a una falla en las comunicaciones.

extraviado

Cualquier Flowfile para el que recibamos un mensaje 'No encontrado' del servidor remoto se moverá a not.found relación.

Permiso denegado

Cuando NiFi no puede obtener un archivo de flujo del servidor remoto debido a un permiso insuficiente, pasará por esta relación.