数据断面聚合

[maikebing]

需求
一天内 一万条数据， 整合成一小时一条， 使用平均的方法， 或者每个小时的最后一条作为依据。
Task<List> LoadTelemetryAsync(Guid deviceId, string keys, DateTime begin, DateTime end, TimeSpan every, Aggregate aggregate);

注意
keys 为空则表示全部，
every 如果是 TimeSpan.Zero表示不适用。aggregate 也不会使用。

• EFStorage 数据聚合 #802
• TimescaleDBStorage 数据聚合 #803
• ShardingStorage 数据聚合。 #804
• InfluxDBStorage 已实现。
• PinusDBStorage 数据聚合 #805
• TaosStorage 数据聚合 #806
• IoTDB 已实现

[maikebing]

InfluxDB 中的语法。

from(bucket: "iotsharp")
  |> range(start: v.timeRangeStart, stop: v.timeRangeStop)
  |> filter(fn: (r) => r["_measurement"] == "TelemetryData")
  |> filter(fn: (r) => r["DeviceId"] == "52958d0c-c462-4644-b91f-a0c4587f898e")
  |> filter(fn: (r) => r["_field"] == "humidity")
  |> aggregateWindow(every: 15m, fn: mean, createEmpty: false)
  |> yield(name: "mean")

[maikebing]

下图中， 是每小时 一条是数据。

[maikebing]

IoTDB 已经实现。
#726

[maikebing]

修复跟 InfluxDB有关的bug #770

[iotbi]

TimescaleDB实现了么

[maikebing]

TimescaleDB 没实现呢。