guitalens worker config and similator log

Patrick Maeght
1 parent e11721dc
Showing 4 changed files with 48 additions and 8 deletions Show diff stats
simulators/logconf/__init__.py
simulators/logconf/logging.ini
simulators/plc/guitalens_worker.py
src/monitoring/plc_checker.py
@@ -0,0 +1,4 @@
+
+import logging.config
+
+logging.config.fileConfig( __path__[0] + '/logging.ini')
 \ No newline at end of file
@@ -0,0 +1,31 @@
+[loggers]
+keys=root
+
+[handlers]
+keys=fileHandler, consoleHandler
+
+[formatters]
+keys=simpleFormaters
+
+[logger_root]
+level=DEBUG
+handlers=fileHandler, consoleHandler
+
+[handler_fileHandler]
+class=logging.handlers.RotatingFileHandler
+level=INFO
+maxBytes=1000000
+backupCount=20
+encoding=utf8
+formatter=simpleFormaters
+args=('../../logs/guitalens.log', 'a')
+
+[handler_consoleHandler]
+class=StreamHandler
+level=INFO
+formatter=simpleFormaters
+args=(sys.stdout,)
+
+[formatter_simpleFormaters]
+format=%(asctime)s - %(module)s:%(name)s:%(lineno)s - %(levelname)s - %(message)s
+datefmt=
@@ -6,9 +6,16 @@ import time
 from datetime import datetime
 import urllib.request
 import json
-
+import os, sys
+print(os.path.abspath("."))
+_path = os.path.abspath("..")
+sys.path.insert(0, _path )
+import logconf
 logger = logging.getLogger(__name__)
-
+"""logger = logging.getLogger(__name__)
+logging.basicConfig(level=logging.DEBUG, format='%(asctime)s - %(name)s - %(levelname)s - %(message)s')
+logging.FileHandler('../../logs/guitalens.log', mode='w')
+logger.setLevel('DEBUG')"""
  
 class WorkerState(object):
     """
@@ -60,14 +67,14 @@ class WorkerUrl(threading.Thread):
             self.shared.status_time = str(datetime.now())
         except Exception as e:
             logger.info('Worker init error ' + str(e))
-            self.shared.status = 'wait'
+            #self.shared.status = 'wait'
  
     def try_work(self):
         try:
             self.work()
         except Exception as e:
             logger.info('Worker error ' + str(e))
-            self.shared.status = 'wait'
+            self.shared.status = 'init'
  
     def work(self):
         #logger.info('Working '+ str(self.item))
 import json
 import logging
 logger = logging.getLogger(__name__)
+logger.setLevel('DEBUG')
  
  
  
@@ -136,10 +137,7 @@ class PlcChecker(object):
             self.device_name = self.get_key(device, "device_name")
             self.device_type = self.get_key(device, "device_type")
             self.serial_number = self.get_key(device, "serial_number")
-            try:
-                self.valid = not bool(int(self.get_key(device, "error_code")))
-            except:
-               self.valid = False
+            self.valid = True if self.get_key(device, "error_code") == '0' else False
             for device_values in device["device_values"]:
                 sensor = []
                 sensor.append(self.device_name)