bug修复

admin

2023-08-30 23a6a2b9cbe40df4b3309f2db86d7db592e5d07c

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
"""
日志
"""
import sys
from loguru import logger
import constant
 
 
class MyLogger:
    def __init__(self):
        logger.remove()
 
        # 显示在控制台
        # logger.add(sys.stdout,
        #           filter=lambda record: record["extra"].get("name") == "l2_trade", enqueue=True)
 
        logger.add(self.get_path("first_code", "first_code_record"),
                   filter=lambda record: record["extra"].get("name") == "first_code_record",
                   rotation="00:00", compression="zip", enqueue=True)
 
        logger.add(self.get_path("debug", "debug"),
                   filter=lambda record: record["extra"].get("name") == "debug",
                   rotation="00:00", compression="zip", enqueue=True)
 
        logger.add(self.get_path("kpl", "kpl_limit_up_reason_change"),
                   filter=lambda record: record["extra"].get("name") == "kpl_limit_up_reason_change",
                   rotation="00:00", compression="zip", enqueue=True)
 
        logger.add(self.get_path("kpl", "kpl_limit_up"),
                   filter=lambda record: record["extra"].get("name") == "kpl_limit_up",
                   rotation="00:00", compression="zip", enqueue=True)
 
        logger.add(self.get_path("kpl", "kpl_debug"),
                   filter=lambda record: record["extra"].get("name") == "kpl_debug",
                   rotation="00:00", compression="zip", enqueue=True)
 
        # 看盘日志
        logger.add(self.get_path("kp", "kp_msg"),
                   filter=lambda record: record["extra"].get("name") == "kp_msg",
                   rotation="00:00", compression="zip", enqueue=True)
 
        logger.add(self.get_path("redis", "redis_debug"),
                   filter=lambda record: record["extra"].get("name") == "redis_debug",
                   rotation="00:00", compression="zip", enqueue=True)
 
        logger.add(self.get_path("profile", "profile"),
                   filter=lambda record: record["extra"].get("name") == "profile",
                   rotation="00:00", compression="zip", enqueue=True)
 
    def get_path(self, dir_name, log_name):
        path_str = "{}/logs/gp/{}/{}".format(constant.get_path_prefix(), dir_name, log_name) + ".{time:YYYY-MM-DD}.log"
        # print(path_str)
        return path_str
 
    def get_logger(self, log_name):
        return logger.bind(name=log_name)
 
 
__mylogger = MyLogger()
 
logger_first_code_record = __mylogger.get_logger("first_code_record")
 
logger_debug = __mylogger.get_logger("debug")
 
logger_kpl_limit_up_reason_change = __mylogger.get_logger("kpl_limit_up_reason_change")
 
logger_kpl_limit_up = __mylogger.get_logger("kpl_limit_up")
 
logger_kpl_debug = __mylogger.get_logger("kpl_debug")
 
logger_kp_msg = __mylogger.get_logger("kp_msg")
 
logger_redis_debug = __mylogger.get_logger("redis_debug")
 
logger_profile = __mylogger.get_logger("profile")