Apache NiFi - Categorización de procesadores
En este capítulo, discutiremos la categorización de procesos en Apache NiFi.
Procesadores de ingestión de datos
Los procesadores de la categoría Ingestión de datos se utilizan para ingerir datos en el flujo de datos de NiFi. Estos son principalmente el punto de partida de cualquier flujo de datos en Apache NiFi. Algunos de los procesadores que pertenecen a estas categorías son GetFile, GetHTTP, GetFTP, GetKAFKA, etc.
Procesadores de enrutamiento y mediación
Los procesadores de enrutamiento y mediación se utilizan para enrutar los archivos de flujo a diferentes procesadores o flujos de datos de acuerdo con la información en los atributos o el contenido de esos archivos de flujo. Estos procesadores también son responsables de controlar los flujos de datos de NiFi. Algunos de los procesadores que pertenecen a esta categoría son RouteOnAttribute, RouteOnContent, ControlRate, RouteText, etc.
Procesadores de acceso a bases de datos
Los procesadores de esta categoría de acceso a la base de datos son capaces de seleccionar o insertar datos o ejecutar y preparar otras declaraciones SQL de la base de datos. Estos procesadores utilizan principalmente la configuración del controlador del grupo de conexiones de datos de Apache NiFi. Algunos de los procesadores que pertenecen a esta categoría son ExecuteSQL, PutSQL, PutDatabaseRecord, ListDatabaseTables, etc.
Procesadores de extracción de atributos
Los procesadores de extracción de atributos son responsables de extraer, analizar y cambiar el procesamiento de los atributos del archivo de flujo en el flujo de datos de NiFi. Algunos de los procesadores que pertenecen a esta categoría son UpdateAttribute, EvaluateJSONPath, ExtractText, AttributesToJSON, etc.
Procesadores de interacción del sistema
Los procesadores de interacción del sistema se utilizan para ejecutar procesos o comandos en cualquier sistema operativo. Estos procesadores también ejecutan scripts en muchos idiomas para interactuar con una variedad de sistemas. Algunos de los procesadores que pertenecen a esta categoría son ExecuteScript, ExecuteProcess, ExecuteGroovyScript, ExecuteStreamCommand, etc.
Procesadores de transformación de datos
Los procesadores que pertenecen a Data Transformation son capaces de alterar el contenido de los archivos de flujo. Estos pueden usarse para reemplazar completamente los datos de un archivo de flujo que normalmente se usa cuando un usuario tiene que enviar un archivo de flujo como un cuerpo HTTP para invocar el procesador HTTP. Algunos de los procesadores que pertenecen a esta categoría son ReplaceText, JoltTransformJSON, etc.
Envío de procesadores de datos
Los procesadores de datos de envío son generalmente el procesador final en un flujo de datos. Estos procesadores son responsables de almacenar o enviar datos al servidor de destino. Después de almacenar o enviar con éxito los datos, estos procesadores DEJAN el archivo de flujo con la relación de éxito. Algunos de los procesadores que pertenecen a esta categoría son PutEmail, PutKafka, PutSFTP, PutFile, PutFTP, etc.
Procesadores de división y agregación
Estos procesadores se utilizan para dividir y fusionar el contenido presente en un archivo de flujo. Algunos de los procesadores que pertenecen a esta categoría son SplitText, SplitJson, SplitXml, MergeContent, SplitContent, etc.
Procesadores HTTP
Estos procesadores se ocupan de las llamadas HTTP y HTTPS. Algunos de los procesadores que pertenecen a esta categoría son InvokeHTTP, PostHTTP, ListenHTTP, etc.
Procesadores AWS
Los procesadores de AWS son responsables de la interacción con el sistema de servicios web de Amazon. Algunos de los procesadores que pertenecen a esta categoría son GetSQS, PutSNS, PutS3Object, FetchS3Object, etc.