У тебя же есть поле, по которому можно понять какой это генератор?

А вы group by какие-нибудь делаете?

Апликейшен

submit нажал?)

Вот тут на графике его видно, навёл курсор

Конечно)

SELECT sum("AT") as "sum"
FROM (
 SELECT (last("startedT") - last("endedT")) as "AT"
 FROM "$measurement_name"
 WHERE ("transaction" = 'internal'
 AND "testId" =~ /^$test_id$/
 AND $timeFilter)
 GROUP BY time(${aggregation_interval}s), "location"
 fill(null))
WHERE $timeFilter
GROUP BY time(${aggregation_interval}s)

тебе не нужен aggregatewindow

Вместо location тут свой application положи

flux же мсье)

Точняк, попробую на флаксе найти сейчас

я может не догоняю зачем тут группировки? нам нужна одна линияя всех юзеров. чтобы склеить в одну таблицу делаем
|> group()
чтобы посчитать сумму за период можно сделать так
|> aggregateWindow(every: 5s, fn: sum, createEmpty: false)

Ты тогда потеряешь значения со всех лоад станций кроме одной

либо
|> group(columns: ["_time"])
|> sum()

from(bucket: "${measurement}")
|> range(start: ${firstTestStartTime}, stop: ${firstTestEndTime})
|> filter(fn: (r) =>
r._measurement == "${measurement}" and
r.location =~ /${location:regex}/
)
|> filter(fn: (r) =>
r._field == "endedT" or
r._field == "startedT"
)
|> aggregateWindow(every: ${aggregation_interval}s, fn: last)
|> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
|> map(fn: (r) => ({
_value: (r.startedT - r.endedT), _time:r._time
}))
|> aggregateWindow(every: ${aggregation_interval}s, fn: sum)

почему? сумма же по всем велью внутри 5 сек

таймшифт только надо убрать

Поправил)

локейшн убери еще)

Я, кстати, не уверен что смогу скоро уже по Флакс помогать, все наработки сейчас потерял и вряд ли в ближайшее время будет возможность с ним поработать