日志改为异步

Administrator

2023-09-15 a6a54fefa3a57232f935947e76150609a9407a4e

 log_module/async_log_util.py

@@ -4,7 +4,7 @@
import queue
import time

from log_module.log import logger_debug
from log_module.log import logger_debug, logger_system
from utils import tool


@@ -31,6 +31,7 @@

    # 运行同步日志
    def run_sync(self):
        logger_system.info(f"run_sync 线程ID:{tool.get_thread_id()}")
        while True:
            try:
                val = self.__log_queue.get()
@@ -46,6 +47,9 @@


l2_data_log = AsyncLogManager()


huaxin_l2_log = AsyncLogManager()


log_queue = queue.Queue()
@@ -77,6 +81,7 @@

# 运行同步日志
def run_sync():
    logger_system.info(f"async_log 线程ID:{tool.get_thread_id()}")
    while True:
        try:
            val = log_queue.get()