From e7f8c6013d777dd5ba10b8d548d2d3db6158d37a Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 08 九月 2022 17:04:27 +0800
Subject: [PATCH] '完善'

---
 log.py |   25 ++++++++++++++-----------
 1 files changed, 14 insertions(+), 11 deletions(-)

diff --git a/log.py b/log.py
index 84144f9..5b88cbc 100644
--- a/log.py
+++ b/log.py
@@ -2,35 +2,37 @@
 
 
 def get_path(dir_name, log_name):
-    return "D:/logs/gp/{}/{}".format(dir_name, log_name)+".{time:YYYY-MM-DD}.log"
+    return "D:/logs/gp/{}/{}".format(dir_name, log_name) + ".{time:YYYY-MM-DD}.log"
 
 
-#   姣忎竴澶╃敓鎴愪竴涓棩蹇楁枃浠讹紝鍘嗗彶鏃ュ織鏂囦欢閲囩敤zip鍘嬬缉
+#   姣忎竴澶╃敓鎴愪竴涓棩蹇楁枃浠讹紝鍘嗗彶鏃ュ織鏂囦欢閲囩敤zip鍘嬬缉,寮傛鍐欏叆鏃ュ織
 logger.add(get_path("trade", "trade_gui"), filter=lambda record: record["extra"].get("name") == "trade_gui",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 logger.add(get_path("trade", "trade"), filter=lambda record: record["extra"].get("name") == "trade", rotation="00:00",
            compression="zip")
-logger.add(get_path("trade", "delegate"), filter=lambda record: record["extra"].get("name") == "delegate", rotation="00:00",
+logger.add(get_path("trade", "delegate"), filter=lambda record: record["extra"].get("name") == "delegate",
+           rotation="00:00",
            compression="zip")
 logger.add(get_path("l2", "l2_error"), filter=lambda record: record["extra"].get("name") == "l2_error",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 
 logger.add(get_path("l2", "l2_process"), filter=lambda record: record["extra"].get("name") == "l2_process",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 
 logger.add(get_path("l2", "l2_trade"), filter=lambda record: record["extra"].get("name") == "l2_trade",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 
 logger.add(get_path("juejin", "juejin_tick"), filter=lambda record: record["extra"].get("name") == "juejin_tick",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 
 logger.add(get_path("ths", "code_operate"), filter=lambda record: record["extra"].get("name") == "code_operate",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 
 logger.add(get_path("device", "device"), filter=lambda record: record["extra"].get("name") == "device",
-           rotation="00:00", compression="zip")
+           rotation="00:00", compression="zip", enqueue=True)
 
-
+logger.add(get_path("system", "system"), filter=lambda record: record["extra"].get("name") == "system",
+           rotation="00:00", compression="zip", enqueue=True)
 
 logger_trade_gui = logger.bind(name="trade_gui")
 logger_trade = logger.bind(name="trade")
@@ -41,6 +43,7 @@
 logger_juejin_tick = logger.bind(name="juejin_tick")
 logger_code_operate = logger.bind(name="code_operate")
 logger_device = logger.bind(name="device")
+logger_system = logger.bind(name="system")
 
 if __name__ == '__main__':
     logger_trade_gui.info("娴嬭瘯")

--
Gitblit v1.8.0