Customizable InfluxDB2 export interval #2348

conf/glances.conf

@@ -503,6 +503,9 @@ protocol=http
 org=nicolargo
 bucket=glances
 token=EjFUTWe8U-MIseEAkaVIgVnej_TrnbdvEcRkaB1imstW7gapSqy6_6-8XD-yd51V0zUUpDy-kAdVD1purDLuxA==
+# Set the interval between two exports (in seconds)
+# If the interval is set to 0, the Glances refresh time is used (default behavor)
+#interval=0
 # Prefix will be added for all measurement name
 # Ex: prefix=foo
 #     => foo.cpu

glances/exports/glances_influxdb2.py

@@ -35,16 +35,28 @@ class Export(GlancesExport):
         self.prefix = None
         self.tags = None
         self.hostname = None
+        self.interval = 0
 
         # Load the InfluxDB configuration file
         self.export_enable = self.load_conf(
             'influxdb2',
             mandatories=['host', 'port', 'user', 'password', 'org', 'bucket', 'token'],
-            options=['protocol', 'prefix', 'tags'],
+            options=['protocol', 'prefix', 'tags', 'interval'],
         )
         if not self.export_enable:
             exit('Missing INFLUXDB version 1 config')
 
+        # Interval between two exports (in seconds)
+        # if export_interval is set to 0, the Glances refresh time is used (default behavor)
+        try:
+            self.interval = int(self.interval)
+        except ValueError:
+            logger.warning("InfluxDB export interval is not an integer, use default value (0)")
+            self.interval = 0
+        # and should be set to the Glances refresh time if the value is 0
+        self.interval = self.interval if self.interval > 0 else self.args.time
+        logger.debug("InfluxDB export interval is set to {} seconds".format(self.interval))
+
         # The hostname is always add as a tag
         self.hostname = node().split('.')[0]
 
@@ -72,7 +84,7 @@ class Export(GlancesExport):
         write_client = client.write_api(
             write_options=WriteOptions(
                 batch_size=500,
-                flush_interval=10000,
+                flush_interval=self.interval * 1000,
                 jitter_interval=2000,
                 retry_interval=5000,
                 max_retries=5,