aggregate.rate() 函数
aggregate.rate() 是实验性的，并且随时可能更改。
aggregate.rate() 计算每个输入表每时间窗口的平均增长率。
aggregate.rate() 要求输入数据具有 _start 和 _stop 列，以计算要操作的时间窗口。使用 range() 分配 _start 和 _stop 值。
此函数旨在复制 Prometheus rate() 函数，并且应仅与 计数器 一起使用。
函数类型签名
(<-tables: stream[A], every: duration, ?groupColumns: [string], ?unit: duration) => stream[B] where A: Record, B: Record
有关更多信息，请参阅 函数类型签名。
参数
every
（必需）时间窗口的持续时间。
groupColumns
要分组的列的列表。默认为 []。
unit
计算速率时使用的时间长度。默认为 1s。
tables
输入数据。默认为管道转发数据 (<-)。
示例
计算数据中的平均变化率
import "experimental/aggregate"
import "sampledata"
data =
sampledata.int()
|> range(start: sampledata.start, stop: sampledata.stop)
data
|> aggregate.rate(every: 30s, unit: 1s, groupColumns: ["tag"])
此页面是否有帮助？
感谢您的反馈！