JsonQueryElasticsearch

描述:

一种允许用户运行用Elasticsearch JSON DSL编写的查询(带有聚合)的处理器。它不会自动为用户分页查询。如果将传入关系添加到此处理器,它将使用流文件的内容进行查询。应注意查询的大小,因为来自Elasticsearch的整个响应将立即全部加载到内存中并转换为结果流文件。

额外细节...

标签:

elasticsearch,elasticsearch 5,查询,读取,获取,json

特性:

在下面的列表中,必需属性的名称以粗体显示。其他任何属性(非粗体)均视为可选属性。该表还指示所有默认值,以及属性是否支持NiFi表达式语言

姓名默认值允许值描述
询问使用JSON语法而不是Lucene语法的查询。例如:{“ query”:{“ match”:{“ somefield”:“ somevalue”}}}。如果未设置此参数,将从流文件内容中读取查询。
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
查询属性如果设置,将在指定属性中的每个结果流文件上设置执行的查询。
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
指数要使用的索引名称。
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
类型该文档的类型(由Elasticsearch用于索引和搜索)。
支持表达式语言:true(将使用流文件属性和变量注册表进行评估)
客户服务控制器服务API:
ElasticSearchClientService
实施: ElasticSearchClientServiceImpl
用于运行查询的Elasticsearch客户端服务。
拆分搜索结果splitUp-no
  • Don't split up results.
  • 是的Split up results.
将搜索结果分成每个结果一个流文件。
拆分汇总结果splitUp-no
  • Don't split up results.
  • 是的Split up results.
将聚合结果拆分为每个结果一个流文件。

关系:

姓名描述
聚集体聚集被路由到该关系。
失败 由于与服务器可用性无关的原因而失败的所有流文件都将变为这种关系。
原版的所有不会引起错误发生的原始流文件都将变为这种关系。即使您选择“拆分匹配”选项将单个匹配发送到“匹配”关系,这也适用。
命中搜索命中将路由到此关系。

读取属性:

未指定。

写入属性:

姓名描述
模仿型应用程序/ json
聚合名称聚合的名称,其结果在输出流文件中

状态管理:

该组件不存储状态。

受限制的:

此组件不受限制。

输入要求:

该组件允许传入的关系。

系统资源注意事项:

未指定。