1. 创建链接


1.1 语法

• 语法
  

1. func NewClient(cfg Config) (Client, error)

复制代码

• 结构体
  

1. type Config struct {
   
2.     Address      string
   
3.     Client       *http.Client
   
4.     RoundTripper http.RoundTripper
   
5. }

复制代码

• 示例
  

1.         client, err = api.NewClient(api.Config{
   
2.                 Address: "http://10.10.182.112:9090",
   
3.         })

复制代码

1.2 完整示例

1. package mainimport (        "fmt"        "github.com/prometheus/client_golang/api")func CreatClient() (client api.Client, err error) {        client, err = api.NewClient(api.Config{
   
2.                 Address: "http://10.10.182.112:9090",
   
3.         })        if err != nil {                fmt.Printf("Error creating client: %v\n", err)                return nil, err        }        return client, nil}func main() {        client, err := CreatClient()        if err != nil {                fmt.Errorf("%+v", err)        }        if client != nil {                fmt.Println("client创建成功")        }}

复制代码

2. 简单查询


2.1 语法

• 创建API实例
  

1. func NewAPI(c Client) API

复制代码

• 查询
  

1. func (API) Query(ctx context.Context, query string, ts time.Time, opts ...Option) (Value, Warnings, error)

复制代码

• 在context中设置超时
  

1. func WithTimeout(parent Context, timeout time.Duration) (Context, CancelFunc)

复制代码

• 语法示例
  

1.         v1api := proV1.NewAPI(Client)
   
2.         ctx := context.Background()
   
3.         result, warnings, err := v1api.Query(ctx, "up", time.Now(), proV1.WithTimeout(5*time.Second))

复制代码

2.2 完整示例

1. package main
   
2. 
   
3. import (
   
4.         "context"
   
5.         "fmt"
   
6.         "github.com/prometheus/client_golang/api"
   
7.         proV1 "github.com/prometheus/client_golang/api/prometheus/v1"
   
8.         "github.com/prometheus/common/model"
   
9.         "time"
   
10. )
    
11. 
    
12. var Client api.Client
    
13. 
    
14. func init() {
    
15.         Client, _ = CreatClient()
    
16. }
    
17. 
    
18. func CreatClient() (client api.Client, err error) {
    
19.         client, err = api.NewClient(api.Config{
    
20.                 Address: "http://10.10.181.112:9090",
    
21.         })
    
22.         if err != nil {
    
23.                 fmt.Printf("Error creating client: %v\n", err)
    
24.                 return nil, err
    
25.         }
    
26.         return client, nil
    
27. }
    
28. 
    
29. func Query() (result model.Value, err error) {
    
30.         v1api := proV1.NewAPI(Client)
    
31.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    
32.         defer cancel()
    
33.         result, warnings, err := v1api.Query(ctx, "up", time.Now(), proV1.WithTimeout(5*time.Second))
    
34.         if err != nil {
    
35.                 return nil, err
    
36.         }
    
37.         if len(warnings) > 0 {
    
38.                 fmt.Printf("Warnings: %v\n", warnings)
    
39.         }
    
40.         return result, nil
    
41. }
    
42. 
    
43. func main() {
    
44.         result, err := Query()
    
45.         if err != nil {
    
46.                 fmt.Errorf("%q", err)
    
47.         }
    
48.         fmt.Printf("Result:\n%v\n", result)
    
49. }

复制代码

3. 范围值查询


3.1 语法

• 范围设置
  

1. type Range struct {
   
2.     Start, End time.Time
   
3.     Step       time.Duration
   
4. }

复制代码

语法示例

1.         r := proV1.Range{
   
2.                 Start: time.Now().Add(-time.Hour),
   
3.                 End:   time.Now(),
   
4.                 Step:  time.Minute,
   
5.         }

复制代码

• 范围查询
  

1. func (API) QueryRange(ctx context.Context, query string, r Range, opts ...Option) (Value, Warnings, error)

复制代码

语法示例

1. result, warnings, err := v1api.QueryRange(ctx, "rate(prometheus_tsdb_head_samples_appended_total[5m])", r, proV1.WithTimeout(5*time.Second))

复制代码

3.2 完整示例

