PutElasticsearchJson 2025.10.9.21¶
Pacote¶
org.apache.nifi | nifi-elasticsearch-restapi-nar
Descrição¶
Um processador Elasticsearch PUT que usa as bibliotecas de cliente Elastic REST oficiais. Cada FlowFile é tratado como um documento a ser enviado à _bulk API do Elasticsearch. Vários FlowFiles podem ser agrupados em lotes em cada solicitação enviada ao Elasticsearch.
Requisito de entrada¶
REQUIRED
Oferece suporte a propriedades dinâmicas confidenciais¶
falso
Propriedades¶
Propriedade |
Descrição |
|---|---|
Tamanho do lote |
O número preferencial de FlowFiles a ser enviado em um único lote |
Conjunto de caracteres |
Especifica o conjunto de caracteres dos dados do documento. |
Serviço de cliente |
Um serviço de cliente do Elasticsearch a ser usado para executar consultas. |
Modelos dinâmicos |
Os dynamic_templates do documento. Deve ser analisável como um objeto JSON. Requer Elasticsearch 7 ou posterior |
Atributo do identificador |
O nome do atributo do FlowFile que contém o identificador do documento. Se a operação de índice for “index”, essa propriedade poderá ser deixada em branco ou avaliada como um valor vazio; nesse caso, o identificador do documento será gerado automaticamente pelo Elasticsearch. Para todas as outras operações de índice, o atributo deve ser avaliado como um valor não vazio. |
Índice |
O nome do índice a ser usado. |
Operação de índice |
O tipo da operação usada para indexar (criar, excluir, indexar, atualizar, inserir) |
Registrar respostas de erro em log |
Se essa opção estiver ativada, os erros serão registrados nos logs do NiFi no nível de log de erros. Caso contrário, eles só serão registrados se o registro de depuração estiver ativado no NiFi como um todo. O objetivo dessa opção é fornecer ao usuário a capacidade de depurar operações com falha sem ter que ativar o registro de depuração. |
Comprimento máximo da cadeia de caracteres do campo JSON |
O comprimento máximo permitido de um valor de cadeia de caracteres ao analisar um documento ou atributo JSON. |
Enviar respostas de erro |
Se estiver habilitada, as mensagens de resposta do Elasticsearch marcadas como “error” serão enviadas para o relacionamento “error_responses”. Isto não afeta a saída de arquivos de fluxo para os relacionamentos “successful” ou “errors”. |
Script |
O script para atualização/upsert do documento. Aplica-se apenas a operações de atualização/upsert. Deve ser analisável como objeto JSON. Se for deixado em branco, o conteúdo do FlowFile será usado para atualização/upsert do documento |
Upsert com script |
Se é para adicionar o sinalizador scripted_upsert à operação upsert. Se verdadeiro, força o Elasticsearch a executar o script, independentemente de o documento existir ou não. O padrão é falso. Se o documento upsert fornecido (do conteúdo de FlowFile) ficará vazio, mas certifique-se de definir Suppress Null and Empty Values do controlador do serviço de cliente como Never Suppress, ou nenhum documento «upsert» será incluído na solicitação ao Elasticsearch e a operação não criará um novo documento para o script executar, resultando no erro «not_found» |
Tratar não encontrado como sucesso |
Se verdadeiro, os registros associados ao documento Elasticsearch “not_found” serão encaminhados para a relação “successful”; caso contrário, serão encaminhados para a relação “errors”. Se Output Error Responses for “true”, as respostas “not_found” do Elasticsearch serão enviadas à relação error_responses. |
Tipo |
O tipo desse documento (usado pelo Elasticsearch para indexação e pesquisa). |
Relações¶
Nome |
Descrição |
|---|---|
errors |
O(s) registro(s)/FlowFile(s) correspondente(s) ao(s) documento(s) Elasticsearch que resultou(am) em um “erro” (no Elasticsearch) será(ão) encaminhado(s) para cá. |
failure |
Todos os FlowFiles que falham por motivos não relacionados à disponibilidade do servidor vão para essa relação. |
original |
Todos os FlowFiles enviados ao Elasticsearch sem falhas de solicitação vão para essa relação. |
retry |
Todos os FlowFiles que falham devido à disponibilidade do servidor/cluster vão para essa relação. |
successful |
O(s) registro(s)/FlowFile(s) correspondente(s) ao(s) documento(s) Elasticsearch que não resultou(ram) em “erro” (no Elasticsearch) será(ão) encaminhado(s) para cá. |
Grava atributos¶
Nome |
Descrição |
|---|---|
elasticsearch.put.error |
A mensagem de erro se houver um problema ao analisar o FlowFile, ao enviar o documento analisado ao Elasticsearch ou analisar a resposta do Elasticsearch |
elasticsearch.bulk.error |
A resposta _bulk se houver um erro durante o processamento do documento Elasticsearch. |