"""
|
异步日志管理器
|
"""
|
import queue
|
import time
|
|
from log_module.log import logger_debug
|
from utils import tool
|
|
log_queue = queue.Queue()
|
|
|
def __add_log(logger, method, *args):
|
log_queue.put_nowait((logger, time.time(), method, args))
|
|
|
def debug(logger, *args):
|
__add_log(logger, "debug", *args)
|
|
|
def info(logger, *args):
|
__add_log(logger, "info", *args)
|
|
|
def warning(logger, *args):
|
__add_log(logger, "warning", *args)
|
|
|
def error(logger, *args):
|
__add_log(logger, "error", *args)
|
|
|
def exception(logger, *args):
|
__add_log(logger, "exception", *args)
|
|
|
# 运行同步日志
|
def run_sync():
|
while True:
|
try:
|
val = log_queue.get()
|
time_s = val[1]
|
cmd = val[2]
|
method = getattr(val[0], cmd)
|
d = list(val[3])
|
d[0] = f"[{tool.to_time_str(int(time_s))}.{str(time_s).split('.')[1][:3]}] " + d[0]
|
d = tuple(d)
|
method(*d)
|
except:
|
pass
|
|
|
if __name__ == "__main__":
|
# info(logger_debug, "*-{}", "test")
|
info(logger_debug, "123123")
|
run_sync()
|
