Simple Log Service:Use Prometheus SDK to upload metric data in Function Compute scenarios

Go

Simple Log Service SDK for Go is installed. For more information, see Install Simple Log Service SDK for Go. The Gather() function is used to query all metrics. Then, the Encode or Decode operation is called.

package main

import (
	"bytes"
	"fmt"
	"time"

	"github.com/gogo/protobuf/proto"
	"github.com/golang/snappy"
	"github.com/prometheus/client_golang/prometheus"
	"github.com/prometheus/common/expfmt"
	"github.com/prometheus/prometheus/util/fmtutil"

	"io/ioutil"
	"math/rand"
	"net/http"
)

var durationHistogram = prometheus.NewHistogram(
	prometheus.HistogramOpts{
		Name:    "server_handling_seconds",
		Buckets: prometheus.DefBuckets,
	},
)

var requestCount = prometheus.NewCounter(
	prometheus.CounterOpts{
		Name: "server_requests_count",
	},
)

func main() {
	prometheus.MustRegister(durationHistogram)

	// Replace your-project-name, endpoint, your-project-name, and your-metricstore-name based on your business requirements.
	u := fmt.Sprintf("https://%s.%s/prometheus/%s/%s/api/v1/write", "your-project-name", "endpoint", "your-project-name", "your-metricstore-name")

	for i := 0; i < 300; i++ {
		// Update metric data.
		for j := 0; j < 100; j++ {
			val := rand.Float64() * 10
			durationHistogram.Observe(val)
			requestCount.Inc()
		}

		// Collect all registered metric data.
		mfs, err := prometheus.DefaultGatherer.Gather()
		if err != nil {
			panic(err)
		}

		// Encode the metric data.
		// Note: The metric data must be encoded because the le label +Inf is added to Histogram metrics during data encoding. 
		buf := bytes.NewBuffer(nil)
		encoder := expfmt.NewEncoder(buf, expfmt.NewFormat(expfmt.TypeTextPlain))
		for _, mf := range mfs {
			if err := encoder.Encode(mf); err != nil {
				panic(err)
			}
		}

		// Parse the encoded metric data and convert the parsed data into the data that conforms to the Prometheus Remote Write PB protocol.
		// In this example, an error occurs and the process is directly terminated without handling the error. In actual scenarios, you must select a handling method based on your business requirements. For example, you can skip the error or exit and retry the process.
		request, err := fmtutil.MetricTextToWriteRequest(buf, nil)
		if err != nil {
			panic(err)
		}

		// Serialize and compress the *prompb.WriteRequest object.
		data, _ := proto.Marshal(request)
		bufBody := snappy.Encode(nil, data)
		rwR, err := http.NewRequest("POST", u, ioutil.NopCloser(bytes.NewReader(bufBody)))
		if err != nil {
			panic(err)
		}
		rwR.Header.Add("Content-Encoding", "snappy")
		rwR.Header.Set("Content-Type", "application/x-protobuf")
		// Configure the BasicAuth parameter. You must specify an AccessKey ID and an AccessKey secret. 
		rwR.SetBasicAuth("yourAccessKeyID", "yourAccessKeySecret")

		// Send metric data to the Simple Log Service Metricstore.
		resp, err := http.DefaultClient.Do(rwR)
		if err != nil {
			panic(err)
		}
		d, err := ioutil.ReadAll(resp.Body)
		if err != nil {
			panic(err)
		}
		fmt.Println(string(d))

		time.Sleep(time.Second)
	}

}