From fb620c15e7d2c342294054b8cb50b9ca6654d5c9 Mon Sep 17 00:00:00 2001 From: VVT789 <sdxt_0802@163.com> Date: 星期二, 04 三月 2025 11:55:23 +0800 Subject: [PATCH] 时序库查询修改 --- zhitan-system/src/main/java/com/zhitan/realtimedata/data/influxdb/InfluxDBRepository.java | 2 +- 1 files changed, 1 insertions(+), 1 deletions(-) diff --git a/zhitan-system/src/main/java/com/zhitan/realtimedata/data/influxdb/InfluxDBRepository.java b/zhitan-system/src/main/java/com/zhitan/realtimedata/data/influxdb/InfluxDBRepository.java index fd11822..38f70ea 100644 --- a/zhitan-system/src/main/java/com/zhitan/realtimedata/data/influxdb/InfluxDBRepository.java +++ b/zhitan-system/src/main/java/com/zhitan/realtimedata/data/influxdb/InfluxDBRepository.java @@ -147,7 +147,7 @@ StringBuilder fluxSql = new StringBuilder(); fluxSql.append("from(bucket: \"").append(config.getBucket()).append("\")") .append(timeRange).append("|> filter(fn: (r) => r[\"_measurement\"] == \"") - .append("meilin\")"); + .append(config.getMeasurement()).append(")"); fluxSql.append("|> filter(fn: (r) => r[\"_field\"] == \"value\")"); if (!tagCodes.isEmpty()) { fluxSql.append("|> filter(fn: (r) => r[\"tag\"] =~ /"); -- Gitblit v1.9.3