PutElasticsearchHttpRecord
描述:
通过提供诸如索引插入和文档类型的参数，以及操作类型将输入数据流的记录内容写入到Elasticsearch。注意：该组件采用Bulk API来发送数据，也就是说，输入数据流的全部内容将被读取到内存中，并将每个记录转换为一个JSON文档，并将JSON文档添加到单个HTTP请求体中。因此对于非常大的输入数据流（例如，具有大量记录），这可能会导致内存性能使用问题。
标签:
elasticsearch, insert, update, upsert, delete, write, put, http, record, 插入, 更新, 删除, 写入, 记录
参数:
如下列表中，必填参数则标识为加粗. 其他未加粗参数，则表示为可选参数。表中同时提到参数默认值设置, 参数还支持 表达式语言, 并且 如果将一个参数认定为"敏感", 表示是加密状态. 在输入一个敏感参数时, 确保 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地址 支持表达式语言 (仅支持变量) | ||
| 代理端口号 | 指定代理主机的端口号 支持表达式语言 (仅支持变量) | ||
| 代理用户名 | 指定代理服务的访问用户名 支持表达式语言 (仅支持变量) | ||
| 代理用户密码 | 指定代理服务的访问用户密码 敏感状态 支持表达式语言 (仅支持变量) | ||
| 记录读取服务 | 控制器服务API: RecordReaderFactory 实现: ParquetReader GrokReader SyslogReader Syslog5424Reader CSVReader AvroReader JsonPathReader JsonTreeReader ScriptedReader XMLReader | 指定用于解析输入数据和决定数据Schema信息的记录读取服务 | |
| 文档标识符的记录路径 | 指定文档标识符在记录中的字段路径表达式，如果《索引操作》为"index"， 该值可置空或表达式计算值为空，则Elasticsearch将自动生成文档标识符。对于其他索引操作的值，则不允许为空值。 支持表达式语言 (支持流属性和变量) | ||
| 索引 | 用于插入的索引名 支持表达式语言 (支持流属性和变量) | ||
| 类型 | 文档的可选类型（用于ES索引或搜索） 支持表达式语言 (支持流属性和变量) | ||
| 索引操作 | index | 索引操作的类型 (index, update, upsert, delete) 支持表达式语言 (支持流属性和变量) | |
| 空值处理 | 始终输出 | - 始终输出  - 始终忽略 - 建议输出 | 决定应该如何处理null字段 |
动态参数:
| 名字 | 值 | 描述 |
|---|---|---|
| A URL query parameter | The value to set it to | 在用于处理的ElasticSearch URL中添加指定的属性名称/值作为查询参数 支持表达式语言 (仅支持变量) |
连线:
| 名字 | 描述 |
|---|---|
| retry | 如果无法更新，但再次尝试操作可能会成功的数据流输出到此连线 |
| success | 成功写入Elasticsearch的数据将输出到此连线 |
| failure | 所有不能写入Elasticsearch的数据将输出到此连线 |
读取属性:
未提供。
写入属性:
未提供。
状态管理:
该组件不保存状态。
限制:
该组件没有限制
输入流要求:
组件必须提供输入流。
系统资源考量:
未提供。