Finished code

metrics.py

@@ -1,44 +1,61 @@
 import requests
-import os
+from os import getenv
-from dotenv import load_dotenv
+from time import sleep
-from flask import Flask
+from prometheus_client.core import GaugeMetricFamily, REGISTRY
-app = Flask(__name__)
+from prometheus_client import start_http_server
 
-load_dotenv()
+class TasmotaCollector(object):
-ip = os.getenv('DEVICE_IP')
+    def __init__(self):
-user = os.getenv('USER')
+        self.ip = getenv('DEVICE_IP')
-password = os.getenv('PASSWORD')
+        if not self.ip:
+            self.ip = "192.168.4.1"
+        self.user = getenv('USER')
+        self.password = getenv('PASSWORD')
 
-def get_values():
+    def collect(self):
 
-    url = 'http://' + ip + '/?m=1'
+        response = self.fetch()
 
-    session = requests.Session()
+        for key in response:
-    
+            metric_name = "tasmota_" + key.lower().replace(" ", "_") 
-    if user and password:
+            metric = response[key].split()[0]
-        session.auth = (user, password)
+            unit = None
+            if len(response[key].split()) > 1:
+                unit = response[key].split()[1]
+            g = GaugeMetricFamily(metric_name, key, labels=['device'], unit=unit)
+            g.add_metric([self.ip], metric)
+            yield g
 
-    page = session.get(url)
+    def fetch(self):
 
-    values = {}
+        url = 'http://' + self.ip + '/?m=1'
 
-    string_values = str(page.text).split("{s}")
+        session = requests.Session()
-    for i in range(1,len(string_values)-1):
+        
-        label = string_values[i].split("{m}")[0]
+        if self.user and self.password:
-        value = string_values[i].split("{m}")[1].split("{e}")[0]
+            session.auth = (self.user, self.password)
-        values[label] = value
 
-    return values
+        page = session.get(url)
 
-@app.route('/metrics')
+        values = {}
-def return_metrics():
 
-    response = ""
+        string_values = str(page.text).split("{s}")
+        for i in range(1,len(string_values)-1):
+            label = string_values[i].split("{m}")[0]
+            value = string_values[i].split("{m}")[1].split("{e}")[0]
+            values[label] = value
 
-    data = get_values()
+        return values
 
-    for key in data:
+if __name__ == '__main__':
-        line = key.lower().replace(" ", "_") + " " + data[key].split()[0] + '\n'
-        response += line
 
-    return(response)
+    port = getenv('EXPORTER_PORT')
+    if not port:
+        port = 8000
+
+    start_http_server(int(port))
+    REGISTRY.register(TasmotaCollector())
+
+    while(True):
+        sleep(1)
+