当前,各大云厂商均推出了Elasticsearch的云上托管服务,并通过提供运维管理、监控告警、日志查看等工具,方便用户进行集群的管理与维护。但在数据接入方面,腾讯云 Elasticsearch Service(ES)在实践中发现,用户仍需单独打通每一个组件的上下游,最终完成整个链路的创建,而数据链路涉及数据源配置、数据采集、数据缓存、数据加工、数据目的等复杂的流程,每一步都需要单独配置的情况下,用户接入以及运维的成本较高。
基于此,腾讯云ES推出了一站式的数据链路可视化接入服务,相对于传统的数据接入,数据接入可以大大的降低使用与维护成本,提高链路创建效率。数据接入提供了CVM与TKE、MySQL等数据源的接入,只需在界面上填写链路中相关组件的配置信息或者遵循相关指引,即可快速完成整个链路的创建。
使用介绍
进入新建页面
- 登录 ES 控制台,单击数据接入进入数据链路列表。
- 单击新建数据链路进入新建页面。
数据链路配置
填写基本信息
1.填写数据链路名称,将根据该名称自动生成数据链路ID。
2.选择地域,后续数据链路的相关组件与资源,都将来自该地域。
3.选择数据源,当前日志场景支持CVM与TKE等等数据源、指标场景支持CVM,后续将支持更多的数据源,其他数据同步配置如MySQL等可通过相关文档指引进行。
4.点击“开始创建”,将进入数据链路组件配置页面。
组件配置
1.建议数据链路各个组件在同一个VPC以保证网络互通,否则您需要自行打通网络连接。
2.通过选择数据链路模式,可切换该链路组件配置。
3.为了创建数据接入链路,通过助手下发配置时,要使用用户密钥,初次点击“新建数据链路”时,需要您授权创建服务相关角色,授权 “腾讯云Elasticsearch服务” 访问您的 "自动化助手服务”、“云服务器CVM”、“容器服务TKE”、”消息队列CKafka”,使用相关服务接口完成相应功能。
以下将通过CVM及TKE日志采集链路的配置进行相关说明。
CVM-Filebeat-CKafka-Logstash-ES
数据源
1.选择VPC。
2.选择CVM,仅支持Linux系统的CVM,且CVM必须安装自动化助手后才能采集数据。
数据采集
1.填写采集配置相关内容。
2.output信息将在提交时根据您填写的链路配置自动填充,请勿在此输入相关信息。
数据缓存
1.选择CKafka实例。
2.从Ckakfa实例已经路由打通的VPC中,选择跟当前链路组件有交集的VPC。
3.创建或者选择已有Topic,当选择创建Topic时,如您未填写Topic名称,将自动生成格式为{数据链路ID_topic_随机字符串}的Topic名称。
数据加工
1.选择VPC。
2.选择Logstash实例。
3.生成数据链路时,将自动在该实例下创建名称为{数据链路ID_lgpipe_随机字符串}的管道,如需对数据进行加工,可在数据链路创建完成后到对应的Logstash实例下修改相关管道的配置。
数据目的
1.选择VPC。
2.选择ES实例。
3.选择写入的索引类型,自治索引适用于2022年6月1日之后创建的7.14.2版本集群,早于此时间创建的7.14.2版本集群重启后可支持。低于7.14.2版本的集群需升级至7.14.2版本。
4.填写索引名称,当写入的索引类型为普通索引时,该名称为索引别名,您可根据该别名访问您的数据。如您未填写索引名称,将自动生成格式为{数据链路ID_index_随机字符串}的索引名称。
5.在写入的索引类型中,如您选择的是新建自治索引,您可对字段映射进行预定义;如您选择的是选择自治索引,请确保采集的 "时间字段" 与所选自治索引的 "时间字段" 完全一致,否则将导致数据写入失败。
TKE-Filebeat-CKafka-Logstash-ES
数据源
1.选择VPC
2.选择TKE集群。
数据采集
1.命名空间:必选。第一个下拉可选择 包含/不包含。第二个下拉可选择命名空间,支持多选,不支持选择不包含全部命名空间。
2.Pod 标签:选填。支持创建多个 Pod 标签,标签之间是逻辑与关系。
3.容器名称:选填。填写的容器名称必须在采集目标集群及命名空间之下,为空时,Filebeat 会采集命名空间下符合 Pod 标签的全部容器。
4.日志内容过滤:选填。根据关键字过滤日志,可填多个关键字,以逗号分隔。
5.高级采集配置:选填。个性化设置解析方式、过滤等,一般采用默认配置。
数据缓存
1.选择CKafka实例。
2.从Ckakfa实例已经路由打通的VPC中,选择跟当前链路组件有交集的VPC。
3.创建或者选择已有Topic,当选择创建Topic时,如您未填写Topic名称,将自动生成格式为{数据链路ID_topic_随机字符串}的Topic名称。
数据加工
1.选择VPC。
2.选择Logstash实例。
3.生成数据链路时,将自动在该实例下创建名称为{数据链路ID_lgpipe_随机字符串}的管道,如需对数据进行加工,可在数据链路创建完成后到对应的Logstash实例下修改相关管道的配置。
数据目的
1.选择VPC。
2.选择ES实例。
3.选择写入的索引类型,自治索引适用于2022年6月1日之后创建的7.14.2版本集群,早于此时间创建的7.14.2版本集群重启后可支持。低于7.14.2版本的集群需升级至7.14.2版本。
4.填写索引名称,当写入的索引类型为普通索引时,该名称为索引别名,您可根据该别名访问您的数据。如您未填写索引名称,将自动生成格式为{数据链路ID_index_随机字符串}的索引名称。
5.在写入的索引类型中,如您选择的是新建自治索引,您可对字段映射进行预定义;如您选择的是选择自治索引,请确保采集的 "时间字段" 与所选自治索引的 "时间字段" 完全一致,否则将导致数据写入失败。
免费体验活动专区
Elasticsearch 新用户可享 2核4G,0元 体验 30 天!顺畅体验云上集群
扫码加入 Elasticsearch 技术社区