第 22 章 Elasticsearch Index Sink
将 JSON 格式的数据存储在 ElasticSearch 中。
输入数据必须以 JSON 格式格式化,具体取决于索引的要求。
如果指定了 certificate 属性,则必须将其 base64 编码,然后才能将其作为参数传递。
在标头中,您可以设置以下属性:
-
indexId/ce-indexid: ElasticSearch 的索引 ID。 -
indexName/ce-indexname: ElasticSearch 的索引名称。
如果您没有在标头中设置属性,则 Kamelet 将交换 ID 用于索引设置。
22.1. 配置选项 复制链接链接已复制到粘贴板!
下表总结了 elasticsearch-index-sink Kamelet 可用的选项:
| 属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
|---|---|---|---|---|---|
| clusterName * | Elasticsearch 集群名称 | ElasticSearch 集群的名称。 | 字符串 | quickstart | |
| hostAddresses * | 主机地址 |
以逗号分隔的远程传输地址列表, | 字符串 | quickstart-es-http:9200 | |
| certificate | 证书 | 用于访问 Elasticsearch 集群的证书。您必须使用 base64 对这个值进行编码。 | 字符串 | ||
| enableSSL | 启用 SSL | 指定使用 SSL 进行连接。 | 布尔值 | True | |
| indexName | ElasticSearch 中的索引 | ElasticSearch 索引的名称。 | 字符串 | data | |
| password | 密码 | 要连接到 ElasticSearch 的密码。 | 字符串 | ||
| user | 用户名 | 要连接到 ElasticSearch 的用户名。 | 字符串 |
* = 标记为星号的字段 是必需的。