文档文档

timedMovingAverage() 函数

timedMovingAverage() 返回在指定频率下定义的时​​间范围内值的平均值。

对于表中的每一行,timedMovingAverage() 返回当前值和前一个period(持续时间)中所有行值的平均值。它以 every 参数定义的频率返回移动平均值。

按日历月和年聚合

everyperiod 参数支持所有有效的持续时间单位,包括日历月 (1mo) 和年 (1y)。

按周聚合

当按周 (1w) 聚合时,周是使用 Unix 纪元(1970-01-01T00:00:00Z UTC)确定的。Unix 纪元是星期四,因此所有计算的周都从星期四开始。

函数类型签名
(<-tables: stream[A], every: duration, period: duration, ?column: string) => stream[B] where A: Record, B: Record

有关更多信息,请参阅函数类型签名

参数

every

(必需) 时间窗口的频率。

period

(必需) 每个平均时间窗口的长度。

负持续时间表示开始和停止边界已反转。

column

要操作的列。默认为 _value

tables

输入数据。默认为管道转发数据 (<-)。

示例

计算每年的五年移动平均值

data
    |> timedMovingAverage(every: 1y, period: 5y)

查看示例输入和输出


此页对您有帮助吗?

感谢您的反馈!


Flux 的未来

Flux 即将进入维护模式。您可以继续像现在这样使用它,而无需对您的代码进行任何更改。

阅读更多

现已全面上市

InfluxDB 3 Core 和 Enterprise

快速启动。更快扩展。

获取更新

InfluxDB 3 Core 是一个开源、高速、近实时数据引擎,可实时收集和处理数据,并将其持久化到本地磁盘或对象存储。InfluxDB 3 Enterprise 构建于 Core 的基础上,增加了高可用性、读取副本、增强的安全性以及数据压缩,从而实现更快的查询和优化的存储。InfluxDB 3 Enterprise 的免费层可供非商业家用或业余爱好者使用。

欲了解更多信息,请查看