前言

prometheus 大概在 2.30 版本左右的时候，增加了 remote write 的能力，这是一种有别于 exporter 暴漏指标由 prometheus 拉，以及 pushgateway 推的指标上报方式，你可以借助于这种方式上报你的指标，也可以基于此能力，将多个集群的指标汇聚到一个集群之中。

腾讯云的 cls 推出了指标主题的类型，其支持的，也正是这种 remote write 写入的方式。

相关资料

prometheus 官方相关文档： https://prometheus.io/docs/practices/remote_write/ (opens new window) 腾讯云指标主题的介绍：指标上报 (opens new window)

申明

原创文章eryajf，未经授权，严禁转载，侵权必究！此乃文中随机水印，敬请读者谅解。

Copyright 二丫讲梵 (opens new window) 版权所有

实践介绍

本文实际主要想介绍的，是基于 go 语言的 remote write 上报实践，这里就结合我的个人实际体验，来进行记录。

我在实践的过程中，找到了一个比较好用的包： https://github.com/castai/promwrite (opens new window)，但实际应用过程中发现，此包没有支持开启了认证的场景，而腾讯云 cls 默认是开启认证的，因此个人对此包做了一些功能扩展，提交了 pr，但是之后源仓库维护者没有理会，我就单独重置了 mod，因此接下来的示例就用我的包来做了。事实上直接看 readme 的介绍也可以了解用法。

我的地址为： https://github.com/eryajf/promwrite (opens new window)

安装包：

go get github.com/eryajf/promwrite

示例代码：

	client := promwrite.NewClient("http://prometheus:8428/api/v1/write")
	resp, err := client.Write(context.Background(), &promwrite.WriteRequest{
		TimeSeries: []promwrite.TimeSeries{
			{
				Labels: []promwrite.Label{
					{
						Name:  "__name__",
						Value: "my_metric_name",
					},
				},
				Sample: promwrite.Sample{
					Time:  time.Now(),
					Value: 123,
				},
			},
		},
	})

如果你的集群包含认证，那么可以使用如下代码：

	client := promwrite.NewClient("http://prometheus:8428/api/v1/write",
		promwrite.HttpClientWithAuth(
			&http.Client{},
			&promwrite.BasicAuth{
				Username: "admin",
				Password: "xxxxxx",
			}))

	resp, err := client.Write(context.Background(), &promwrite.WriteRequest{
		TimeSeries: []promwrite.TimeSeries{
			{
				Labels: []promwrite.Label{
					{
						Name:  "__name__",
						Value: "my_metric_name",
					},
				},
				Sample: promwrite.Sample{
					Time:  time.Now(),
					Value: 123,
				},
			},
		},
	})

其中的 __name__ 是保留字段，会自动作为该记录的的指标名。剩下的如果你需要更多的补充字段，则在 []promwrite.Label 补充即可。