1. package mainimport (        "context"        "fmt"        "github.com/prometheus/client_golang/api"        proV1 "github.com/prometheus/client_golang/api/prometheus/v1"        "github.com/prometheus/common/model"        "time")var Client api.Clientfunc init() {        Client, _ = CreatClient()}func CreatClient() (client api.Client, err error) {        client, err = api.NewClient(api.Config{                Address: "http://10.10.181.112:9090",        })        if err != nil {                fmt.Printf("Error creating client: %v\n", err)                return nil, err        }        return client, nil}func QueryRange() (result model.Value, err error) {        v1api := proV1.NewAPI(Client)        //ctx := context.Background()        ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)        r := proV1.Range{
   
2.                 Start: time.Now().Add(-time.Hour),
   
3.                 End:   time.Now(),
   
4.                 Step:  time.Minute,
   
5.         }        defer cancel()        result, warnings, err := v1api.QueryRange(ctx, "rate(prometheus_tsdb_head_samples_appended_total[5m])", r, proV1.WithTimeout(5*time.Second))        if err != nil {                return nil, err        }        if len(warnings) > 0 {                fmt.Printf("Warnings: %v\n", warnings)        }        return result, nil}func main() {        result, err := QueryRange()        if err != nil {                fmt.Errorf("%q", err)        }        fmt.Printf("Result:\n%v\n", result)}

复制代码

4. 获取指标名称和标签


4.1 语法

• 语法
  

1. func (API) Series(ctx context.Context, matches []string, startTime time.Time, endTime time.Time) ([]model.LabelSet, Warnings, error)

复制代码

• 语法示例
  

1.         lbls, warnings, err := v1api.Series(ctx, []string{
   
2.                 "{__name__=~".+",job="prometheus"}",
   
3.         }, time.Now().Add(-time.Hour), time.Now())

复制代码

说明：

• 数组里可以写多条
  
• 1. __name__

  复制代码
  表示指标名，等号后边支持正则匹配。
  
• 后边可以接一些label，同样支持正则。
  

比如示例中的

1. job="prometheus"

复制代码

，是我们在prometheus配置文件里写的job名。

• LabelSet
  

1. type LabelSet map[LabelName]LabelValue

复制代码

可以看到LabelSet实际是一个map，因此我们可以只打印示例中的指标名：

1.         for _, lbl := range lbls {
   
2.                 fmt.Println(lbl["__name__"])
   
3.         }

复制代码

4.1 完整示例（获取所有数据条目）

1. package main
   
2. 
   
3. import (
   
4.         "context"
   
5.         "fmt"
   
6.         "os"
   
7.         "time"
   
8. 
   
9.         "github.com/prometheus/client_golang/api"
   
10.         proV1 "github.com/prometheus/client_golang/api/prometheus/v1"
    
11. )
    
12. 
    
13. var Client api.Client
    
14. 
    
15. func init() {
    
16.         Client, _ = CreatClient()
    
17. }
    
18. 
    
19. func CreatClient() (client api.Client, err error) {
    
20.         client, err = api.NewClient(api.Config{
    
21.                 Address: "http://10.10.181.112:9090",
    
22.         })
    
23.         if err != nil {
    
24.                 fmt.Printf("Error creating client: %v\n", err)
    
25.                 return nil, err
    
26.         }
    
27.         return client, nil
    
28. }
    
29. 
    
30. func ExampleAPI_series() {
    
31.         v1api := proV1.NewAPI(Client)
    
32.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    
33.         defer cancel()
    
34.         lbls, warnings, err := v1api.Series(ctx, []string{
    
35.                 //"{__name__=~"scrape_.+",job="node"}",
    
36.                 "{__name__=~".+"}",
    
37.         }, time.Now().Add(-time.Hour), time.Now())
    
38.         if err != nil {
    
39.                 fmt.Printf("Error querying Prometheus: %v\n", err)
    
40.                 os.Exit(1)
    
41.         }
    
42.         if len(warnings) > 0 {
    
43.                 fmt.Printf("Warnings: %v\n", warnings)
    
44.         }
    
45.         fmt.Println("Result:", len(lbls))
    
46.         for _, lbl := range lbls {
    
47.                 //fmt.Println(lbl["__name__"])
    
48.                 fmt.Println(lbl)
    
49.         }
    
50. }
    
51. func main() {
    
52.         ExampleAPI_series()
    
53. }

复制代码

【附官方示例】

https://github.com/prometheus/client_golang/blob/main/api/prometheus/v1/example_test.go

1. package v1_test
   
2. 
   
3. import (
   
4.         "context"
   
5.         "fmt"
   
6.         "net/http"
   
7.         "os"
   
8.         "time"
   
9. 
   
10.         "github.com/prometheus/common/config"
    
11. 
    
12.         "github.com/prometheus/client_golang/api"
    
13.         v1 "github.com/prometheus/client_golang/api/prometheus/v1"
    
14. )
    
