Decouple InfluxDB writings from request handling.

With #451, we found that writing an InfluxDB data point might block and lead to high latencies.
openHPI · Jan 28, 2024 · 08c3a3d · 08c3a3d
1 parent ae86b1c
commit 08c3a3d
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/pkg/monitoring/influxdb2_middleware.go b/pkg/monitoring/influxdb2_middleware.go
@@ -164,7 +164,8 @@ func ChangedPrewarmingPoolSize(id dto.EnvironmentID, count uint) {
 func WriteInfluxPoint(p *write.Point) {
 	if influxClient != nil {
 		p.AddTag("stage", config.Config.InfluxDB.Stage)
-		influxClient.WritePoint(p)
+		// We identified that the influxClient is not truly asynchronous. See #541.
+		go func() { influxClient.WritePoint(p) }()
 	} else {
 		entry := log.WithField("name", p.Name())
 		for _, tag := range p.TagList() {