DeleteByQueryElasticsearch 2025.10.2.19¶

捆绑包¶

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

描述¶

使用查询从 Elasticsearch 索引中删除。可以从 FlowFile 正文或 Query 参数加载查询。

标签¶

delete, elastic, elasticsearch, elasticsearch7, elasticsearch8, elasticsearch9, query

输入要求¶

ALLOWED

支持敏感的动态属性¶

false

属性¶

属性	描述
最大 JSON 字段字符串长度	解析 JSON 文档或属性时字符串值的最大允许长度。
el-query-attribute	如果设置此参数，系统将在每个结果 FlowFile 的指定属性中记录所执行的查询。
el-rest-client-service	用于运行查询的 Elasticsearch 客户端服务。
el-rest-fetch-index	要使用的索引的名称。
el-rest-query	JSON 语法（而非 Lucene 语法）中的查询。例如：{"query":{"match":{"somefield":"somevalue"}}}。如果未设置此参数，则将从 FlowFile 内容中读取查询。如果查询（属性和 FlowFile 内容）为空，则将使用默认的空 JSON 对象，这将导致 Elasticsearch 中出现“match_all”查询。
el-rest-query-clause	JSON 语法（而非 Lucene 语法）中的“query”子句。例如：{"match":{"somefield":"somevalue"}}。如果查询为空，则将使用默认 JSON 对象，这将导致 Elasticsearch 中出现“match_all”查询。
el-rest-query-definition-style	如何定义 JSON 查询以供处理器使用。
el-rest-type	此文档的类型（由 Elasticsearch 用于建立索引和执行搜索）。

关系¶

名称	描述
failure	如果“by query”操作失败并且读取了 FlowFile，则会将其发送到此关系。
retry	所有因服务器/集群可用性而失败的 FlowFile 都将转到此关系。
success	如果“by query”操作成功并且读取了 FlowFile，则会将其发送到此关系。

写入属性¶

名称	描述
elasticsearch.delete.took	完成删除操作所花费的时间，以毫秒为单位。
elasticsearch.delete.error	运行删除操作出现错误时由 Elasticsearch 提供的错误消息。