应使用Flux，因其支持多列差值、空值容错、分组兼容及nonNegative等关键参数；InfluxQL的DIFFERENCE()功能受限且易出错。
差值计算该用InfluxQL还是Flux？
InfluxDB 2.x 默认禁用 InfluxQL，Flux 是官方主推的查询语言，所有新特性（包括稳定可靠的差值计算）都优先在 Flux 中实现。InfluxQL 的 DIFFERENCE() 函数仅支持单字段、无分组、无空值容错，遇到 null 或跨 tag 分组时直接中断返回空结果——这不是 bug，是设计限制。
- Flux 的
difference()函数支持columns指定多列、nonNegative过滤负值、keepFirst保留首行，且与group()、aggregateWindow()天然兼容 - 若强制用 InfluxQL，必须确保数据严格按时间升序、无缺失、无重复时间戳，否则
DIFFERENCE()输出不可信 - 迁移建议：哪怕你用的是 InfluxDB 2.x 的 InfluxQL 兼容层，也应默认切到 Flux 查询端点
/api/v2/query?org=xxx
Flux 中正确调用 difference() 的三个关键参数
Flux 的 difference() 看似简单，但漏设参数会导致静默错误：比如没加 nonNegative: true，负值差分会污染后续求均值；不设 columns: ["_value"]，它会对所有数值列（含 _start、_stop）都算差，触发类型错误。
- 必须显式指定
columns: ["_value"]，避免误操作元数据列 - 时间乱序数据要先
|> sort(columns: ["_time"])，否则difference()按流式顺序计算，结果错位 - 若需每小时差值（如传感器累计计数清零重置），加
nonNegative: false并配合map()修复跳变：|> map(fn: (r) => ({ r with _value: if r._value < 0 then r._value + 4294967296 else r._value }))
Go 客户端执行 Flux 查询并解析差值结果
Go 用 influxdb-client-go v2 时，别直接拼接字符串发 Flux 脚本——变量注入不处理转义，特殊字符（如 tag 值含空格或单引号）会导致语法错误。应使用 QueryAPI.Query() 配合 query.NewQuery() 构造安全请求。
- Flux 脚本中所有动态值（如 bucket 名、measurement、tag key）必须用
${v}占位符，再通过query.WithParameter()注入，例如：from(bucket: "${bucket}") |> range(start: ${start}) |> filter(fn: (r) => r._measurement == "${measurement}") |> difference(columns: ["_value"], nonNegative: true) - 返回的
flux.Table需遍历Table.Record()，Record.ValueByKey("_value")才是差值结果；直接读Record.Values()会混入索引和元数据 - 注意时区：Go 的
time.Time默认 UTC，若 Flux 中用了timezone: "Asia/Shanghai"，客户端解析_time字段时需用time.LoadLocation("Asia/Shanghai")，否则时间戳偏移
差值为 null 的常见原因和绕过方法
Flux 的 difference() 对首行永远输出 null（因无前值可减），这本身合理，但常被当成数据异常。更隐蔽的问题是：当 group key 变化（如从 host=A 切到 host=B）时，difference() 不重置计数器，而是延续上一组最后值计算，导致跨组差值失真。
立即学习“go语言免费学习笔记（深入）”；
- 解决首行 null：用
|> drop(columns: ["_value"]) |> fill(column: "_value", value: 0.0)替换，或前端过滤r.Record.ValueByKey("_value") != nil - 防跨组污染：必须在
difference()前显式|> group(columns: ["host", "region"])，且确保 group key 包含所有区分维度 - 若原始数据有采样空洞（如某分钟无上报），
aggregateWindow(every: 1m, fn: last)再差值，比直接对原始流差值更鲁棒
Flux 差值逻辑依赖数据流的连续性，而真实物联网场景里断连、重传、时钟漂移都会破坏它——别指望一个 difference() 调用解决所有问题，得结合业务规则做二次校验。
