关于go:使用golang-自定义编写开发-Prometheus-exporter

3次阅读

共计 8157 个字符，预计需要花费 21 分钟才能阅读完成。

Exporter 是基于 Prometheus 施行的监控零碎中重要的组成部分，承当数据指标的采集工作，官网的 exporter 列表中曾经蕴含了常见的绝大多数的零碎指标监控，比方用于机器性能监控的 node_exporter, 用于网络设备监控的 snmp_exporter 等等。这些已有的 exporter 对于监控来说，仅仅须要很少的配置工作就能提供欠缺的数据指标采集。
prometheus 四种类型的指标 Counter 计数，Gauge 观测类，Histogram 直方，Summary 摘要 用 golang 语言如何结构这 4 种类型对应的指标，二是搞清楚批改指标值的场景和形式。

不带 label 的根本例子 


package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    cpuUsage := prometheus.NewGauge(prometheus.GaugeOpts{
        Name:        "cpu_usage",                              // 指标名称
        Help:        "this is test metrics cpu usage",         // 帮忙信息

    })
    // 给指标设置值
    cpuUsage.Set(29.56)
    // 注册指标
    prometheus.MustRegister(cpuUsage)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带有固定 label 指标的例子

带有非固定 label 指标的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义带有不固定 label 的指标
    mtu := prometheus.NewGaugeVec(prometheus.GaugeOpts{
        Name: "interface_mtu",
        Help: "网卡接口 MTU",
    }, []string{"interface", "Machinetype"})

    // 给指标设置值
    mtu.WithLabelValues("lo", "host").Set(1500)
    mtu.WithLabelValues("ens32", "host").Set(1500)
    mtu.WithLabelValues("eth0", "host").Set(1500)

    // 注册指标
    prometheus.MustRegister(mtu)

    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

2. Counter 指标类型

不带 label 的根本例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqTotal := prometheus.NewCounter(prometheus.CounterOpts{
        Name: "current_request_total",
        Help: "以后申请总数",
    })
    // 注册指标
    prometheus.MustRegister(reqTotal)

    // 设置值
    reqTotal.Add(10)

    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带有固定 label 指标的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    suceReqTotal := prometheus.NewCounter(prometheus.CounterOpts{
        Name:        "sucess_request_total",
        Help:        "申请胜利的总数",
        ConstLabels: prometheus.Labels{"StatusCode": "200"},
    })
    // 注册指标
    prometheus.MustRegister(suceReqTotal)

    // 设置值
    suceReqTotal.Add(5675)

    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带有非固定 label 指标的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    pathReqTotal := prometheus.NewCounterVec(prometheus.CounterOpts{
        Name: "path_request_total",
        Help: "path 申请总数",
    }, []string{"path"})
    // 注册指标
    prometheus.MustRegister(pathReqTotal)

    // 设置值
    pathReqTotal.WithLabelValues("/token").Add(37)
    pathReqTotal.WithLabelValues("/auth").Add(23)
    pathReqTotal.WithLabelValues("/user").Add(90)
    pathReqTotal.WithLabelValues("/api").Add(67)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

3. Histogram 指标类型

不带 label 的根本例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqDelay := prometheus.NewHistogram(prometheus.HistogramOpts{
        Name:    "request_delay",
        Help:    "申请提早，单位秒",
        Buckets: prometheus.LinearBuckets(0, 3, 6), // 调用 LinearBuckets 生成区间，从 0 开始，宽度 3，共 6 个 Bucket
    })

    // 注册指标
    prometheus.MustRegister(reqDelay)

    // 设置值
    reqDelay.Observe(6)

    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带固定 label 的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqDelay := prometheus.NewHistogram(prometheus.HistogramOpts{
        Name:        "request_delay",
        Help:        "申请提早，单位秒",
        Buckets:     prometheus.LinearBuckets(0, 3, 6), // 调用 LinearBuckets 生成区间，从 0 开始，宽度 3，共 6 个 Bucket
        ConstLabels: prometheus.Labels{"path": "/api"},
    })

    // 注册指标
    prometheus.MustRegister(reqDelay)

    // 设置值
    reqDelay.Observe(6)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带有非固定 label 的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqDelay := prometheus.NewHistogramVec(prometheus.HistogramOpts{
        Name:    "request_delay",
        Help:    "申请提早，单位秒",
        Buckets: prometheus.LinearBuckets(0, 3, 6), // 调用 LinearBuckets 生成区间，从 0 开始，宽度 3，共 6 个 Bucket
    }, []string{"path"})

    // 注册指标
    prometheus.MustRegister(reqDelay)

    // 设置值
    reqDelay.WithLabelValues("/api").Observe(6)
    reqDelay.WithLabelValues("/user").Observe(3)
    reqDelay.WithLabelValues("/delete").Observe(2)
    reqDelay.WithLabelValues("/get_token").Observe(13)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

