Prometheus+Grafana Exporter的使用

1
package main
2

3
import (
4
  "math/rand"
5
  "net/http"
6
  "time"
7

8
  "github.com/prometheus/client_golang/prometheus"
9
  "github.com/prometheus/client_golang/prometheus/promhttp"
10
)
11

12
func main() {
13
  // 1. 定义一个 Gauge 指标
14
  temp := prometheus.NewGauge(prometheus.GaugeOpts{
15
    Name: "temperature_celsius",
16
    Help: "Current temperature in Celsius.",
17
  })
18
  prometheus.MustRegister(temp)
19

20
  // 2. 后台更新指标值
21
  go func() {
22
    for {
23
      temp.Set(20 + rand.Float64()*10) // 随机 20~30 度
24
      time.Sleep(5 * time.Second)
25
    }
26
  }()
27

28
  // 3. 启动 HTTP 服务，暴露 /metrics
29
  http.Handle("/metrics", promhttp.Handler())
30
  http.ListenAndServe(":8080", nil)
31
}

1
package main
2

3
import (
4
  "net/http"
5
  "time"
6

7
  "github.com/prometheus/client_golang/prometheus"
8
  "github.com/prometheus/client_golang/prometheus/promhttp"
9
)
10

11
func main() {
12
  // 定义 Counter 指标
13
  requestsTotal := prometheus.NewCounter(
14
    prometheus.CounterOpts{
15
      Name: "myapp_requests_total",
16
      Help: "Total number of requests processed.",
17
    },
18
  )
19
  prometheus.MustRegister(requestsTotal)
20

21
  // 模拟每 2 秒增加一次计数
22
  go func() {
23
    for {
24
      requestsTotal.Inc() // 每次 +1
25
      time.Sleep(2 * time.Second)
26
    }
27
  }()
28

29
  // 暴露 /metrics
30
  http.Handle("/metrics", promhttp.Handler())
31
  http.ListenAndServe(":8080", nil)
32
}

1
package main
2

3
import (
4
  "math/rand"
5
  "net/http"
6
  "time"
7

8
  "github.com/prometheus/client_golang/prometheus"
9
  "github.com/prometheus/client_golang/prometheus/promhttp"
10
)
11

12
func main() {
13
  // 定义 Gauge 指标
14
  temperature := prometheus.NewGauge(
15
    prometheus.GaugeOpts{
16
      Name: "temperature_celsius",
17
      Help: "Current temperature in Celsius.",
18
    },
19
  )
20
  prometheus.MustRegister(temperature)
21

22
  // 模拟每 3 秒随机变化
23
  go func() {
24
    for {
25
      temp := 20 + rand.Float64()*10 // 20~30 度
26
      temperature.Set(temp)
27
      time.Sleep(3 * time.Second)
28
    }
29
  }()
30

31
  http.Handle("/metrics", promhttp.Handler())
32
  http.ListenAndServe(":8080", nil)
33
}

1
package main
2

3
import (
4
  "math/rand"
5
  "net/http"
6
  "time"
7

8
  "github.com/prometheus/client_golang/prometheus"
9
  "github.com/prometheus/client_golang/prometheus/promhttp"
10
)
11

12
func main() {
13
  // 定义 Histogram（使用默认桶）
14
  requestDuration := prometheus.NewHistogram(
15
    prometheus.HistogramOpts{
16
      Name:    "http_request_duration_seconds",
17
      Help:    "Histogram of HTTP request durations.",
18
      Buckets: prometheus.DefBuckets, // 默认桶: [0.005, 0.01, 0.025, 0.05, 0.1, 0.25, 0.5, 1, 2.5, 5, 10]
19
    },
20
  )
21
  prometheus.MustRegister(requestDuration)
22

23
  // 模拟每 1 秒记录一个随机耗时（0~5 秒）
24
  go func() {
25
    for {
26
      duration := rand.Float64() * 5
27
      requestDuration.Observe(duration)
28
      time.Sleep(1 * time.Second)
29
    }
30
  }()
31

32
  http.Handle("/metrics", promhttp.Handler())
33
  http.ListenAndServe(":8080", nil)
34
}

1
package main
2

3
import (
4
  "math/rand"
5
  "net/http"
6
  "time"
7

8
  "github.com/prometheus/client_golang/prometheus"
9
  "github.com/prometheus/client_golang/prometheus/promhttp"
10
)
11

12
func main() {
13
  // 定义 Summary（指定目标分位数）
14
  responseSize := prometheus.NewSummary(
15
    prometheus.SummaryOpts{
16
      Name:       "http_response_size_bytes",
17
      Help:       "Summary of HTTP response sizes.",
18
      Objectives: map[float64]float64{0.5: 0.05, 0.9: 0.01, 0.99: 0.001},
19
    },
20
  )
21
  prometheus.MustRegister(responseSize)
22

23
  // 模拟每 2 秒记录一个随机响应大小（100~1000 字节）
24
  go func() {
25
    for {
26
      size := 100 + rand.Float64()*900
27
      responseSize.Observe(size)
28
      time.Sleep(2 * time.Second)
29
    }
30
  }()
31

32
  http.Handle("/metrics", promhttp.Handler())
33
  http.ListenAndServe(":8080", nil)
34
}