GetElasticsearch 2025.10.9.21¶

捆绑包¶

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

Elasticsearch get 处理器，它使用官方 Elastic REST 客户端库，通过 _id 从 Elasticsearch 提取单个文档。请注意，文档的完整主体将在写入 FlowFile 进行传输之前被读入内存。

elasticsearch, elasticsearch7, elasticsearch8, elasticsearch9, index, json, put, record

ALLOWED

false

属性	描述
Attribute Name	用于检索到的文档输出的 FlowFile 属性的名称。
Client Service	用于运行查询的 Elasticsearch 客户端服务。
Destination	指明检索到的文档是写入 FlowFile 内容还是写入 FlowFile 属性。
Document Id	要检索的文档的 _id。
Index	要使用的索引的名称。
Type	此文档的类型（由 Elasticsearch 用于建立索引和执行搜索）。

名称	描述
document	提取到的文档将路由到此关系。
failure	所有因与服务器可用性无关的原因而失败的 FlowFile 都将转到此关系。
not_found	如果 Elasticsearch 集群中不存在指定文档，则会将一个 FlowFile 路由到此关系。
retry	所有因服务器/集群可用性而失败的 FlowFile 都将转到此关系。

名称	描述
filename	filename 属性设置为文档标识符
elasticsearch.index	包含文档的 Elasticsearch 索引
elasticsearch.type	Elasticsearch 文档类型
elasticsearch.get.error	提取文档出现错误时由 Elasticsearch 提供的错误消息。