Add debug output for influx data-points

Freifunk-Dresden · Dec 30, 2024 · 02f5a69 · 02f5a69
1 parent 9a8575b
commit 02f5a69
Showing 1 changed file with 13 additions and 0 deletions.
diff --git a/src/main/java/de/freifunkdresden/viewerbackend/Influx.java b/src/main/java/de/freifunkdresden/viewerbackend/Influx.java
@@ -25,6 +25,9 @@
 package de.freifunkdresden.viewerbackend;
 
 import de.freifunkdresden.viewerbackend.exception.DatabaseConnectionException;
+import org.apache.logging.log4j.Level;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 import org.influxdb.InfluxDB;
 import org.influxdb.InfluxDBFactory;
 import org.influxdb.dto.BatchPoints;
@@ -34,6 +37,8 @@
 
 public class Influx {
 
+    private static final Logger LOGGER = LogManager.getLogger(Influx.class);
+
     private final String url;
     private final String username;
     private final String password;
@@ -68,6 +73,9 @@ public void checkConnection() {
     }
 
     public void write(Point p) {
+        if (DataGen.isDebug()) {
+            LOGGER.log(Level.DEBUG, "[Influx] Write Point: {}", p);
+        }
         if (DataGen.isReadOnly()) {
             return;
         }
@@ -76,6 +84,11 @@ public void write(Point p) {
     }
 
     public void write(Collection<Point> points) {
+        if (DataGen.isDebug()) {
+            for (Point p : points) {
+                LOGGER.log(Level.DEBUG, "[Influx] Write Multi-Point: {}", p);
+            }
+        }
         if (DataGen.isReadOnly()) {
             return;
         }