go exporter模板 | 云深不知处

type

status

date

slug

summary

category

icon

password

此模板源自他人，供参考

main包


/**
 * @Author: xuyasong
 * @Description:
 * @File:  main
 * @Version: 1.0.0
 * @Date: 2019/2/22
 */

package main

import (
    "flag"
    "log"
    "net/http"

    "demo/collector"

    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/client_golang/prometheus/promhttp"
)

var (
    // 命令行参数
    listenAddr       = flag.String("web.listen-port", "9002", "An port to listen on for web interface and telemetry.")
    metricsPath      = flag.String("web.telemetry-path", "/metrics", "A path under which to expose metrics.")
    metricsNamespace = flag.String("metric.namespace", "bec", "Prometheus metrics namespace, as the prefix of metrics name")
)

func main() {
    flag.Parse()

    metrics := collector.NewMetrics(*metricsNamespace)
    registry := prometheus.NewRegistry()
    registry.MustRegister(metrics)

    http.Handle(*metricsPath, promhttp.HandlerFor(registry, promhttp.HandlerOpts{}))

    http.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
        w.Write([]byte(`<html>
            <head><title>A Prometheus Exporter</title></head>
            <body>
            <h1>A Prometheus Exporter</h1>
            <p><a href='/metrics'>Metrics</a></p>
            </body>
            </html>`))
    })

    log.Printf("Starting Server at http://localhost:%s%s", *listenAddr, *metricsPath)
    log.Fatal(http.ListenAndServe(":" + *listenAddr, nil))
}

collector包


/**
 * @Author: xuyasong
 * @Description:
 * @File:  network
 * @Version: 1.0.0
 * @Date:
 */

package collector

import (
    "context"
    "encoding/json"
    "fmt"
    "strconv"
    "strings"
    "sync"
    "time"

    "github.com/prometheus/client_golang/prometheus"
    "github.com/prometheus/common/log"
)

type Metrics struct {
    metrics map[string]*prometheus.Desc
    mutex   sync.Mutex
}

func newGlobalMetric(namespace string, metricName string, docString string, labels []string) *prometheus.Desc {
    return prometheus.NewDesc(namespace+"_"+metricName, docString, labels, nil)
}


func NewMetrics(namespace string) *Metrics {
    return &Metrics{
        metrics: map[string]*prometheus.Desc{
            "pod_network_receive_bytes":  newGlobalMetric(namespace, "pod_network_receive_bytes", "network receive bytes of pod ", []string{"pod_name", "namespace", "node_name"}),
    }
}

/**
 * 接口：Describe
 * 功能：传递结构体中的指标描述符到channel
 */
func (c *Metrics) Describe(ch chan<- *prometheus.Desc) {
    for _, m := range c.metrics {
        ch <- m
    }
}

/**
 * 接口：Collect
 * 功能：抓取最新的数据，传递给channel
 */
func (c *Metrics) Collect(ch chan<- prometheus.Metric) {
    c.mutex.Lock() // 加锁
    defer c.mutex.Unlock()
   // do something ,add metric to channel
   //具体指标数据可以用另一个包采集
    ch <- prometheus.MustNewConstMetric(c.metrics["pod_network_receive_bytes"], prometheus.CounterValue, 0, pod.podName, pod.namespace, hostname)
}

部署参考

dockerfile


FROM nginx:stable-alpine

MAINTAINER xuyasong

RUN sed -i 's/dl-cdn.alpinelinux.org/mirrors.ustc.edu.cn/g' /etc/apk/repositories

RUN mkdir -p /opt/bin && chown -R root:root /opt \
    && apk update&&apk add --no-cache  wget curl less util-linux

COPY bin/demo-exporter /opt/bin/demo-exporter

COPY scripts /opt/bin/scripts

CMD ["/opt/bin/scripts/entrypoint.sh"]

entrypoint.sh


#!/bin/sh

cd /opt
mkdir -p log
chmod 755 log
bin/demo-exporter 2>>log/demo-exporter.log

deployment


---
kind: Deployment
apiVersion: apps/v1
metadata:
  name: demo-exporter
  namespace: monitor
  labels:
    k8s-app: demo-exporter
spec:
  selector:
    matchLabels:
      k8s-app: demo-exporter
  template:
    metadata:
      labels:
        k8s-app: demo-exporter
      annotations:
        "prometheus.io/scrape": "true"
    spec:
      containers:
        - name: demo-exporter
          image: demo-exporter
          imagePullPolicy: Always
          resources:
            limits:
              cpu: "1"
              memory: "500Mi"
            requests:
              cpu: "1"
              memory: "200Mi"
          securityContext:
            privileged: true
          volumeMounts:
          - mountPath: /opt/log
            name: demo-exporter-log
      volumes:
        - hostPath:
            path: /var/demo-exporter
          name: demo-exporter-log
---
apiVersion: v1
kind: Service
metadata:
  annotations:
    prometheus.io/scrape: "true"
  labels:
    k8s-app: demo-exporter
  name: demo-exporter
  namespace: monitor
spec:
  ports:
  - name: http-metrics
    port: 9006
    protocol: TCP
    targetPort: 9006
  selector:
    k8s-app: demo-exporter
  type: ClusterIP