必须用QueryAPI.Query()配合Flux的range()函数指定时间范围，不能用InfluxQL的WHERE time > ...；range(start: -1h)查最近1小时，需搭配filter()限定measurement以防性能问题。
用 InfluxDB 2.x 的 Go 客户端查时间范围数据
直接结论：必须用 QueryAPI.Query() 配合 Flux 查询语句，不能用 SQL 风格语法；InfluxDB 2.x 不支持 WHERE time > ... 这类 InfluxQL 写法，硬写会返回空结果或报错 error: type error。
Flux 查询语句里怎么写时间范围
Flux 中时间过滤靠 range() 函数，不是 WHERE 或 BETWEEN。它接收两个参数：start 和可选的 stop，单位是 duration（如 -1h）或绝对时间（如 2024-01-01T00:00:00Z）。
常见写法：
-
range(start: -1h)：查最近 1 小时 -
range(start: "2024-01-01T00:00:00Z", stop: "2024-01-01T01:00:00Z")：查固定时间段（注意必须带Z或时区偏移） -
range(start: -2h, stop: -1h)：查倒数第二小时，适合做环比
别漏掉 |> filter(fn: (r) => r._measurement == "cpu")，否则 range() 会返回所有 measurement 的数据，性能差且容易超内存。
Go 代码里怎么传 Flux 查询并解析结果
关键点：用 QueryAPI.Query() 返回 flux.TableIterator，逐行读取；不能直接 JSON.Unmarshal 响应体——InfluxDB 返回的是多行 Flux 表格式文本（类似 CSV+元数据），客户端已封装好解析逻辑。
典型错误：
- 把
QueryAPI.QueryRaw()当成普通 HTTP 响应处理，结果得到一堆乱序的表头和值 - 没调用
table.Next()就直接table.Record()，panic 报record is nil - 忽略
r.ValueByKey("_value")可能是nil（比如字段不存在或类型不匹配）
最小可用片段：
query := `from(bucket: "mydb")
|> range(start: -1h)
|> filter(fn: (r) => r._measurement == "temperature" and r.location == "room1")
|> keep(columns: ["_time", "_value"])`
iter, err := queryAPI.Query(ctx, query)
if err != nil {
log.Fatal(err)
}
for iter.Next() {
table := iter.Table()
for table.Next() {
r := table.Record()
t := r.Time()
v := r.ValueByKey("_value")
if v != nil {
fmt.Printf("%v: %v\n", t, v)
}
}
}
if err = iter.Err(); err != nil {
log.Fatal(err)
}
时区、精度和性能要注意什么
InfluxDB 默认用 UTC 存储时间，_time 字段也是 UTC。如果你按本地时间构造 start/stop 字符串但没加时区，比如写 "2024-01-01 00:00:00"，Flux 会当成 UTC 解析，导致查错窗口。
另外，range() 的 start 越靠前，扫描的数据块越多；避免用 range(start: -7d) 查全量再 filter()，应尽量让 filter() 靠前，或用 aggregateWindow() 降采样。
还有个隐蔽坑：InfluxDB 2.7+ 对超长查询默认限流，如果 range() 跨度太大又没加 limit()，可能只返回前 1 万行就断开，且不报错——得手动加 |> limit(n: 50000) 并检查 iter.More()。
golang免费学习笔记（深入）：立即使用
在学习笔记中，你将探索golang的核心概念和高级技巧！
