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. |
Client Service |
Um serviço de cliente do Elasticsearch a ser usado para executar consultas. |
Dynamic Templates |
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) |
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”. |
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 |
Scripted Upsert |
Whether to add the scripted_upsert flag to the Upsert Operation. If true, 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 |
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. |