GetElasticsearch 2025.5.31.15

捆绑包

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

描述

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

标签

elasticsearch、elasticsearch5、elasticsearch6、elasticsearch7、elasticsearch8、index、json、put、record

输入要求

ALLOWED

支持敏感的动态属性

false

属性

属性

描述

el-rest-client-service

用于运行查询的 Elasticsearch 客户端服务。

el-rest-fetch-index

要使用的索引的名称。

el-rest-type

此文档的类型(由 Elasticsearch 用于建立索引和执行搜索)。

get-es-attribute-name

用于检索到的文档输出的 FlowFile 属性的名称。

get-es-destination

指明检索到的文档是写入 FlowFile 内容还是写入 FlowFile 属性。

get-es-id

要检索的文档的 _id。

关系

名称

描述

document

提取到的文档将路由到此关系。

failure

所有因与服务器可用性无关的原因而失败的 FlowFile 都将转到此关系。

not_found

如果 Elasticsearch 集群中不存在指定文档,则会将一个 FlowFile 路由到此关系。

retry

所有因服务器/集群可用性而失败的 FlowFile 都将转到此关系。

写入属性

名称

描述

filename

filename 属性设置为文档标识符

elasticsearch.index

包含文档的 Elasticsearch 索引

elasticsearch.type

Elasticsearch 文档类型

elasticsearch.get.error

提取文档出现错误时由 Elasticsearch 提供的错误消息。

另请参阅

语言: 中文