1// ...
2    customTransport := &customHeaderTransport{
3        base: client.Transport,
4        headers: map[string]string{
5            "Authorization": "Bearer <Token>", // 替换为控制台实际的 Token
6            "InstanceId": "<监控实例 ID>",      // 替换为控制台实际的监控实例 ID
7        },
8    }
9// ...
10
11func main() {
12    // 创建自定义的 HTTP 客户端，需加入鉴权信息
13    url := "<Pushgateway 地址>/import/"
14
15    customClient := NewCustomClient()
16    registry := prometheus.NewRegistry()
17
18    completionTime := prometheus.NewGauge(prometheus.GaugeOpts{
19        Name: "<指标名称>",
20        Help: "The timestamp of the last successful completion of a Pushgateway push",
21    })
22
23    registry.MustRegister(completionTime)
24    const timeStep = 5
25
26    pusher := push.New(url, "<任务名称>").
27        Gatherer(registry).Client(customClient).
28        Grouping("<标签名>", "<标签值>").
29        Format(expfmt.NewFormat(expfmt.TypeTextPlain))
30    for {
31        completionTime.SetToCurrentTime()
32        if err := pusher.Push(); err != nil {
33            fmt.Println("Could not push completion time to PushGateway: ", err)
34            return
35        }
36        time.Sleep(timeStep * time.Second)
37    }
38}

1echo "<指标名称> <指标值>" | curl -v \
2  --data-binary @- \
3  -H "InstanceId: <监控实例 ID>" \
4  -H "Content-Type: text/plain; charset=utf-8; version=0.0.4" \
5  -H "Authorization: Bearer <Token>" \
6  "<Pushgateway 地址>/import/metrics"