1

fastapi-demo/config/__init__.py

@@ -98,56 +98,23 @@ class CfgBaseInit(object):
             raise worker_exception
 
 
-
-
-
 class Logger(object):
     # 日志
     log_path = CfgBaseInit.config.get("LOG", "log_path")
     when = CfgBaseInit.config.get("LOG", "when")
     backupCount = int(CfgBaseInit.config.get("LOG", "backupCount"))
 
-    formatter = logging.Formatter(
-        '%(asctime)s %(name)s %(process)d %(thread)d %(threadName)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s')
-    handler = TimedRotatingFileHandler(log_path, when=when, backupCount=backupCount)
-    handler.setFormatter(formatter)
+    logging.basicConfig(
+        format='%(asctime)s %(name)s %(process)d %(thread)d %(threadName)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s')
     logger = logging.getLogger(CfgBaseInit.project_name)
-    logger.addHandler(handler)
     logger.setLevel(logging.DEBUG)
 
-    def __init__(self, cls):
-        self._cls = cls
-
-    def __call__(self, *args, **kwargs):
-        if not hasattr(self._cls, 'logger'):
-            self._cls.logger = logger
-        return self._cls(*args, **kwargs)
-
-    @staticmethod
-    def replace_blank(msg, *args, **kwargs):
-        msg = str(msg)
-        return f"{msg % args}".replace("\r", " ").replace("\n", " ")
-
-    def debug(self, msg, *args, **kwargs):
-        self.logger.debug(self.replace_blank(msg, *args, **kwargs))
-
-    def info(self, msg, *args, **kwargs):
-        self.logger.info(self.replace_blank(msg, *args, **kwargs))
-
-    def warning(self, msg, *args, **kwargs):
-        self.logger.warning(self.replace_blank(msg, *args, **kwargs))
-
-    def error(self, msg, *args, **kwargs):
-        self.logger.error(self.replace_blank(msg, *args, **kwargs))
-
-    def exception(self, msg, *args, **kwargs):
-        self.logger.exception(self.replace_blank(msg, *args, **kwargs))
-
-    def critical(self, msg, *args, **kwargs):
-        self.logger.critical(self.replace_blank(msg, *args, **kwargs))
+    # 输出到文件
+    handler = TimedRotatingFileHandler(log_path, when=when, backupCount=backupCount)
+    logger.addHandler(handler)
 
 
-logger = Logger(Logger)
+logger = Logger.logger
 
 
 class RedisInit(CfgBaseInit):
@@ -241,6 +208,7 @@ class BehaviorAPI(CfgBaseInit):
         r = requests.post(BehaviorAPI.url, data=data, headers=CfgBaseInit.headers)
         return r
 
+
 class AsyncKafka(CfgBaseInit):
     """异步请求模块
     """