利用Golang prometheus，如何度量网络请求的指标？

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《利用Golang prometheus，如何度量网络请求的指标？》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

我有一个服务 A，我正在使用 prometheus 废弃指标，A 向另一个服务 B 发出一些出站请求。有没有办法获取从 A 到 B 的请求指标？

就像，我想要来自 A -> B 的请求的测量计数和持续时间

正确答案

可以使用 prometheus.newcountervec 和 prometheus.newhistogramvec （或 proemetheus.newsummaryvec，取决于用例）来记录指标。

我们可以使用自定义标签来识别谁是客户端以及谁是客户端服务器。通过这种方式，可以过滤出客户端的 request count 和 duration 指标到特定的服务器。

这是示例片段

client.go

package main

import (
    "net/http"
    "time"

    "github.com/labstack/echo/v4"
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
)

var (
    requestcounter = prometheus.newcountervec(
        prometheus.counteropts{
            name: "client_request_count",
            help: "total number of requests from client",
        },
        []string{"client", "server", "method", "route", "status"},
    )

    durationhistorgram = prometheus.newhistogramvec(
        prometheus.histogramopts{
            name:    "client_request_duration_secs",
            help:    "duration of requests from client",
            buckets: []float64{0.1, 0.5, 1, 2, 5},
        },
        []string{"client", "server", "method", "route", "status"},
    )
)

func init() {
    prometheus.mustregister(requestcounter)
    prometheus.mustregister(durationhistorgram)
}

func main() {

    e := echo.new()
    e.get("/", func(c echo.context) error {

        // the request start time
        start := time.now()
        req, err := http.newrequest("get", "http://localhost:8002", nil)
        if err != nil {
            return c.json(http.statusinternalservererror, err.error())
        }

        resp, err := http.defaultclient.do(req)
        if err != nil {
            return c.json(http.statusinternalservererror, err.error())
        }
        defer resp.body.close()

        labels := prometheus.labels{
            "client": "server a", // defines the client server
            "server": "server b", // defines the outbound request server
            "method": "get",// http method
            "route":  "/", // request route
            "status": resp.status,// response status
        }
        duration := time.since(start).seconds()

        // the duration
        durationhistorgram.with(labels).observe(duration)

        // request api count
        requestcounter.with(labels).inc()

        return c.string(http.statusok, "[client -> server] request send and received")
    })

    e.get("/metrics", echo.wraphandler(promhttp.handler()))

    if err := e.start(":8001"); err != nil {
        panic(err)
    }
}

server.go

package main

import (
    "net/http"

    "github.com/labstack/echo/v4"
)

func main() {
    e := echo.new()

    e.get("/", func(c echo.context) error {
        return c.json(http.statusok, map[string]interface{}{
            "message": "response sending from server",
        })
    })

    if err := e.start(":8002"); err != nil {
        panic(err)
    }
}

正如您在代码中看到的，这些是我们的自定义标签。

[]string{"client", "server", "method", "route", "status"},

这些是标签值

labels := prometheus.labels{
            "client": "server a", // defines the client server
            "server": "server b", // defines the outbound request server
            "method": "get", // http method
            "route":  "/", // request route
            "status": resp.status,// response status
        }

终于我们可以查询了

client_request_count {client="Server A", server="Server B"}

服务器a向服务器b发送请求

参考文献

• prometheus historgram
• 普罗米修斯摘要
• 直方图和摘要
• 示例

本篇关于《利用Golang prometheus，如何度量网络请求的指标？》的介绍就到此结束啦，但是学无止境，想要了解学习更多关于Golang的相关知识，请关注golang学习网公众号！