UpdateByQueryElasticsearch 2025.5.31.15¶

Pacote¶

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

Descrição¶

Atualize documentos em um índice do Elasticsearch usando uma consulta. A consulta pode ser carregada de um corpo de FlowFile ou do parâmetro Query. A consulta carregada pode conter qualquer JSON aceito pela API _update_by_query do Elasticsearch; por exemplo, um objeto “query” para identificar quais documentos devem ser atualizados, além de um “script” para definir as atualizações a serem executadas.

Tags¶

elastic, elasticsearch, elasticsearch5, elasticsearch6, elasticsearch7, elasticsearch8, query, update

Requisito de entrada¶

ALLOWED

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-query-attribute	Se definido, a consulta executada será definida em cada FlowFile de resultado no atributo especificado.
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-query	Uma consulta na sintaxe JSON, não na sintaxe Lucene. Ex.: {«query»:{«match»:{«somefield»:»somevalue»}}}. Se esse parâmetro não for definido, a consulta será lida a partir do conteúdo do FlowFile. Se a consulta (propriedade e conteúdo do FlowFile) estiver vazia, será usado um objeto JSON vazio padrão, o que resultará em uma consulta “match_all” no Elasticsearch.
el-rest-query-clause	Uma cláusula de “query” na sintaxe JSON, não na sintaxe Lucene. Ex.: {«match»:{«somefield»:»somevalue»}}. Se a consulta estiver vazia, será usado um objeto JSON padrão, o que resultará em uma consulta “match_all” no Elasticsearch.
el-rest-query-definition-style	Como a consulta JSON será definida para uso pelo processador.
el-rest-script	Um “script” a ser executado durante a operação, na sintaxe JSON. Ex.: {«source»: «ctx._source.count++», «lang»: «painless»}
el-rest-type	O tipo desse documento (usado pelo Elasticsearch para indexação e pesquisa).

Relações¶

Nome	Descrição
failure	Se a operação “by query” falhar e um FlowFile tiver sido lido, ele será enviado para essa relação.
retry	Todos os FlowFiles que falham devido à disponibilidade do servidor/cluster vão para essa relação.
success	Se a operação “by query” for bem-sucedida e um FlowFile tiver sido lido, ele será enviado para essa relação.

Grava atributos¶

Nome	Descrição
elasticsearch.update.took	O tempo que levou para concluir a operação de atualização em ms.
elasticsearch.update.error	A mensagem de erro fornecida pelo Elasticsearch se houver um erro na execução da atualização.