PutElasticsearchJson 2025.5.31.15¶
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 |
|---|---|
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. |
el-rest-client-service |
Um serviço de cliente do Elasticsearch a ser usado para executar consultas. |
el-rest-fetch-index |
O nome do índice a ser usado. |
el-rest-type |
O tipo desse documento (usado pelo Elasticsearch para indexação e pesquisa). |
put-es-json-charset |
Especifica o conjunto de caracteres dos dados do documento. |
put-es-json-dynamic_templates |
Os dynamic_templates do documento. Deve ser analisável como um objeto JSON. Requer Elasticsearch 7 ou posterior |
put-es-json-id-attr |
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. |
put-es-json-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 |
put-es-json-scripted-upsert |
Se o sinalizador scripted_upsert deve ser adicionado à 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 FlowFile) estiver vazio, certifique-se de definir Suppress Null/Empty Values (Suprimir valores nulos/vazios) do serviço de controlador do serviço cliente como Never Suppress (Nunca suprimir) 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 em um erro “not_found” (não encontrado) |
put-es-not_found-is-error |
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. |
put-es-output-error-responses |
Se isso estiver ativado, as mensagens de resposta do Elasticsearch marcadas como “error” serão enviadas à relação “error_responses”, o que não afeta a saída dos FlowFiles para as relações “successful” ou “errors” |
put-es-record-batch-size |
O número preferencial de FlowFiles a ser enviado em um único lote |
put-es-record-index-op |
O tipo da operação usada para indexar (criar, excluir, indexar, atualizar, inserir) |
put-es-record-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. |
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. |