wip: selecting data from InfluxDB

ODZ-UJF-AV-CR · Jan 26, 2025 · 7013035 · 7013035
1 parent fd7b1d0
commit 7013035
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/GAPP/apps/gapp-server/src/services/cars.service.ts b/GAPP/apps/gapp-server/src/services/cars.service.ts
@@ -35,10 +35,10 @@ export class CarsService extends InfluxDbServiceBase {
     public async getCarsStatus(callsigns: string[]) {
         console.log(callsigns);
         const query = `from(bucket: "cars")
-        |> range(start: -48h)
-        |> filter(fn: (r) => r._measurement == "car_status")
-        |> filter(fn: (r) => [${callsigns}].includes(r.callsign))
-        |> last()`;
+            |> range(start: -24h)
+            |> last()
+            |> pivot(rowKey:["_time"], columnKey: ["_field"], valueColumn: "_value")
+            |> keep(columns: ["_time", "altitude", "longitude", "latitude", "callsign"])`;
 
         const data = await this.queryAPi.collectRows(query);