flush redis on startup

anselm.py

@@ -14,7 +14,8 @@ class Observe(QThread, System):
     def __init__(self):
         QThread.__init__(self)
         System.__init__(self)
-
+        self.r.flushdb()
+        
     def run(self):
         self.p.subscribe("io")
         self.log.info('start listening redis ')
@@ -95,6 +96,7 @@ class Anselm(System):
         self.observer_thread = Observe()
         self.observer_thread.signal.connect(self.end_task)
         self.observer_thread.start()
+
         self.init_ui()
 
     def init_ui(self):

anselm/system.py

@@ -4,6 +4,9 @@ import logging
 import datetime
 import time
 import redis
+from logging_gelf.formatters import GELFFormatter
+from logging_gelf.handlers import GELFTCPSocketHandler
+
 
 class System:
     """
@@ -31,12 +34,13 @@ class System:
     def init_log(self):
     
         log_level = self.config.get('loglevel')
-        self.log = logging.getLogger()
-        
-        if log_level is None:
-            log_level = self.log_level
+        self.log = logging.getLogger("gelf")
+        self.log.setLevel(logging.DEBUG)
 
-        coloredlogs.install(fmt=self.log_fmt, level=log_level, logger=self.log)
+        handler = GELFTCPSocketHandler(host="172.30.56.135", port=12204)
+        handler.setFormatter(GELFFormatter(null_character=True))
+        self.log.addHandler(handler)
+        
     
     def init_kv(self):
     

setup.py

@@ -38,7 +38,8 @@ setup(
                     'redis',
                     'flask',
                     'requests',
-                    'numpy',
+                    'numpy', 
+                    'logging-gelf',
                     ],
     #extras_require={
     #    'dev': ['sphinx',