PutElasticsearchHttp
描述:
通过提供诸如索引插入和文档类型的参数将输入数据流的数据写入Elasticsearch
标签:
elasticsearch, insert, update, upsert, delete, write, put, 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地址 支持表达式语言 (仅支持变量) | ||
代理端口号 | 指定代理主机的端口号 支持表达式语言 (仅支持变量) | ||
代理用户名 | 指定代理服务的访问用户名 支持表达式语言 (仅支持变量) | ||
代理用户密码 | 指定代理服务的访问用户密码 敏感状态 支持表达式语言 (仅支持变量) | ||
属性标识符 | 每个数据流中包含标识符的属性名称。如果《索引操作》为"index",此属性可以保留为空或计算出空值,在这种情况下,文档的标识符将由ElasticSearch自动生成。 对于其他《索引操作》值,该属性必须为非空 | ||
索引 | 用于插入的索引名 支持表达式语言 (支持流属性和变量) | ||
类型 | 文档的可选类型(用于ES索引或搜索) 支持表达式语言 (支持流属性和变量) | ||
字符编码 | UTF-8 | 指定文档数据的字符集编码 支持表达式语言 (支持流属性和变量) | |
分批数量 | 100 | 在单个事务中写入数据库的最优输入数据流的数量。注意,在执行批量操作之前,数据流的内容将存储在内存中。同样,结果也会以接收数据流的相同顺序返回。 支持表达式语言 (仅支持变量) | |
索引操作 | index | 索引操作的类型 (index, update, upsert, delete) 支持表达式语言 (支持流属性和变量) |
动态参数:
名字 | 值 | 描述 |
---|---|---|
A URL query parameter | The value to set it to | 在用于处理的ElasticSearch URL中添加指定的属性名称/值作为查询参数 支持表达式语言 (仅支持变量) |
连线:
名字 | 描述 |
---|---|
retry | 如果无法写入文档,但再次尝试操作可能会成功的数据流输出到此连线 |
success | 成功写入Elasticsearch的数据将输出到此连线 |
failure | 所有不能写入Elasticsearch的数据将输出到此连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
资源 | 描述 |
---|---|
MEMORY | 此组件的实例可能导致此系统资源的高使用率。多个实例或高并发性设置可能导致性能下降。 |