changed logging destination to stdout

Author: DevAlone

main.py

@@ -64,36 +64,22 @@ def prepare_loggers():
     global main_logger
 
     asyncio_logger = logging.getLogger("asyncio")
-    asyncio_logger_file_handler = logging.FileHandler("logs/asyncio.log")
-    asyncio_logger_file_handler.setLevel(logging.DEBUG)
-    asyncio_logger_file_handler.setFormatter(
-            logging.Formatter(
-                "%(levelname)s ~ %(asctime)s ~ %(funcName)30s() - %(message)s"
-                )
-            )
-    asyncio_logger.addHandler(asyncio_logger_file_handler)
-
-    if settings.DEBUG:
-        asyncio.get_event_loop().set_debug(True)
-
-        asyncio_logger.setLevel(logging.DEBUG)
+    asyncio_logger.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+    asyncio_logger_handler = logging.StreamHandler(sys.stdout)
+    asyncio_logger_handler.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+    asyncio_logger_handler.setFormatter(
+        logging.Formatter(settings.LOG_FORMAT_STRING)
+    )
+    asyncio_logger.addHandler(asyncio_logger_handler)
+    asyncio.get_event_loop().set_debug(settings.DEBUG)
 
     main_logger = logging.getLogger("proxy_py/main")
-
-    if settings.DEBUG:
-        main_logger.setLevel(logging.DEBUG)
-    else:
-        main_logger.setLevel(logging.INFO)
-
-    logger_file_handler = logging.FileHandler("logs/main.log")
-    logger_file_handler.setLevel(logging.DEBUG)
-    logger_file_handler.setFormatter(
-            logging.Formatter(
-                "%(levelname)s ~ %(asctime)s ~ %(funcName)30s() ~ %(message)s"
-                )
-            )
-
-    main_logger.addHandler(logger_file_handler)
+    main_logger.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+    logger_handler = logging.StreamHandler(sys.stdout)
+    logger_handler.setFormatter(logging.Formatter(settings.LOG_FORMAT_STRING))
+    logger_handler.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+    
+    main_logger.addHandler(logger_handler)
 
 
 async def core():
@@ -164,9 +150,9 @@ def main():
     sys.argv = sys.argv[1:]
     try:
         return {
-            'core': lambda: asyncio.get_event_loop().run_until_complete(core()),
-            'server': server,
-        }[command]()
+                'core': lambda: asyncio.get_event_loop().run_until_complete(core()),
+                'server': server,
+                }[command]()
     except KeyError:
         print_help()
         return 0

processor.py

@@ -9,10 +9,7 @@
 import time
 import logging
 import peewee
-
-
-
-LOGGERS_FORMAT = "%(levelname)s ~ %(asctime)s ~ %(funcName)30s() ~ %(message)s"
+import sys
 
 
 class Processor:
@@ -31,29 +28,22 @@ def get_instance():
 
     def __init__(self):
         self.logger = logging.getLogger("proxy_py/processor")
+        self.logger.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
 
-        if settings.DEBUG:
-            self.logger.setLevel(logging.DEBUG)
-        else:
-            self.logger.setLevel(logging.INFO)
-
-        logger_file_handler = logging.FileHandler("logs/processor.log")
-        logger_file_handler.setLevel(logging.DEBUG)
-        logger_file_handler.setFormatter(logging.Formatter(LOGGERS_FORMAT))
+        logger_handler = logging.StreamHandler(sys.stdout)
+        logger_handler.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+        logger_handler.setFormatter(logging.Formatter(settings.LOG_FORMAT_STRING))
 
-        self.logger.addHandler(logger_file_handler)
+        self.logger.addHandler(logger_handler)
 
         self.collectors_logger = logging.getLogger("proxy_py/collectors")
-        if settings.DEBUG:
-            self.collectors_logger.setLevel(logging.DEBUG)
-        else:
-            self.collectors_logger.setLevel(logging.INFO)
+        self.collectors_logger.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
 
-        collectors_logger_file_handler = logging.FileHandler("logs/collectors.log")
-        collectors_logger_file_handler.setLevel(logging.DEBUG)
-        logger_file_handler.setFormatter(logging.Formatter(LOGGERS_FORMAT))
+        collectors_logger_handler = logging.StreamHandler(sys.stdout)
+        collectors_logger_handler.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+        collectors_logger_handler.setFormatter(logging.Formatter(settings.LOG_FORMAT_STRING))
 
-        self.collectors_logger.addHandler(collectors_logger_file_handler)
+        self.collectors_logger.addHandler(collectors_logger_handler)
 
         self.logger.debug("processor initialization...")
 

proxy_py/_settings.py

@@ -16,6 +16,7 @@
 
 # enable to get more information in logs
 DEBUG = False
+LOG_FORMAT_STRING = "%(levelname)s ~ [%(name)s] ~ %(asctime)s ~ %(funcName)30s():L%(lineno)d - %(message)s"
 
 
 """

server/proxy_provider_server.py

@@ -11,25 +11,20 @@
 import logging
 import aiohttp
 import aiohttp_jinja2
+import sys
 
 
 class ProxyProviderServer(BaseApp):
     def __init__(self, host, port):
         logger = logging.getLogger("proxy_py/server")
+        logger.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
 
-        if settings.DEBUG:
-            logger.setLevel(logging.DEBUG)
-        else:
-            logger.setLevel(logging.INFO)
-
-        logger_file_handler = logging.FileHandler("logs/server.log")
-        logger_file_handler.setLevel(logging.DEBUG)
-        logger_file_handler.setFormatter(logging.Formatter(
-            "%(levelname)s ~ %(asctime)s ~ %(client_ip)s ~ %(message)s"
-        ))
-
-        logger.addHandler(logger_file_handler)
+        logger_handler = logging.StreamHandler(sys.stdout)
+        logger_handler.setLevel(logging.DEBUG if settings.DEBUG else logging.INFO)
+        logger_handler.setFormatter(logging.Formatter(settings.LOG_FORMAT_STRING))
 
+        logger.addHandler(logger_handler)
+        
         super(ProxyProviderServer, self).__init__(logger)
 
         self.host = host
@@ -39,14 +34,6 @@ def __init__(self, host, port):
     def start(self, loop):
         loop.run_until_complete(self.init())
 
-        '''
-        server = await loop.create_server(
-            self._app.make_handler(),
-            self.host,
-            self.port
-        )
-        '''
-
         return web.run_app(self._app, host=self.host, port=self.port, loop=loop)
 
     async def setup_router(self):