aboutsummaryrefslogtreecommitdiffstats
path: root/ms
diff options
context:
space:
mode:
Diffstat (limited to 'ms')
-rw-r--r--ms/logging.yaml9
-rw-r--r--ms/py-executor/server.py27
2 files changed, 30 insertions, 6 deletions
diff --git a/ms/logging.yaml b/ms/logging.yaml
index 3a31ca85c..914e261b0 100644
--- a/ms/logging.yaml
+++ b/ms/logging.yaml
@@ -11,4 +11,11 @@ formatters:
standard:
format: '%(asctime)s:[%(name)s]:[%(filename)s]-[%(lineno)d]
[%(levelname)s]:%(message)s '
- datefmt: "%Y-%m-%d %H:%M:%S" \ No newline at end of file
+ datefmt: "%Y-%m-%d %H:%M:%S"
+ default:
+ format: '%(asctime)s - %(name)s - %(threadName)s - %(levelname)s - %(message)s'
+
+loglevel: info
+logfilesize: 1048576
+rollovercount: 5
+
diff --git a/ms/py-executor/server.py b/ms/py-executor/server.py
index 7f6537011..2420344ee 100644
--- a/ms/py-executor/server.py
+++ b/ms/py-executor/server.py
@@ -18,6 +18,7 @@
import logging
import os
import time
+import yaml
from builtins import KeyboardInterrupt
from concurrent import futures
from pathlib import Path, PurePath
@@ -96,13 +97,29 @@ if __name__ == '__main__':
config_file = str(os.path.expanduser(Path(supplied_configuration_file or default_configuration_file)))
configuration = ScriptExecutorConfiguration(config_file)
- logging_formater = '%(asctime)s - %(name)s - %(threadName)s - %(levelname)s - %(message)s'
- logging.basicConfig(filename=configuration.script_executor_property('logFile'),
- level=logging.DEBUG,
+ log_file_name = configuration.script_executor_property('logFile')
+ log_file = os.path.join(os.path.dirname(os.path.abspath(os.path.dirname(__file__))), "logging.yaml")
+ print(log_file)
+ with open(log_file) as log:
+ log_config = yaml.safe_load(log)
+ print(log_config)
+ logging_formater = log_config["formatters"]["default"]["format"]
+ print(log_config["loglevel"])
+ if log_config["loglevel"] == "debug":
+ loglevel = logging.DEBUG
+ elif log_config["loglevel"] == "info":
+ loglevel = logging.INFO
+ elif log_config["loglevel"] == "error":
+ loglevel = logging.ERROR
+ logging.basicConfig(filename=log_file_name,
+ level=loglevel,
format=logging_formater)
- console = logging.StreamHandler()
- console.setLevel(logging.INFO)
+ console = logging.handlers.RotatingFileHandler(log_file_name, maxBytes=log_config["logfilesize"],
+ backupCount=log_config["rollovercount"])
+
+ console.setLevel(loglevel)
formatter = logging.Formatter(logging_formater)
console.setFormatter(formatter)
logging.getLogger('').addHandler(console)
serve(configuration)
+