4.Summary 指标类型

不带 label 的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqDelay := prometheus.NewSummary(prometheus.SummaryOpts{
        Name:       "request_delay",
        Help:       "申请提早",
        Objectives: map[float64]float64{0.5: 0.05, 0.90: 0.01, 0.99: 0.001}, // 百分比: 精度
    })

    // 注册指标
    prometheus.MustRegister(reqDelay)

    // 设置值
    reqDelay.Observe(4)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带有固定 label 的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqDelay := prometheus.NewSummary(prometheus.SummaryOpts{
        Name:        "request_delay",
        Help:        "申请提早",
        Objectives:  map[float64]float64{0.5: 0.05, 0.90: 0.01, 0.99: 0.001}, // 百分比: 精度
        ConstLabels: prometheus.Labels{"path": "/api"},
    })

    // 注册指标
    prometheus.MustRegister(reqDelay)

    // 设置值
    reqDelay.Observe(4)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

带有非固定 label 的例子 

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    // 定义指标
    reqDelay := prometheus.NewSummaryVec(prometheus.SummaryOpts{
        Name:       "request_delay",
        Help:       "申请提早",
        Objectives: map[float64]float64{0.5: 0.05, 0.90: 0.01, 0.99: 0.001}, // 百分比: 精度
    }, []string{"path"})

    // 注册指标
    prometheus.MustRegister(reqDelay)

    // 设置值
    reqDelay.WithLabelValues("/api").Observe(4)
    reqDelay.WithLabelValues("/token").Observe(2)
    reqDelay.WithLabelValues("/user").Observe(3)
    // 裸露指标
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

5. 值的批改

5.1 基于事件的触发来批改值，比方每拜访 1 次 /api 就增 1

基于事件的触发对指标的值进行批改，通常大多数是来自业务方面的指标需要，如自研的利用须要裸露相干指标给 promethus 进行监控、展现，那么指标采集的代码（指标定义、设置值）就要嵌入到自研利用代码里了。

package main

import (
    "fmt"
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "net/http"
)

func main() {
    urlRequestTotal := prometheus.NewCounterVec(prometheus.CounterOpts{
        Name: "urlRequestTotal",
        Help: "PATH 申请累计 单位 次",
    }, []string{"path"})

    http.HandleFunc("/api", func(w http.ResponseWriter, r *http.Request) {urlRequestTotal.WithLabelValues(r.URL.Path).Inc() // 应用 Inc 函数进行增 1
        fmt.Fprintf(w, "Welcome to the api")
    })

    prometheus.MustRegister(urlRequestTotal)
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

基于工夫周期的触发来批改值，比方上面的示例中，是每距离 1 秒获取 cpu 负载指标

基于工夫周期的触发，能够是多少秒、分、时、日、月、周。

package main

import (
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
    "github.com/shirou/gopsutil/load"
    "net/http"
    "time"
)

func main() {
    cpuUsage := prometheus.NewGaugeVec(prometheus.GaugeOpts{
        Name: "CpuLoad",
        Help: "CPU 负载",
    }, []string{"time"})

    // 开启一个子协程执行该匿名函数内的逻辑来给指标设置值，且每秒获取一次
    go func() {for range time.Tick(time.Second) {info, _ := load.Avg()
            cpuUsage.WithLabelValues("Load1").Set(float64(info.Load1))
            cpuUsage.WithLabelValues("Load5").Set(float64(info.Load5))
            cpuUsage.WithLabelValues("Load15").Set(float64(info.Load15))
        }
    }()

    prometheus.MustRegister(cpuUsage)
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

基于每拜访一次获取指标的 URI 才批改值，比方每次拜访 /metrics 才去批改某些指标的值

上面的这个示例是，每拜访一次 /metrics 就获取一次内存总容量 

package main

import (
    "fmt"
    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"

    "github.com/shirou/gopsutil/mem"
    "net/http"
)

func main() {
    MemTotal := prometheus.NewGaugeFunc(prometheus.GaugeOpts{
        Name: "MemTotal",
        Help: "内存总容量 单位 GB",
    }, func() float64 {fmt.Println("call MemTotal ...")
        info, _ := mem.VirtualMemory()
        return float64(info.Total / 1024 / 1024 / 1024)
    })
    prometheus.MustRegister(MemTotal)
    http.Handle("/metrics", promhttp.Handler())
    http.ListenAndServe("localhost:9100", nil)
}

正文完
go
发表至： go
2023-06-14
 0
关于go:Go-快速入门指南-运算优先级
关于go:Go-Struct
关于go:Go运算操作符全解与实战编写更高效的代码
关于go:去深圳见了几个大佬我悟了……

站内搜索

-「」