GetElasticsearch 2025.10.2.19¶
捆绑包¶
org.apache.nifi | nifi-elasticsearch-restapi-nar
描述¶
Elasticsearch get 处理器，它使用官方 Elastic REST 客户端库，通过 _id 从 Elasticsearch 提取单个文档。请注意，文档的完整主体将在写入 FlowFile 进行传输之前被读入内存。
输入要求¶
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 提供的错误消息。 |