Demo attempt at metric logging

jmurrayufo · Dec 11, 2017 · a99e9e6 · a99e9e6
1 parent c500bc4
commit a99e9e6
Show file tree

Hide file tree

Showing 2 changed files with 25 additions and 0 deletions.
diff --git a/InGenStation/code/CustomLogging/GlobalLog.py b/InGenStation/code/CustomLogging/GlobalLog.py
@@ -1,5 +1,7 @@
 import logging
 import logstash
+import platform
+import json
 from . import VerboseLogstashFormatter
 
 
@@ -22,7 +24,28 @@ def __init__(self, _type=None):
         ch.setFormatter(formatter)
         self._log.addHandler(ch)
 
+
     def __getattr__(self, name):
         return getattr(self._log, name)
 
 
+    def metric(self, name, **kwargs):
+        report_dict = dict({
+           "metric": True,
+           "app.name":"DevHab",
+           "app.version":"0.1.0",
+           "env.domain":"dragon",
+           "env.infrastructure":"dev",
+           "env.name":"isbe",
+           "env.platform":platform.platform(),
+           "name":name
+        })
+        for key in kwargs:
+            report_dict[key] = kwargs[key]
+        self.info(json.dumps(report_dict))
+
+
+    @property
+    def report_dict(self):
+        return None
+
diff --git a/InGenStation/code/RoachHab.py b/InGenStation/code/RoachHab.py
@@ -28,6 +28,8 @@ async def run(self):
             t_sleep = 60 - (time.time() - t)
             t_sleep = max(0, t_sleep)
             self.log.debug(f"Sleep for {t_sleep:.3f} s")
+            self.log.metric(name="t0.temp","generic_float"=self.sensors["t0"].temperature)
+            self.log.metric(name="h1.temp","generic_float"=self.sensors["h1"].temperature)
             await asyncio.sleep(t_sleep)