Resultados da pesquisa a pedido "apache-nifi"
O Apache NIFI Jon não está finalizando automaticamente
Eu sou novo na ferramenta Apache NIFI. Estou tentando importar dados do mongo db e colocar esses dados no HDFS. Criei 2 processadores, um para o MongoDB e o segundo para o HDFS, e os configurei corretamente. O trabalho está sendo executado com ...
Consumidor Kafka Avro com problemas de decodificador
Quando tentei correrConsumidor Kafka com Avro [https://gist.github.com/yaroncon/97082e0b794d83fccf12]sobre os dados com meu esquema respectivo, ele retorna um erro de "AvroRuntimeException: dados malformados. O comprimento é negativo: -40". Vejo ...
Criar uma tabela do Postgresql a partir do Avro Schema no Nifi
Usando o InferAvroSchema, obtive um esquema do Avro do meu arquivo. Eu quero criar uma tabela no PostregSql usando este esquema do Avro. Qual processador eu tenho que usar. Eu uso: GetFile-> InferAvroSchema-> quero criar uma tabela a partir ...
Como chamar um serviço REST remoto no NiFi
É possível usar xmlHttpRequest no processador NIFI para chamar o serviço de descanso remoto? No meu caso, oExecuteScript processador (usando Javascript) não pode avaliarXMLHttpRequest; existe alguma solução semelhante que eu possa usar para obter ...
Diferença entre o Apache Beam e o Apache Nifi
Quais são os casos de uso do Apache Beam e Apache Nifi? Parece que ambos são mecanismos de fluxo de dados. Caso ambos tenham um caso de uso semelhante, qual dos dois é melhor?
PutSql - erro no formato da data
Estou tentando ler dados do 'Teradata' e preencher o mesmo no banco de dados 'Oracle'. Por favor, encontre abaixo do meu fluxo, 'ExecuteSQL' -> 'SplitAvro' -> 'ConvertAvroToJSON' -> 'ConvertJSONToSQL' -> 'PutSQL' Mensagem de erro: Não é ...
Nifi: como escrever processador personalizado
eu quero escreverprocessador nifi que pode ler o arquivo xml do diretório hdfs e, em seguida, extrair seus dados em atributos de arquivo de fluxo, também se houver um caso em que dois processadores nifi possam obter esse arquivo e ler dados ou ...
Como alguém configura um cache de mapa distribuído para NiFi?
Sou novato no NiFi e estou simplesmente brincando com os processadores. Estou tentando incorporarWait eNotify processadores em meus testes, mas tenho que configurar um Cache de Mapa Distribuído (servidorecliente?). A documentação do NiFi assume ...
Módulos de importação no Nifi ExecuteScript
Eu sou novo no Nifi e python Eu quero executar meu script python. Então, usei o ExecuteScript e tentei importar certos módulos. Eu importei assim: import json, sftp, paramikoEmbora eu tenha o sftp instalado, quando o importo no Executescript, ...
nifi ConvertRecord JSON para CSV recebendo apenas um único registro?
Eu tenho o fluxo abaixo configurado para ler dados json e convertê-lo em csv usando o processador convertRecord. No entanto, o arquivo de fluxo de saída é preenchido apenas com um único registro(Estou assumindo apenas o primeiro registro) em vez ...
Página 1 do 2