Resultados de la búsqueda a petición "apache-nifi"
Cómo extraer un subconjunto de un archivo CSV usando NiFi
Tengo un archivo csv con más de 100 columnas y quiero extraer solo 60 columnas específicas como un subconjunto (ambos nombre de columna + su valor). Sé que podemos usar procesadores Extract Text. @ ¿Puede alguien decirme qué expresión regular ...
nifi ConvertRecord JSON a CSV obteniendo un solo registro?
Tengo el siguiente flujo configurado para leer datos json y convertirlos a csv usando el procesador convertRecord. Sin embargo, el archivo de flujo de salida essolo rellenado con un solo registro (Estoy asumiendo solo el primer registro) en ...
Convierta un archivo CSV a JSON usando Apache NiFi
Estoy tratando de leer un csv del sistema de archivos local y convertir el contenido al formato JSON usando Apache Nifi y poner el archivo de formato JSON en el sistema local. He logrado convertir la primera fila del archivo csv pero no otras ...
Consumidor de Kafka Avro con problemas de decodificador
Cuando intenté correrKafka Consumer con Avro [https://gist.github.com/yaroncon/97082e0b794d83fccf12]sobre los datos con mi esquema respectivo, devuelve un error de "AvroRuntimeException: datos con formato incorrecto. La longitud es negativa: ...
¿Cómo actualizar la línea con datos modificados en Jython?
Tengo un archivo csv que contiene cientos de miles de filas y debajo hay algunas líneas de muestra ... 1,Ni,23,28-02-2015 12:22:33.2212-02 2,Fi,21,28-02-2015 12:22:34.3212-02 3,Us,33,30-03-2015 12:23:35-01 4,Uk,34,31-03-2015 ...
Crear una tabla Postgresql desde Avro Schema en Nifi
Usando InferAvroSchema obtuve un Esquema Avro de mi archivo. Quiero crear una tabla en PostregSql usando este esquema Avro. Qué procesador tengo que usar. Yo uso: GetFile-> InferAvroSchema-> Quiero crear una tabla a partir de este esquema -> ...
Nifi: cómo escribir un procesador personalizado
Quiero escribirprocesador nifi que puede leer archivos xml del directorio hdfs y luego extraer sus datos en atributos de archivos de flujo, también si hay un caso en el que dos procesadores nifi pueden obtener este archivo y leer datos o escribir ...
El error de marca de hora / fecha y hora de Nifi PutSQL no se puede convertir.
Probé la solución sugerida para eliminar el error de conversión de formato de marca de tiempo usando el procesador "UpdateAttribute", es decir, ConvertJSONtoSQL-> UpdateAttribute -> PutSQL En UpdateAttribute utilicé Property Value ...
Importar módulos en Nifi ExecuteScript
Soy nuevo en Nifi y Python Quiero ejecutar mi script de Python. Entonces usé ExecuteScript e intenté importar ciertos módulos. He importado así: import json, sftp, paramikoAunque tengo instalado sftp, cuando lo importo en Executescript, dice ...
Diferencia entre Apache Beam y Apache Nifi
¿Cuáles son los casos de uso de Apache Beam y Apache Nifi? Parece que ambos son motores de flujo de datos. En caso de que ambos tengan un caso de uso similar, ¿cuál de los dos es mejor?
Página 1 de 2