利用promwrite对prometheus进行remote-write写入
# 前言
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)
# 实践介绍
本文实际主要想介绍的，是基于 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,
},
},
},
})
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
如果你的集群包含认证，那么可以使用如下代码：
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,
},
},
},
})
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
其中的 __name__ 是保留字段，会自动作为该记录的的指标名。剩下的如果你需要更多的补充字段，则在 []promwrite.Label 补充即可。
|