PutElasticsearch5
描述:
通过指定一定的参数将输入数据流的内容写入到Elasticsearch中, 比如文档的索引和类型。如果集群配置为安全连接(SSL/TLS)且X-Pack可用，则将创建安全连接。该组件支持Elasticsearch 5.x集群
标签:
elasticsearch, elasticsearch 5, insert, update, write, put, 更新, 插入, 写入
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 orchsym.properties 文件中存在属性设置 orchsym.sensitive.props.key.
| 名字 | 默认值 | 允许值列表 | 描述 |
|---|---|---|---|
| 集群名字 | elasticsearch | ES集群的名字 (比如 elasticsearch_brew).默认为'elasticsearch' 支持表达式语言 (仅支持变量) | |
| 主机列表 | ES主机列表，且通过英文逗号分隔多个，主机和端口直接用冒号分隔 host1:port,host2:port,.... 比如：testcluster:9300. 该组件使用客户端来连接主机，且默认端口为9300 支持表达式语言 (仅支持变量) | ||
| SSL服务 | 控制器服务API: SSLContextService 实现: StandardRestrictedSSLContextService StandardSSLContextService | 用于提供客户端TLS/SSL连接的证书信息服务。 仅当ElasticSearch节点已使用TLS/SSL进行安全保护时，此服务才适用 | |
| X-Pack插件路径 | 指定Elasticsearch X-Pack的插件jar包路径，如果ES集群已经使用了X-Pack插件来作为安全连接，则必须提供X-Pack插件jar包。 注意：千万不要将X-Pack的jar包直接放到产品的lib目录里，这样做将会阻止加载X-Pack的jar包 支持表达式语言 (仅支持变量) | ||
| 用户名 | 指定访问ES集群的用户名 支持表达式语言 (仅支持变量) | ||
| 密码 | 指定访问ES集群的用户密码 敏感状态 | ||
| Ping超时 | 5s | 用于确定何时无法访问节点的Ping超时。 比如, 5s (5秒)。 如果非本地，建议30s 支持表达式语言 (仅支持变量) | |
| 取样间隔 | 5s | 对列出和连接的节点进行采样或ping的频率。 比如, 5s (5秒)。 如果非本地，建议30s 支持表达式语言 (仅支持变量) | |
| 属性标识符 | 每个数据流中包含标识符的属性名称 | ||
| 索引 | 要插入的索引的名称 支持表达式语言 (支持流属性和变量) | ||
| 类型 | 文档类型 (ES用于索引和搜索) 支持表达式语言 (支持流属性和变量) | ||
| 字符编码 | UTF-8 | 指定文档数据的字符集编码 支持表达式语言 (支持流属性和变量) | |
| 分批数量 | 100 | 在单个事务中写入数据库的最优输入数据流的数量 支持表达式语言 (仅支持变量) | |
| 索引操作 | index | 索引操作的类型 (index, update, upsert) 支持表达式语言 (支持流属性和变量) |
连线:
| 名字 | 描述 |
|---|---|
| retry | 如果无法写入文档，但再次尝试操作可能会成功的数据流输出到此连线 |
| success | 成功写入Elasticsearch的数据将输出到此连线 |
| failure | 所有不能写入Elasticsearch的数据将输出到此连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
| 资源 | 描述 |
|---|---|
| MEMORY | 此组件的实例可能导致此系统资源的高使用率。多个实例或高并发性设置可能导致性能下降。 |