СФ
Переслано от Степа Фомичев...
from(bucket: "${database}")
|> range(start: ${firstTestStartTime}, stop: ${firstTestEndTime})
|> filter(fn: (r) => r._measurement == "${measurement}")
|> filter(fn: (r) => r.testId == "${test_1}")
|> filter(fn: (r) =>
r._field == "endedT" or
r._field == "startedT")
|> aggregateWindow(every: ${aggregation_interval}s, fn: mean)
|> fill(value: 0.0)
|> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
|> map(fn: (r) => ({
_value: (r.startedT - r.endedT), _time:r._time, _field: "Test", testId: "#" + r.testId
}))
|> timeShift(duration: ${timeshift}ms)
|> range(start: ${firstTestStartTime}, stop: ${firstTestEndTime})
|> filter(fn: (r) => r._measurement == "${measurement}")
|> filter(fn: (r) => r.testId == "${test_1}")
|> filter(fn: (r) =>
r._field == "endedT" or
r._field == "startedT")
|> aggregateWindow(every: ${aggregation_interval}s, fn: mean)
|> fill(value: 0.0)
|> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
|> map(fn: (r) => ({
_value: (r.startedT - r.endedT), _time:r._time, _field: "Test", testId: "#" + r.testId
}))
|> timeShift(duration: ${timeshift}ms)