我需要为 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))