QueryElasticsearchHttp
描述:
通过设置特殊的连接参数来查询Elasticsearch。注意，每页文档的所有内容将被读取到内存中，然后输出。 还需注意，ElasticSearch的 max_result_window 索引设置将限制此查询检索记录的上限。 想要查询更多记录，可使用ScrollElasticsearchHttp组件
标签:
elasticsearch, query, read, get, http
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| URL | 用于连接的ES URL，包含 scheme (http等), 主机和端口号. REST API的默认端口号为9200 支持表达式语言 (仅支持变量) | ||
| SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 用于提供客户端TLS/SSL连接的证书信息服务。 仅当ElasticSearch节点已使用TLS/SSL进行安全保护时，此服务才适用 | |
| 用户名 | 用于访问ES集群的用户名 支持表达式语言 (仅支持变量) | ||
| 密码 | 用于访问ES集群的用户密码 敏感状态 支持表达式语言 (仅支持变量) | ||
| 连接超时 | 5 secs | ES的REST API连接的最大等待时间 支持表达式语言 (仅支持变量) | |
| 响应超时 | 15 secs | ES的REST API响应的最大等待时间 支持表达式语言 (仅支持变量) | |
| 代理配置 | 控制器服务API: ProxyConfigurationService 实现: StandardProxyConfigurationService | 指定网路请求的代理配置服务。如果设置，它将影响每个组件配置的代理设置。 支持代理： SOCKS, HTTP + AuthN | |
| 代理主机 | 指定代理主机的名字或IP地址 支持表达式语言 (仅支持变量) | ||
| 代理端口号 | 指定代理主机的端口号 支持表达式语言 (仅支持变量) | ||
| 代理用户名 | 指定代理服务的访问用户名 支持表达式语言 (仅支持变量) | ||
| 代理用户密码 | 指定代理服务的访问用户密码 敏感状态 支持表达式语言 (仅支持变量) | ||
| 查询语句 | 指定在ElasticSearch中执行的Lucene风格的查询语句(比如： genre:blues AND -artist:muddy) 支持表达式语言 (支持流属性和变量) | ||
| 页面大小 | 20 | 指定每页返回多少文档 支持表达式语言 (支持流属性和变量) | |
| 索引名 | 用于读取的索引名。如果设置为“_all”，则查询将匹配所有的索引 支持表达式语言 (支持流属性和变量) | ||
| 类型 | 查询语句类型（可选），用于Elasticsearch检索和查询。如果置空，则查询将匹配所有类型 支持表达式语言 (支持流属性和变量) | ||
| 字段列表 | 指定要从文档中读取且由逗号分隔字段列表。如果置空，则整个文档将被读取 支持表达式语言 (支持流属性和变量) | ||
| 排序 | 排序参数 (比如, timestamp:asc). 如果置空，则按默认文档顺序 支持表达式语言 (支持流属性和变量) | ||
| 限量 | 如果设置，则限制输出结果的数量 支持表达式语言 (支持流属性和变量) | ||
| 输出方式 | 数据流内容 | - 数据流内容 - 数据流属性 | 指定结果输出方式。如果为“数据流内容”，则将JSON响应的结果输出到数据流中。如果为“数据流属性”，则针对每个结果输出原始输入数据流，且每个文档的字段将作为数据流属性，并以'es.result.'作为前缀 |
| 路由策略 | 从不 | - 始终  - 从不 - 不命中 | 指定成功查询后生成和路由查询信息的策略 |
动态参数:
| 名字 | 值 | 描述 |
|---|---|---|
| A URL query parameter | The value to set it to | 在用于处理的ElasticSearch URL中添加指定的属性名称/值作为查询参数 支持表达式语言 (仅支持变量) |
连线:
| 名字 | 描述 |
|---|---|
| retry | 如果无法获取文档，但再次尝试操作可能会成功的数据流输出到此连线.注意，如果没有输入连线，输出数据流可能基于组件属性和查询结果而输出 |
| success | 成功从Elasticsearch查询的数据将输出到此连线 |
| failure | 所有不能成功Elasticsearch查询的数据将输出到此连线。注意，仅支持有输入数据流在失败时才会路由到此连线 |
读取属性:
未提供。
写入属性:
| 名字 | 描述 |
|---|---|
| filename | 文档标识的文件名属性 |
| es.query.hitcount | 查询命中数 |
| es.id | 文档标识符 |
| es.index | 包含文档的索引 |
| es.query.url | 查询语句 |
| es.type | 文档类型 |
| es.result.* | 如果《输出方式》为'数据流属性', 每个结果的JSON属性将被放置到以这个前缀的相应属性中 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件允许提供输入流。
系统资源考量:
未提供。