DeleteByQueryElasticsearch 2025.5.31.15¶

捆绑包¶

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

描述¶

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

标签¶

delete、elastic、elasticsearch、elasticsearch5、elasticsearch6、elasticsearch7、elasticsearch8、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 提供的错误消息。