Resultados da pesquisa a pedido "apache-nifi"
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 ...
Converta um arquivo CSV em JSON usando o Apache NiFi
Estou tentando ler um csv do sistema de arquivos local e converter o conteúdo no formato JSON usando o Apache Nifi e colocar o arquivo no formato JSON no sistema local. Consegui converter a primeira linha do arquivo csv, mas não outras. o ...
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, ...
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 é ...
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?
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 ...
Como atualizar a linha com dados modificados no Jython?
Eu tenho um arquivo csv que contém centenas de milhares de linhas e abaixo estão algumas linhas de exemplo .., 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 ...
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 ...
Erro Nifi PutSQL Timestamp / Datetime não pode ser convertido
Tentei a solução sugerida para remover o erro de conversão do formato do carimbo de data / hora usando o processador "UpdateAttribute", ou seja, ConvertJSONtoSQL-> UpdateAttribute -> PutSQL No UpdateAttribute eu usei Property Value ...
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 ...
Página 1 do 2