MinecraftUtilities/Backend
2
1
Fork 1
Code Issues 1 Pull Requests 3 Actions Activity

bulk write influx points
All checks were successful
Deploy App / docker (ubuntu-latest, 2.44.0, 17, 3.8.5) (push) Successful in 1m55s
Details

Browse Source
This commit is contained in:
Lee 2024-04-17 00:04:14 +01:00
parent 08be02ff73
commit be40a981fe
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/main/java/xyz/mcutils/backend/service/MetricService.java
View File

@ -1,6 +1,7 @@
package xyz.mcutils.backend.service; package xyz.mcutils.backend.service;
import com.influxdb.client.WriteApiBlocking; import com.influxdb.client.WriteApiBlocking;
import com.influxdb.client.write.Point;
import com.influxdb.spring.influx.InfluxDB2AutoConfiguration; import com.influxdb.spring.influx.InfluxDB2AutoConfiguration;
import lombok.extern.log4j.Log4j2; import lombok.extern.log4j.Log4j2;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
@ -11,7 +12,9 @@ import xyz.mcutils.backend.service.metric.Metric;
import xyz.mcutils.backend.service.metric.metrics.RequestsPerRouteMetric; import xyz.mcutils.backend.service.metric.metrics.RequestsPerRouteMetric;
import xyz.mcutils.backend.service.metric.metrics.TotalRequestsMetric; import xyz.mcutils.backend.service.metric.metrics.TotalRequestsMetric;
import java.util.ArrayList;
import java.util.HashMap; import java.util.HashMap;
import java.util.List;
import java.util.Map; import java.util.Map;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
@ -108,9 +111,11 @@ public class MetricService {
* Push all metrics to InfluxDB. * Push all metrics to InfluxDB.
*/ */
private void writeToInflux() { private void writeToInflux() {
List<Point> points = new ArrayList<>();
for (Metric<?> metric : metrics.values()) { for (Metric<?> metric : metrics.values()) {
influxWriteApi.writePoint(metric.toPoint()); points.add(metric.toPoint());
} }
influxWriteApi.writePoints(points);
log.info("Wrote {} metrics to Influx", metrics.size()); log.info("Wrote {} metrics to Influx", metrics.size());
} }
} }