DeleteByQueryElasticsearch 2025.5.31.15¶
Pacote¶
org.apache.nifi | nifi-elasticsearch-restapi-nar
Descrição¶
Exclua de um índice do Elasticsearch usando uma consulta. A consulta pode ser carregada de um corpo de FlowFile ou do parâmetro Query.
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-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.delete.took |
O tempo que levou para concluir a operação de exclusão em ms. |
elasticsearch.delete.error |
A mensagem de erro fornecida pelo Elasticsearch se houver um erro na execução da exclusão. |