From 23182f2c951df5fa55e70e30ff70ddaf91199a2e Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期四, 05 二月 2026 15:57:58 +0800
Subject: [PATCH] 1
---
component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java | 5 ++---
1 files changed, 2 insertions(+), 3 deletions(-)
diff --git a/component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java b/component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
similarity index 94%
rename from component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java
rename to component/component-Influxdb/src/main/java/com/zy/component/influxdb/service/InfluxDBService.java
index df7edff..c3f5ad4 100644
--- a/component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java
+++ b/component/component-Influxdb/src/main/java/com/zy/component/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;
@@ -41,7 +40,6 @@
.setTimestamp(Instant.now().toEpochMilli(), WritePrecision.MS);
try {
influxDBClient.writePoint(point);
- System.out.println("Data written to the database.");
} catch (Exception e) {
logger.error("Failed to write data to the database.");
e.printStackTrace();
@@ -58,6 +56,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<>();
--
Gitblit v1.9.1