15. 
    
16. func ExampleAPI_query() {
    
17.         client, err := api.NewClient(api.Config{
    
18.                 Address: "http://demo.robustperception.io:9090",
    
19.         })
    
20.         if err != nil {
    
21.                 fmt.Printf("Error creating client: %v\n", err)
    
22.                 os.Exit(1)
    
23.         }
    
24. 
    
25.         v1api := v1.NewAPI(client)
    
26.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    
27.         defer cancel()
    
28.         result, warnings, err := v1api.Query(ctx, "up", time.Now(), v1.WithTimeout(5*time.Second))
    
29.         if err != nil {
    
30.                 fmt.Printf("Error querying Prometheus: %v\n", err)
    
31.                 os.Exit(1)
    
32.         }
    
33.         if len(warnings) > 0 {
    
34.                 fmt.Printf("Warnings: %v\n", warnings)
    
35.         }
    
36.         fmt.Printf("Result:\n%v\n", result)
    
37. }
    
38. 
    
39. func ExampleAPI_queryRange() {
    
40.         client, err := api.NewClient(api.Config{
    
41.                 Address: "http://demo.robustperception.io:9090",
    
42.         })
    
43.         if err != nil {
    
44.                 fmt.Printf("Error creating client: %v\n", err)
    
45.                 os.Exit(1)
    
46.         }
    
47. 
    
48.         v1api := v1.NewAPI(client)
    
49.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
    
50.         defer cancel()
    
51.         r := v1.Range{
    
52.                 Start: time.Now().Add(-time.Hour),
    
53.                 End:   time.Now(),
    
54.                 Step:  time.Minute,
    
55.         }
    
56.         result, warnings, err := v1api.QueryRange(ctx, "rate(prometheus_tsdb_head_samples_appended_total[5m])", r, v1.WithTimeout(5*time.Second))
    
57.         if err != nil {
    
58.                 fmt.Printf("Error querying Prometheus: %v\n", err)
    
59.                 os.Exit(1)
    
60.         }
    
61.         if len(warnings) > 0 {
    
62.                 fmt.Printf("Warnings: %v\n", warnings)
    
63.         }
    
64.         fmt.Printf("Result:\n%v\n", result)
    
65. }
    
66. 
    
67. type userAgentRoundTripper struct {
    
68.         name string
    
69.         rt   http.RoundTripper
    
70. }
    
71. 
    
72. // RoundTrip implements the http.RoundTripper interface.
    
73. func (u userAgentRoundTripper) RoundTrip(r *http.Request) (*http.Response, error) {
    
74.         if r.UserAgent() == "" {
    
75.                 // The specification of http.RoundTripper says that it shouldn't mutate
    
76.                 // the request so make a copy of req.Header since this is all that is
    
77.                 // modified.
    
78.                 r2 := new(http.Request)
    
79.                 *r2 = *r
    
80.                 r2.Header = make(http.Header)
    
81.                 for k, s := range r.Header {
    
82.                         r2.Header[k] = s
    
83.                 }
    
84.                 r2.Header.Set("User-Agent", u.name)
    
85.                 r = r2
    
86.         }
    
87.         return u.rt.RoundTrip(r)
    
88. }
    
89. 
    
90. func ExampleAPI_queryRangeWithUserAgent() {
    
91.         client, err := api.NewClient(api.Config{
    
92.                 Address:      "http://demo.robustperception.io:9090",
    
93.                 RoundTripper: userAgentRoundTripper{name: "Client-Golang", rt: api.DefaultRoundTripper},
    
94.         })
    
95.         if err != nil {
    
96.                 fmt.Printf("Error creating client: %v\n", err)
    
97.                 os.Exit(1)
    
98.         }
    
99. 
    
100.         v1api := v1.NewAPI(client)
     
101.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
     
102.         defer cancel()
     
103.         r := v1.Range{
     
104.                 Start: time.Now().Add(-time.Hour),
     
105.                 End:   time.Now(),
     
106.                 Step:  time.Minute,
     
107.         }
     
108.         result, warnings, err := v1api.QueryRange(ctx, "rate(prometheus_tsdb_head_samples_appended_total[5m])", r)
     
109.         if err != nil {
     
110.                 fmt.Printf("Error querying Prometheus: %v\n", err)
     
111.                 os.Exit(1)
     
112.         }
     
113.         if len(warnings) > 0 {
     
114.                 fmt.Printf("Warnings: %v\n", warnings)
     
115.         }
     
116.         fmt.Printf("Result:\n%v\n", result)
     
117. }
     
