如何通过代码创建Prometheus TSDB WAL/Block？代码生成WAL却无数据值

核心原因1：时间戳单位不匹配 #

Prometheus TSDB的Append方法要求传入毫秒级时间戳，但你的代码中使用了time.Now().Unix()（秒级时间戳），这导致所有数据点的时间被标记为当前时间的1/1000——相当于几十年前的历史数据，而Prometheus默认查询范围（比如最近15分钟）根本覆盖不到这些数据，所以看不到值。

核心原因2：未确保数据持久化为可查询的Block #

通过Appender提交的数据会先写入WAL（预写日志），但要生成Prometheus可直接查询的TSDB Block，需要触发compaction（压缩）。程序运行后立即退出的话，后台压缩流程可能还没来得及执行，导致数据只在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() {
    // 创建TSDB实例
    db, err := tsdb.Open(
        "./data",
        nil,
        nil,
        tsdb.DefaultOptions(),
        nil,
    )
    if err != nil {
        fmt.Println("打开TSDB失败:", err)
        os.Exit(1)
    }
    defer db.Close()

    app := db.Appender(context.Background())
    lbls := labels.FromStrings("__name__", "example_gauge", "type", "gauge")
    var ref storage.SeriesRef

    // 使用毫秒级时间戳，每个数据点间隔1秒
    baseTime := time.Now().UnixMilli()
    for i := 0; i < 10; i++ {
        var err error
        ref, err = app.Append(ref, lbls, baseTime+int64(i)*1000, float64(i))
        if err != nil {
            fmt.Println("写入数据失败:", err)
            os.Exit(1)
        }
    }

    // 提交数据到WAL
    if err := app.Commit(); err != nil {
        fmt.Println("提交数据失败:", err)
        os.Exit(1)
    }

    // 主动触发压缩，将WAL中的数据生成可查询的Block
    if err := db.Compact(context.Background(), time.Now().UnixMilli()); err != nil {
        fmt.Println("压缩数据失败:", err)
        os.Exit(1)
    }

    fmt.Println("数据生成完成")
}

验证步骤 #

1. 运行修复后的代码，生成./data目录
2. 将该目录配置为Prometheus的tsdb.path，启动Prometheus
3. 查询example_gauge，即可看到10个连续的数据点（值从0到9，间隔1秒）

内容的提问来源于stack exchange，提问作者Anatoly