Klagarge/MSE-SoftwEng
1
0
Fork 0
Code Issues Pull Requests Releases Activity

fix(gateway): added limit 100 last measurements

Browse Source 
Closes: #26
Signed-off-by: Klagarge <remi@heredero.ch>
This commit is contained in:
Rémi Heredero
2025-05-05 20:45:08 +02:00
parent 75b6c10c94
commit 5f3aa98794
1 changed files with 2 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
gateway/src/RequestInflux.go
View File

@@ -68,6 +68,8 @@ func (gh *Gateway) requestInflux(c *gin.Context) error {
|> filter(fn: (r) => r["user"] == %q) |> filter(fn: (r) => r["user"] == %q)
|> filter(fn: (r) => r["room"] == %q) |> filter(fn: (r) => r["room"] == %q)
|> filter(fn: (r) => r["device"] == %q) |> filter(fn: (r) => r["device"] == %q)
|> sort(columns: ["_time"], desc: true)
|> limit(n: 100)
`, INFLUXDB_BUCKET, MEASUREMENT_NAME, user, room, device) `, INFLUXDB_BUCKET, MEASUREMENT_NAME, user, room, device)
results, err := queryAPI.Query(context.Background(), query) results, err := queryAPI.Query(context.Background(), query)
if err != nil { if err != nil {