summaryrefslogtreecommitdiff
path: root/prometheus_tp_link_exporter
diff options
context:
space:
mode:
authorOleg Pykhalov <go.wigust@gmail.com>2022-02-07 00:01:28 +0300
committerOleg Pykhalov <go.wigust@gmail.com>2022-02-07 00:01:28 +0300
commitae4b8b20b5ae4de1b217f4f9b262cfcb28d05388 (patch)
tree493fec8d57168e3cad6962900c04748da0f5cdb7 /prometheus_tp_link_exporter
parentJoin process_node_network functions. (diff)
downloadpython-prometheus-ssh-exporter-ae4b8b20b5ae4de1b217f4f9b262cfcb28d05388.tar.gz
Diffstat (limited to 'prometheus_tp_link_exporter')
-rw-r--r--prometheus_tp_link_exporter/__main__.py9
1 files changed, 7 insertions, 2 deletions
diff --git a/prometheus_tp_link_exporter/__main__.py b/prometheus_tp_link_exporter/__main__.py
index 06a5bd2..1761079 100644
--- a/prometheus_tp_link_exporter/__main__.py
+++ b/prometheus_tp_link_exporter/__main__.py
@@ -2,10 +2,12 @@
from prometheus_client import Counter, start_http_server
import jc.parsers.ifconfig
+import logging
import os
import subprocess
import time
+log = logging.getLogger("prometheus-tp-link-exporter")
host = os.getenv("PROMETHEUS_TP_LINK_EXPORTER_HOST", "")
password = os.getenv("PROMETHEUS_TP_LINK_EXPORTER_PASSWORD", "")
interval = int(os.getenv("PROMETHEUS_TP_LINK_EXPORTER_INTERVAL", "10"))
@@ -44,7 +46,8 @@ def process_node_network():
previos_value = node_network_transmit_bytes_total._metrics[
(device["name"],)
]._value._value
- if previos_value <= device["tx_bytes"]:
+ if previos_value < device["tx_bytes"]:
+ log.debug(f"Previous value {previos_value} is bigger than current value {device['rx_bytes']} on device {device['name']}, skipping updating the value.")
node_network_transmit_bytes_total.labels(device=device["name"]).inc(
device["tx_bytes"] - previos_value
)
@@ -53,10 +56,12 @@ def process_node_network():
for device in devices:
if (device["name"],) in node_network_receive_bytes_total._metrics:
previos_value = node_network_receive_bytes_total._metrics[(device["name"],)]._value._value
- if previos_value <= device["rx_bytes"]:
+ if previos_value < device["rx_bytes"]:
node_network_receive_bytes_total.labels(device=device["name"]).inc(
device["rx_bytes"] - previos_value
)
+ else:
+ log.debug(f"Previous value {previos_value} is bigger than current value {device['rx_bytes']} on device {device['name']}, skipping updating the value.")
else:
node_network_receive_bytes_total.labels(device=device["name"]).inc(device["rx_bytes"])