FetchElasticsearchHttp
描述:
通过指定参数和文档标识从Elasticsearch中读取文档。注意文档的全部内容将被读取到内存中,然后再输出到数据流中
标签:
elasticsearch, fetch, 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地址 支持表达式语言 (仅支持变量) | ||
代理端口号 | 指定代理主机的端口号 支持表达式语言 (仅支持变量) | ||
代理用户名 | 指定代理服务的访问用户名 支持表达式语言 (仅支持变量) | ||
代理用户密码 | 指定代理服务的访问用户密码 敏感状态 支持表达式语言 (仅支持变量) | ||
文档标识 | 用于读取文档的标识符 支持表达式语言 (支持流属性和变量) | ||
索引 | 用于读取的索引名 支持表达式语言 (支持流属性和变量) | ||
类型 | 文档的可选类型(用于ES索引或搜索)。如果为空,则将检索所有类型中与标识符匹配的第一个文档。 支持表达式语言 (支持流属性和变量) | ||
字段列表 | 从文档中读取的逗号分隔的字段列表。如果列表置空,则将检索整个文档。 支持表达式语言 (支持流属性和变量) |
动态参数:
名字 | 值 | 描述 |
---|---|---|
A URL query parameter | The value to set it to | 在用于处理的ElasticSearch URL中添加指定的属性名称/值作为查询参数 支持表达式语言 (仅支持变量) |
连线:
名字 | 描述 |
---|---|
retry | 如果无法获取文档,但再次尝试操作可能会成功的数据流输出到此连线。注意如果组件没有输入连线,仍然可以根据组件属性和提取操作的结果输出到此连线。 |
success | 成功从Elasticsearch中读取的数据将输出到此连线 |
failure | 所有不能从Elasticsearch中读取数据将输出到此连线。注意只有有输入连线时才会有失败连线 |
not found | 如果文档不存在于Elasticsearch集群中将路由到此连线。注意如果没有输入连线,仍然可以根据组件属性和提取操作的结果输出到此连线。 |
读取属性:
未提供。
写入属性:
名字 | 描述 |
---|---|
filename | 文件名属性设置为文档标识符 |
es.index | 包含文档的索引 |
es.type | 文档类型 |
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件允许提供输入流。
系统资源考量:
未提供。