Compare commits
8 Commits
Author | SHA1 | Date |
---|---|---|
|
ed97c06180 | |
|
b7bc47e2d5 | |
|
9ac6a3f7da | |
|
70e44a432c | |
|
cd2e65544e | |
|
4e45eb26f4 | |
|
83dc893fbb | |
|
00f5029972 |
2685
grafana.json
2685
grafana.json
File diff suppressed because it is too large
Load Diff
14
metrics.py
14
metrics.py
|
@ -5,14 +5,15 @@ from os import getenv
|
||||||
from time import sleep
|
from time import sleep
|
||||||
from prometheus_client.core import GaugeMetricFamily, REGISTRY, CounterMetricFamily
|
from prometheus_client.core import GaugeMetricFamily, REGISTRY, CounterMetricFamily
|
||||||
from prometheus_client import start_http_server
|
from prometheus_client import start_http_server
|
||||||
|
from loguru import logger
|
||||||
|
|
||||||
|
|
||||||
class TasmotaCollector(object):
|
class TasmotaCollector(object):
|
||||||
def __init__(self):
|
def __init__(self):
|
||||||
self.ip = getenv('DEVICE_IP')
|
self.ip = getenv('DEVICE_IP')
|
||||||
|
logger.info("Env variable from DEVICE_NAME used is: " + self.ip)
|
||||||
self.device_name = getenv("DEVICE_NAME").lower()
|
self.device_name = getenv("DEVICE_NAME").lower()
|
||||||
if not self.ip:
|
logger.info("Env variable from DEVICE_NAME used is: " + self.device_name)
|
||||||
self.ip = "192.168.4.1"
|
|
||||||
self.user = getenv('USER')
|
self.user = getenv('USER')
|
||||||
self.password = getenv('PASSWORD')
|
self.password = getenv('PASSWORD')
|
||||||
|
|
||||||
|
@ -21,7 +22,7 @@ class TasmotaCollector(object):
|
||||||
response = self.fetch()
|
response = self.fetch()
|
||||||
|
|
||||||
for key in response:
|
for key in response:
|
||||||
metric_name = self.device_name + "_" + key.lower().replace(" ", "_")
|
metric_name = "tasmota_" + key.lower().replace(" ", "_")
|
||||||
metric = response[key].split()[0]
|
metric = response[key].split()[0]
|
||||||
unit = None
|
unit = None
|
||||||
if len(response[key].split()) > 1:
|
if len(response[key].split()) > 1:
|
||||||
|
@ -37,7 +38,7 @@ class TasmotaCollector(object):
|
||||||
def fetch(self):
|
def fetch(self):
|
||||||
|
|
||||||
url = 'http://' + self.ip + '/?m=1'
|
url = 'http://' + self.ip + '/?m=1'
|
||||||
|
logger.info("Getting Metrics from: " + url)
|
||||||
session = requests.Session()
|
session = requests.Session()
|
||||||
|
|
||||||
if self.user and self.password:
|
if self.user and self.password:
|
||||||
|
@ -70,12 +71,9 @@ signal.signal(signal.SIGINT, signal_handler)
|
||||||
if __name__ == '__main__':
|
if __name__ == '__main__':
|
||||||
|
|
||||||
port = getenv('EXPORTER_PORT')
|
port = getenv('EXPORTER_PORT')
|
||||||
if not port:
|
logger.info("Starting HTTP server on port: " + port)
|
||||||
port = 8000
|
|
||||||
|
|
||||||
start_http_server(int(port))
|
start_http_server(int(port))
|
||||||
REGISTRY.register(TasmotaCollector())
|
REGISTRY.register(TasmotaCollector())
|
||||||
|
|
||||||
while(True):
|
while(True):
|
||||||
sleep(1)
|
sleep(1)
|
||||||
|
|
||||||
|
|
|
@ -1,2 +1,3 @@
|
||||||
prometheus_client
|
prometheus_client
|
||||||
requests
|
requests
|
||||||
|
loguru
|
Loading…
Reference in New Issue