卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章34127本站已运行391

如何以编程方式为 Prometheus 创建 tsdb wal 或块

如何以编程方式为 prometheus 创建 tsdb wal 或块

问题内容

我需要为 Prometheus 生成示例数据,并尝试创建一个脚本来以编程方式创建 tsdb 块。在 ChatGPT 的帮助下,我编写了这段代码,它创建了 Prometheus 接受的 WAL 块,甚至创建了自动完成检测到的系列名称,但我没有看到任何值,为什么?

package main

import (
    "context"
    "fmt"
    "github.com/prometheus/prometheus/model/labels"
    "github.com/prometheus/prometheus/storage"
    "github.com/prometheus/prometheus/tsdb"
    "os"
    "time"
)

func main() {
    // Create a new TSDB instance
    db, err := tsdb.Open(
        "./data", // directory where the data will be stored
        nil,      // a logger (can be nil for no logging)
        nil,      // an optional prometheus.Registerer
        tsdb.DefaultOptions(),
        nil,
    )
    if err != nil {
        fmt.Println("Error opening TSDB:", err)
        os.Exit(1)
    }
    defer db.Close()

    // Create a new appender
    app := db.Appender(context.Background())

    // Create labels for the gauge time series
    lbls := labels.FromStrings("__name__", "example_gauge", "type", "gauge")

    // Initialize a SeriesRef
    var ref storage.SeriesRef

    // Add some data points
    for i := 0; i < 10; i++ {
        var err error
        ref, err = app.Append(ref, lbls, time.Now().Unix()+int64(i), float64(i))
        if err != nil {
            fmt.Println("Error appending:", err)
            os.Exit(1)
        }
    }

    // Commit the data
    err = app.Commit()
    if err != nil {
        fmt.Println("Error committing:", err)
        os.Exit(1)
    }
}


正确答案


好的,上面的代码可以工作,唯一的问题是我需要以毫秒为单位传递时间,而 time.Now().Unix() 以秒为单位返回它,因此您需要将其乘以 1000,因此进行更改这行会给你结果:

来自:

ref, err = app.Append(ref, lbls, time.Now().Unix()+int64(i), float64(i))

至:

ref, err = app.Append(ref, lbls, (time.Now().Unix()+int64(i)) * 1000, float64(i))
卓越飞翔博客
上一篇: 如何从 golang 中导入的包接收的结构中删除某些项目?
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