From 33cf36a06ccadf96fb2486ed8e5a1aa5dd6ed664 Mon Sep 17 00:00:00 2001
From: zhang <zc857179121@qq.com>
Date: 星期五, 30 一月 2026 16:31:57 +0800
Subject: [PATCH] 1
---
component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java | 32 +++++++++++++++++---------------
1 files changed, 17 insertions(+), 15 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/influxdb/service/InfluxDBService.java
index c450804..df7edff 100644
--- a/component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java
+++ b/component/component-Influxdb/src/main/java/com/zy/influxdb/service/InfluxDBService.java
@@ -2,8 +2,11 @@
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;
import org.springframework.stereotype.Service;
import java.time.Instant;
@@ -15,45 +18,43 @@
@Service
-public class InfluxDBService {
+public class InfluxDBService {
private static final Logger logger = LoggerFactory.getLogger(InfluxDBService.class);
- private final InfluxDBClient influxDBClient;
+ @Autowired
+ private InfluxDBClient influxDBClient;
- // 鏋勯�犲嚱鏁版敞鍏ュ鎴风
- public InfluxDBService(InfluxDBClient influxDBClient ) {
- this.influxDBClient = influxDBClient ;
- }
/**
* 鍐欏叆鏁版嵁
+ *
* @param measurement 琛ㄥ悕
- * @param tags 鏍囩
- * @param fields 瀛楁
+ * @param tags 鏍囩
+ * @param fields 瀛楁
*/
- public void writeData(String measurement, Map<String,String> tags,Map<String,Object> fields) {
+ public void writeData(String measurement, Map<String, String> tags, Map<String, Object> fields) {
Point point = Point.measurement(measurement)
.setTags(tags)
.setFields(fields)
- .setTimestamp(Instant.now().minusSeconds(10));
+ .setTimestamp(Instant.now().toEpochMilli(), WritePrecision.MS);
try {
influxDBClient.writePoint(point);
System.out.println("Data written to the database.");
- }
- catch (Exception e) {
- System.err.println("Failed to write data to the database.");
+ } catch (Exception e) {
+ logger.error("Failed to write data to the database.");
e.printStackTrace();
}
}
+
/**
* 鏌ヨ鏁版嵁
+ *
* @param sql sql璇彞
* @return 鏌ヨ缁撴灉鍒楄〃
*/
public List<Map<String, Object>> queryData(String sql) {
-
try {
// 鎵ц鏌ヨ
Stream<Object[]> query = influxDBClient.query(sql);
@@ -68,10 +69,11 @@
.collect(Collectors.toList());
return collect;
} catch (Exception e) {
- System.err.println("Failed to query data from the database.");
+ logger.error("Failed to query data from the database.");
e.printStackTrace();
}
return null;
}
+
}
--
Gitblit v1.9.1