PutElasticsearchRecord 2025.10.9.21¶

Pacote¶

org.apache.nifi | nifi-elasticsearch-restapi-nar

Descrição¶

Um processador Elasticsearch PUT com reconhecimento de registros que usa as bibliotecas de cliente Elastic REST oficiais. Cada registro no FlowFile é convertido em um documento a ser enviado à Elasticsearch _bulk APi. Vários documentos podem ser agrupados em cada solicitação enviada ao Elasticsearch. A operação em massa de cada documento pode ser configurada usando expressões de caminho de registro.

Tags¶

elasticsearch, elasticsearch7, elasticsearch8, elasticsearch9, index, json, put, record

Requisito de entrada¶

REQUIRED

Oferece suporte a propriedades dinâmicas confidenciais¶

falso

Propriedades¶

Propriedade	Descrição
Tamanho do lote	O número de registros a serem enviados em um único lote.
Client Service	Um serviço de cliente do Elasticsearch a ser usado para executar consultas.
Formato de data	Especifica o formato a ser usado ao gravar os campos de data. Se não for especificado, será usado o formato padrão “yyyyy-MM-dd”. Se especificado, o valor deve corresponder ao Java Simple Date Format (por exemplo, MM/dd/yyyyy para um mês de dois dígitos, seguido por um dia de dois dígitos, seguido por um ano de quatro dígitos, todos separados pelo caractere “/”, como em 25/01/2017).
Dynamic Templates Record Path	Um RecordPath apontando para um campo no(s) registro(s) que contém os dynamic_templates do documento. O campo deve ser compatível com o tipo Map (por exemplo, um Map ou Record) ou uma cadeia de caracteres analisável em um objeto JSON. Requer Elasticsearch 7 ou posterior
Agrupar resultados por tipo de erro em massa	The errored records written to the «errors» relationship will be grouped by error type and the error related to the first record within the FlowFile added to the FlowFile as «elasticsearch.bulk.error». If «Treat Not Found as Success» is «false» then records associated with «not_found» Elasticsearch document responses will also be send to the «errors» relationship.
Caminho de ID de registro	Uma expressão de caminho de registro para recuperar o campo ID para uso com o Elasticsearch. Se for deixado em branco, o ID será gerado automaticamente pelo Elasticsearch.
Í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)
Caminho do registro de operação de índice	Uma expressão de caminho de registro para recuperar o campo Operação de índice para uso com o Elasticsearch. Se for deixado em branco, a Operação de índice será determinada usando a propriedade principal Operação de índice.
Caminho do registro de índice	Uma expressão de caminho de registro para recuperar o campo de índice para uso com o Elasticsearch. Se for deixado em branco, o índice será determinado usando a propriedade de índice principal.
Log Error Responses	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.
Output Error Responses	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”.
Record Reader	O Record Reader a ser usado para ler os registros dos FlowFiles de entrada.
Result Record Writer	A resposta do Elasticsearch será examinada em busca de registros com falha e os registros com falha serão gravados em um conjunto de registros com esse serviço Record Writer e enviados à relação “errors”. Os registros bem-sucedidos serão gravados em um conjunto de registros com esse serviço Record Writer e enviados para a relação “bem-sucedido”.
Reter ID (caminho do registro)	Se o campo existente usado como o caminho de registro de ID deve ser mantido.
Retain Record Timestamp	Se o campo existente usado como @timestamp deve ser mantido no caminho do registro.
Script Record Path	Um RecordPath apontando para um campo no(s) registro(s) que contém o script para a atualização/upsert do documento. Aplica-se apenas a operações de atualização/upsert. O campo deve ser compatível com o tipo Map (por exemplo, um Map ou um Record) ou uma cadeia de caracteres analisável em um objeto JSON
Caminho do registro de upsert com script	A RecordPath pointing to a field in the record(s) that contains the scripted_upsert boolean flag. Whether to add the scripted_upsert flag to the Upsert Operation. Forces Elasticsearch to execute the Script whether or not the document exists, defaults to false. If the Upsert Document provided (from FlowFile content) will be empty, but sure to set the Client Service controller service’s Suppress Null and Empty Values to Never Suppress or no «upsert» doc will be, included in the request to Elasticsearch and the operation will not create a new document for the script to execute against, resulting in a «not_found» error
Formato de hora	Especifica o formato a ser usado ao gravar os campos de tempo. Se não for especificado, será usado o formato padrão “HH:mm:ss”. Se especificado, o valor deve corresponder ao Java Simple Date Format (por exemplo, HH:mm:ss para uma hora de dois dígitos no formato de 24 horas, seguida por um minuto de dois dígitos, seguido por um segundo de dois dígitos, todos separados pelo caractere “:”, como em 18:04:15).
Formato de carimbo de data/hora	Especifica o formato a ser usado ao gravar campos de carimbo de data/hora. Se não for especificado, será usado o formato padrão “yyyyy-MM-dd HH:mm:ss”. Se especificado, o valor deve corresponder ao Java Simple Date Format (por exemplo, MM/dd/yyyy HH:mm:ss para um mês de dois dígitos, seguido por um dia de dois dígitos, seguido por um ano de quatro dígitos, todos separados pelo caractere “/”; e depois seguido por uma hora de dois dígitos no formato de 24 horas, seguido por um minuto de dois dígitos, seguido por um segundo de dois dígitos, todos separados pelo caractere “:”, como em 01/25/2017 18:04:15).
Timestamp Record Path	Um RecordPath apontando para o(s) campo no(s) registro(s) com o @timestamp do documento. Se for deixado em branco, o @timestamp será determinado usando a propriedade @timestamp principal
Valor do carimbo de data/hora	O valor a ser usado como o campo @timestamp (obrigatório para Elasticsearch Data Streams)
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).
Type Record Path	Uma expressão de caminho de registro para recuperar o campo de tipo para uso com o Elasticsearch. Se for deixado em branco, o tipo será determinado usando a propriedade de tipo principal.

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 na análise dos registros de FlowFile, no envio dos documentos analisados ao Elasticsearch ou na análise da resposta do Elasticsearch.
elasticsearch.put.error.count	O número de registros que geraram erros na _bulk API do Elasticsearch.
elasticsearch.put.success.count	O número de registros processados com êxito pela _bulk API do Elasticsearch.
elasticsearch.bulk.error	A resposta _bulk se houver um erro durante o processamento do registro no Elasticsearch.

Consulte também¶

org.apache.nifi.processors.elasticsearch.PutElasticsearchJson