腾讯云可观测平台数据写入-Prometheus 监控-文档中心-腾讯云

操作场景
像类似 flink job 上报数据这样的场景下我们需要通过 API 直接将数据写入 Prometheus，因为这些 job 的生命周期可能会很短，来不及等待 Prometheus 写入数据。可以直接使用 Remote Write 协议或者 Pushgateway 的方式。
Remote Write
POST /api/v1/prom/write
Remote Write 是 Prometheus 标准的协议，更多介绍可以访问这里。使用 remote write 我们可以把 VPC 内其他 Prometheus 的数据写入到腾讯云托管的 Prometheus 服务中，对于数据的稳定性提升和迁移，都不失为一种不错的方案。
Pushgateway
虽然 Prometheus 场景主张以拉为主，但是有些场景我们仍然需要使用推的方式，可以参见官方文档。
说明：
注意 Pushgateway 协议在这里仅作为 remote write 协议的补充，不支持删除操作，可以理解为我们提供的删除接口是空的不执行任何逻辑，特殊需求可自行部署 PushGateway。
腾讯云托管的 Prometheus 服务原生集成了 Pushgateway 模块，可以直接推送数据到服务中。下面是一个使用 Go 语言推送数据的简单的例子, 记得将 $IP、$PORT、$APPID、$TOKEN 这些变量改为自己实例的认证链接信息，这些链接信息可以从控制台进行查询。强烈建议替换 $INSTANCE 为当前机器的标识，例如 IP/Hostname。如果没有设置这个 groupingKey，当多台机器一起上报时，数据会互相覆盖。
package main
﻿
import (
    "fmt"
    "time"
﻿
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/push"
    "github.com/prometheus/common/expfmt"
)
﻿
var completionTime = prometheus.NewGauge(prometheus.GaugeOpts{
    Name: "db_backup_last_completion_timestamp_seconds",
    Help: "The timestamp of the last successful completion of a DB backup.",
})
﻿
func do() {
    completionTime.SetToCurrentTime()
}
﻿
func ExamplePusher_Push() {
    if err := push.New("http://$IP:$PORT", "db_backup").
        BasicAuth("$APPID", "$TOKEN").
        Collector(completionTime).
        Grouping("instance", "$INSTANCE").
        Grouping("db", "customers").
        Format(expfmt.FmtText).
        Push(); err != nil {
        fmt.Println("Could not push completion time to Pushgateway:", err)
    }
}
﻿
func main() {
    do()
    ticker := time.NewTicker(2 * time.Second)
    done := make(chan bool)
    for {
        select {
        case <-done:
            return
        case <-ticker.C:
            ExamplePusher_Push()
        }
    }
}
注意：
push.New 生成的对象可以通过 Client 方法自定义 HTTP Client，我们推荐设置一个合适的超时时间，同时 push 数据我们建议使用异步的方式调用，以免阻塞业务主流程。
其它上报场景请参见 自定义监控。 
数据写入

本页目录：

操作场景

Remote Write

Pushgateway