118. 
     
119. func ExampleAPI_queryRangeWithBasicAuth() {
     
120.         client, err := api.NewClient(api.Config{
     
121.                 Address: "http://demo.robustperception.io:9090",
     
122.                 // We can use amazing github.com/prometheus/common/config helper!
     
123.                 RoundTripper: config.NewBasicAuthRoundTripper("me", "defintely_me", "", api.DefaultRoundTripper),
     
124.         })
     
125.         if err != nil {
     
126.                 fmt.Printf("Error creating client: %v\n", err)
     
127.                 os.Exit(1)
     
128.         }
     
129. 
     
130.         v1api := v1.NewAPI(client)
     
131.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
     
132.         defer cancel()
     
133.         r := v1.Range{
     
134.                 Start: time.Now().Add(-time.Hour),
     
135.                 End:   time.Now(),
     
136.                 Step:  time.Minute,
     
137.         }
     
138.         result, warnings, err := v1api.QueryRange(ctx, "rate(prometheus_tsdb_head_samples_appended_total[5m])", r)
     
139.         if err != nil {
     
140.                 fmt.Printf("Error querying Prometheus: %v\n", err)
     
141.                 os.Exit(1)
     
142.         }
     
143.         if len(warnings) > 0 {
     
144.                 fmt.Printf("Warnings: %v\n", warnings)
     
145.         }
     
146.         fmt.Printf("Result:\n%v\n", result)
     
147. }
     
148. 
     
149. func ExampleAPI_queryRangeWithAuthBearerToken() {
     
150.         client, err := api.NewClient(api.Config{
     
151.                 Address: "http://demo.robustperception.io:9090",
     
152.                 // We can use amazing github.com/prometheus/common/config helper!
     
153.                 RoundTripper: config.NewAuthorizationCredentialsRoundTripper("Bearer", "secret_token", api.DefaultRoundTripper),
     
154.         })
     
155.         if err != nil {
     
156.                 fmt.Printf("Error creating client: %v\n", err)
     
157.                 os.Exit(1)
     
158.         }
     
159. 
     
160.         v1api := v1.NewAPI(client)
     
161.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
     
162.         defer cancel()
     
163.         r := v1.Range{
     
164.                 Start: time.Now().Add(-time.Hour),
     
165.                 End:   time.Now(),
     
166.                 Step:  time.Minute,
     
167.         }
     
168.         result, warnings, err := v1api.QueryRange(ctx, "rate(prometheus_tsdb_head_samples_appended_total[5m])", r)
     
169.         if err != nil {
     
170.                 fmt.Printf("Error querying Prometheus: %v\n", err)
     
171.                 os.Exit(1)
     
172.         }
     
173.         if len(warnings) > 0 {
     
174.                 fmt.Printf("Warnings: %v\n", warnings)
     
175.         }
     
176.         fmt.Printf("Result:\n%v\n", result)
     
177. }
     
178. 
     
179. func ExampleAPI_series() {
     
180.         client, err := api.NewClient(api.Config{
     
181.                 Address: "http://demo.robustperception.io:9090",
     
182.         })
     
183.         if err != nil {
     
184.                 fmt.Printf("Error creating client: %v\n", err)
     
185.                 os.Exit(1)
     
186.         }
     
187. 
     
188.         v1api := v1.NewAPI(client)
     
189.         ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
     
190.         defer cancel()
     
191.         lbls, warnings, err := v1api.Series(ctx, []string{
     
192.                 "{__name__=~"scrape_.+",job="node"}",
     
193.                 "{__name__=~"scrape_.+",job="prometheus"}",
     
194.         }, time.Now().Add(-time.Hour), time.Now())
     
195.         if err != nil {
     
196.                 fmt.Printf("Error querying Prometheus: %v\n", err)
     
197.                 os.Exit(1)
     
198.         }
     
199.         if len(warnings) > 0 {
     
200.                 fmt.Printf("Warnings: %v\n", warnings)
     
201.         }
     
202.         fmt.Println("Result:")
     
203.         for _, lbl := range lbls {
     
204.                 fmt.Println(lbl)
     
205.         }
     
206. }

复制代码

到此这篇关于golang获取prometheus数据(prometheus/client_golang包)的文章就介绍到这了,更多相关golang获取prometheus内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

来源：互联网
免责声明：如果侵犯了您的权益，请联系站长（1277306191@qq.com），我们会及时删除侵权内容，谢谢合作！