fix(influxdb): Flush data to InfluxDB v2 every 5 seconds

ptarmiganlabs · Jun 4, 2024 · 2384b6c · 2384b6c
1 parent 1ba4391
commit 2384b6c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/src/globals.js b/src/globals.js
@@ -661,7 +661,7 @@ async function initInfluxDB() {
                     defaultTags: tags,
 
                     /* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
-                    flushInterval: 1000,
+                    flushInterval: 5000,
 
                     /* maximum size of the retry buffer - it contains items that could not be sent for the first time */
                     // maxBufferLines: 30_000,

diff --git a/src/lib/post-to-influxdb.js b/src/lib/post-to-influxdb.js
@@ -625,7 +625,7 @@ async function postButlerSOSMemoryUsageToInfluxdb(memory) {
             // },
 
             /* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
-            flushInterval: 1000,
+            flushInterval: 5000,
 
             /* maximum size of the retry buffer - it contains items that could not be sent for the first time */
             // maxBufferLines: 30_000,
@@ -778,7 +778,7 @@ async function postUserEventToInfluxdb(msg) {
             // },
 
             /* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
-            flushInterval: 1000,
+            flushInterval: 5000,
 
             /* maximum size of the retry buffer - it contains items that could not be sent for the first time */
             // maxBufferLines: 30_000,
@@ -1060,7 +1060,7 @@ async function postLogEventToInfluxdb(msg) {
                     // },
 
                     /* maximum time in millis to keep points in an unflushed batch, 0 means don't periodically flush */
-                    flushInterval: 1000,
+                    flushInterval: 5000,
 
                     /* maximum size of the retry buffer - it contains items that could not be sent for the first time */
                     // maxBufferLines: 30_000,