fixes

Author: devsetgo

dsg_lib/common_functions/logging_config.py

@@ -91,7 +91,7 @@ def config_log(
         log_serializer=False,
         log_diagnose=True,
         app_name='my_app',
-        append_app_name=True
+        append_app_name=True,
         enqueue=True,
         intercept_standard_logging=True,
         file_sink=True
@@ -112,6 +112,7 @@ def config_log(
         log_format = '<green>{time:YYYY-MM-DD HH:mm:ss.SSSSSS}</green> | <level>{level: <8}</level> | <cyan> {name}</cyan>:<cyan>{function}</cyan>:<cyan>{line}</cyan> - <level>{message}</level>'  # pragma: no cover
 
     if log_serializer is True:
+        log_format = '{message}'  # pragma: no cover
         log_name = f'{log_name}.json'  # pragma: no cover
     else:
         log_name = f'{log_name}.log'  # pragma: no cover
@@ -153,6 +154,8 @@ def config_log(
         diagnose=log_diagnose,
     )
 
+    basic_config_handlers:list = []
+
     class InterceptHandler(logging.Handler):
         """
         Interceptor for standard logging.
@@ -198,14 +201,15 @@ def emit(self, record):
                 level, record.getMessage()
             )  # pragma: no cover
 
-    # Configure standard logging to use interceptor handler
-    logging.basicConfig(handlers=[InterceptHandler()], level=logging_level.upper())
 
     if intercept_standard_logging:
         # Add interceptor handler to all existing loggers
         for name in logging.root.manager.loggerDict:
             logging.getLogger(name).addHandler(InterceptHandler())
 
+        # Add interceptor handler to the root logger
+        basic_config_handlers.append(InterceptHandler())
+
     # Set the root logger's level to the lowest level possible
     logging.getLogger().setLevel(logging.NOTSET)
 
@@ -242,8 +246,6 @@ def write(self, message):
                         raise  # Reraise if max retries exceeded
 
 
-    basic_config_handlers:list = []
-
     if file_sink:
         # Create an instance of ResilientFileSink
         resilient_sink = ResilientFileSink(str(log_path))

examples/log_example.py

@@ -16,10 +16,10 @@
     logging_directory='log',
     log_name='log',
     logging_level='DEBUG',
-    log_rotation='1 MB',
+    log_rotation='100 MB',
     log_retention='10 days',
     log_backtrace=True,
-    log_serializer=False,
+    log_serializer=True,
     log_diagnose=True,
     # app_name='my_app',
     # append_app_name=True,
@@ -43,14 +43,14 @@ def div_zero_two(x, y):
 
 
 
-def log_big_string(_):
-    big_string = secrets.token_urlsafe(256)
-    for _ in range(100):
+def log_big_string(lqty=100, size=256):
+    big_string = secrets.token_urlsafe(size)
+    for _ in range(lqty):
         logging.debug(f'Lets make this a big message {big_string}')
         div_zero(x=1, y=0)
         div_zero_two(x=1, y=0)
         # after configuring logging
-        # user loguru to log messages
+        # use loguru to log messages
         logger.debug('This is a debug message')
         logger.info('This is an info message')
         logger.error('This is an error message')
@@ -65,20 +65,19 @@ def log_big_string(_):
         logging.critical('This is a critical message')
 
 
+def worker(wqty=100, lqty=100, size=256):
+    for _ in tqdm(range(wqty), ascii=True):  # Adjusted for demonstration
+        log_big_string(lqty=lqty, size=size)
 
-def worker():
-    for _ in tqdm(range(100), ascii=True):  # Adjusted for demonstration
-        log_big_string(None)
-
-def main():
+def main(wqty=100, lqty=100, size=256, workers=2):
     threads = []
-    for _ in range(4):  # Create x threads
-        t = threading.Thread(target=worker)
+    for _ in range(workers):  # Create workers threads
+        t = threading.Thread(target=worker, args=(wqty, lqty, size,))
         threads.append(t)
         t.start()
 
     for t in threads:
         t.join()
 
 if __name__ == "__main__":
-    main()
+    main(wqty=100, lqty=10, size=256, workers=10)