diff options
author | nicolargo <nicolashennion@gmail.com> | 2020-02-27 15:17:24 +0100 |
---|---|---|
committer | nicolargo <nicolashennion@gmail.com> | 2020-02-27 15:17:24 +0100 |
commit | f6533272a5a61d13a4041d84c43adeffee926aef (patch) | |
tree | 4ac21a9b90046ae9a093a94a869ccce73374b725 /glances | |
parent | 1e8bf7bd5fdec1d2b8eb85e57a38096466f1b5d9 (diff) |
Feature request: Include hostname in all (e.g. kafka) exports #1594
Diffstat (limited to 'glances')
-rw-r--r-- | glances/exports/glances_kafka.py | 9 |
1 files changed, 7 insertions, 2 deletions
diff --git a/glances/exports/glances_kafka.py b/glances/exports/glances_kafka.py index c328d7f6..88d13bf0 100644 --- a/glances/exports/glances_kafka.py +++ b/glances/exports/glances_kafka.py @@ -42,11 +42,14 @@ class Export(GlancesExport): # Optionals configuration keys self.compression = None + self.tags = None # Load the Kafka configuration file section self.export_enable = self.load_conf('kafka', - mandatories=['host', 'port', 'topic'], - options=['compression']) + mandatories=['host', 'port', + 'topic'], + options=['compression', + 'tags']) if not self.export_enable: sys.exit(2) @@ -79,6 +82,8 @@ class Export(GlancesExport): # Create DB input data = dict(zip(columns, points)) + if self.tags is not None: + data.update(self.parse_tags(self.tags)) # Send stats to the kafka topic # key=<plugin name> |