托管 Prometheus 支持通过 ServiceMonitor 来指定自定义目标的采集规则,满足您自定义业务的服务发现需求。本文为您介绍如何通过 ServiceMonitor 来配置服务发现。
您可以使用以下 Demo,体验基于 golang 的应用接入和 ServiceMonitor 服务发现过程。下面的示例中,使用 golang 语言创建了一个应用,并在应用中暴露了一个名为 rpc_durations_seconds 的指标,用于对服务的 RPC 延迟进行统计。
package main import ( "math" "math/rand" "net/http" "time" "github.com/prometheus/client_golang/prometheus" "github.com/prometheus/client_golang/prometheus/collectors" "github.com/prometheus/client_golang/prometheus/promhttp" ) var rpcDurations = prometheus.NewSummaryVec( prometheus.SummaryOpts{ Name: "rpc_durations_seconds", Help: "RPC latency distributions.", Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.99: 0.001}, }, []string{"service"}, ) func main() { // Create a new registry. reg := prometheus.NewRegistry() // Add Go module build info. reg.MustRegister(collectors.NewBuildInfoCollector()) // Add go runtime metrics and process collectors. reg.MustRegister( collectors.NewGoCollector(), collectors.NewProcessCollector(collectors.ProcessCollectorOpts{}), ) reg.MustRegister(rpcDurations) start := time.Now() oscillationFactor := func() float64 { return 2 + math.Sin(math.Sin(2*math.Pi*float64(time.Since(start))/float64(10*time.Minute))) } // Periodically record some sample latencies for the three services. go func() { for { v := rand.Float64() * 0.0002 rpcDurations.WithLabelValues("uniform").Observe(v) time.Sleep(time.Duration(100*oscillationFactor()) * time.Millisecond) } }() go func() { for { v := (rand.NormFloat64() * 0.0002) + 0.00001 rpcDurations.WithLabelValues("normal").Observe(v) time.Sleep(time.Duration(75*oscillationFactor()) * time.Millisecond) } }() go func() { for { v := rand.ExpFloat64() / 1e6 rpcDurations.WithLabelValues("exponential").Observe(v) time.Sleep(time.Duration(50*oscillationFactor()) * time.Millisecond) } }() http.Handle("/metrics", promhttp.HandlerFor( reg, promhttp.HandlerOpts{}, )) http.ListenAndServe(":2023", nil) }
您可以使用 Dockerfile 将上述代码打包为镜像,然后部署在容器服务 VKE 集群中。详情请参见 Golang 应用接入。
如果您的集群中不存在 ServiceMonitor CRD 资源,需要首先在集群中创建 CRD 资源,具体的步骤如下:
kubectl apply -f https://vmp-release-cn-beijing.tos-cn-beijing.volces.com/manifests/crds/promopeartor-crd-servicemonitors.yaml
说明
cn-beijing
字段修改为对应地域的 RegionID。例如:华东2(上海)地域的集群,部署命令为 kubectl apply -f https://vmp-release-cn-shanghai.tos-cn-shanghai.volces.com/manifests/crds/promopeartor-crd-servicemonitors.yaml
。地域的 RegionID 详情请参见 地域和可用区。您可以使用镜像仓库中的镜像,在容器服务 VKE 集群中部署应用。步骤如下:
apiVersion: apps/v1 kind: Deployment metadata: name: golang-demo # 配置应用的名称 namespace: volcano-metrics # 配置应用所在的命名空间 labels: app: golang-demo # 配置应用的标签 spec: replicas: 2 # 配置应用副本数 selector: matchLabels: app: golang-demo template: metadata: labels: app: golang-demo spec: containers: - name: golang-demo # 配置容器名称 image: doc-cn-beijing.cr.volces.com/vmp/golang-demo:1.0 # 配置应用镜像的地址和版本 ports: - containerPort: 2023 # 配置容器端口号
说明
本例中的镜像地址为举例,您需要将其修改为实际环境中镜像的正确地址。
apiVersion: v1 kind: Service metadata: name: golang-service-demo namespace: volcano-metrics # 配置服务所在的命名空间 labels: app: golang-service-demo # 配置服务的标签 spec: selector: app: golang-demo ports: - protocol: TCP port: 2023 targetPort: 2023 name: metrics # 配置服务端口名称 type: ClusterIP
apiVersion: monitoring.coreos.com/v1 kind: ServiceMonitor metadata: name: golang-demo-discover # 配置服务发现名称 namespace: default # 配置 ServiceMonitor 命名空间 labels: volcengine.vmp: "true" # 配置 ServiceMonitor 的标签,允许被 Prometheus-agent 发现 spec: endpoints: - port: metrics # 填写 Service 的服务端口名称 relabelings: # 配置指标的 relabel。如没有需求,可省略 - targetLabel: environment action: replace # 这个例子中我们添加一个固定 label:environment="Production" replacement: Production namespaceSelector: matchNames: - volcano-metrics # 配置为 Service 所在的命名空间 selector: matchLabels: app: golang-service-demo # 配置 Service 的 Label 值,以定位和选择目标 Service
up{job="golang-service-demo"}
,查看对应的服务是否被正确发现。