UpdateByQueryElasticsearch 2025.5.31.15¶

捆绑包¶

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

描述¶

使用查询更新 Elasticsearch 索引中的文档。可以从 FlowFile 正文或 Query 参数加载查询。加载的查询语句可以包含 Elasticsearch 的 _update_by_query API 所接受的任意 JSON，例如用于指定要更新哪些文档的“query”对象，以及定义更新操作的“script”。

标签¶

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

输入要求¶

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-script	JSON 语法上要在操作期间执行的“script”。例如：{"source": "ctx._source.count++", "lang": "painless"}
el-rest-type	此文档的类型（由 Elasticsearch 用于建立索引和执行搜索）。

关系¶

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

写入属性¶

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