1

zhang

1 天以前 d35e2accdca4b3762359231f4fe479c9538b6f6f

 component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java

File was renamed from component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java
@@ -1,9 +1,8 @@
package com.zy.influxdb.service;
package com.zy.component.influxdb.service;

import com.influxdb.v3.client.InfluxDBClient;
import com.influxdb.v3.client.Point;
import com.influxdb.v3.client.write.WritePrecision;
import lombok.extern.slf4j.Slf4j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
@@ -58,6 +57,7 @@
        try {
            // 执行查询
            Stream<Object[]> query = influxDBClient.query(sql);
            logger.info("查询数据：{}", query);
            // 转换为 Map 列表（便于后续处理）
            List<Map<String, Object>> collect = query.map(record -> {
                        Map<String, Object> map = new LinkedHashMap<>();