grafana

ExampleAliGrafana_Query demonstrates how to use AliGrafana.Query. Open the link to see an example: https://go.dev/play/p/GzFSQA0jut5

// An example of an Alibaba Cloud Grafana query
log.SetLevel(log.DebugLevel)
log.SetOutput(os.Stdout)
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
defer cancel()
d := devops.NewDevops()
ag := d.AliGrafana()
addr := "https://xxxx.grafana.aliyuncs.com/api/datasources/proxy/:id/api/v1/query"
token := "Bearer xxxxx"
query := `sum by (rpc) (sum_over_time(arms_rpc_requests_count{}[%s]))`
timeframe := "68400s"
end := time.Now().Local().Unix()

query = fmt.Sprintf(query, timeframe)

// query metrics
res, err := ag.Query(ctx, addr, token, query, grafana.Options{To: end})
if err != nil {
	log.Errorf("Post metrics data from ali grafana error: %s", err.Error())
}
fmt.Println(string(res))

ExampleAliGrafana_QueryRange demonstrates how to use AliGrafana.QueryRange. Open the link to see an example: https://go.dev/play/p/N9eFrFvkZmQ

// An example of an Alibaba Cloud Grafana range query
log.SetLevel(log.DebugLevel)
log.SetOutput(os.Stdout)
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
defer cancel()

// new devops AliGrafana
d := devops.NewDevops()
ag := d.AliGrafana()
addr := "https://xxxx.grafana.aliyuncs.com/api/datasources/proxy/:id/api/v1/query"
token := "Bearer xxxxx"
query := `sum by (rpc) (sum_over_time(arms_rpc_requests_count{}[1m]))`

m, _ := time.ParseDuration("-15m")
now := time.Now().Local()
// options is grafana.Options.
// The example is in the same directory as the structure,
// so it does not have a directory beginning
options := grafana.Options{
	From: now.Add(m).Unix(),
	To:   now.Unix(),
	Step: int64(60),
}
// use QueryRange
res, err := ag.QueryRange(ctx, addr, token, query, options)
if err != nil {
	log.Errorf("Post metrics data from ali grafana error: %s", err.Error())
}
fmt.Println(string(res))

ExampleGrafana_Query demonstrates how to use Grafana.Query. Open the link to see an example: https://go.dev/play/p/akMvLdzZNd-

// An example of an open-source Grafana query

log.SetLevel(log.DebugLevel)
log.SetOutput(os.Stdout)
ctx, cancel := context.WithTimeout(context.Background(), 1*time.Minute)
defer cancel()

// new devops Grafana
d := devops.NewDevops()
ag := d.Grafana()
addr := "https://localhost:3000/api/ds/query"
token := "Bearer xxxx"
query := `{"queries":[{"refId":"A","key":"Q-b34b5ac7-c2d7-44fc-bc77-06570400a564-0","instant":true,"range":false,"exemplar":false,"expr":"sum(rate(kube_pod_container_status_restarts_total{environment=~\"pd\"}[$__range])>=0) by (pod, environment)","datasource":{"uid":"yPdqCed7z","type":"prometheus"},"queryType":"timeSeriesQuery","requestId":"Q-b34b5ac7-c2d7-44fc-bc77-06570400a564-0A","utcOffsetSec":28800,"legendFormat":"","interval":"","datasourceId":34,"intervalMs":15000,"maxDataPoints":2512}],"range":{"from":"2023-04-23T02:40:33.146Z","to":"2023-04-23T03:10:33.146Z","raw":{"from":"now-30m","to":"now"}},"from":"1682217633146","to":"1682219433146"}`
// query metrics
bytes, err := ag.Query(ctx, addr, token, query, grafana.Options{})
if err != nil {
	return
}
log.Debug(string(bytes))