From 0b0d0e790fec8c7edfdbcab5c31d625e0c2eadd6 Mon Sep 17 00:00:00 2001
From: admin <admin@example.com>
Date: 星期四, 19 六月 2025 16:54:49 +0800
Subject: [PATCH] 添加必要的数据日志
---
log_module/log.py | 25 +++++++++++++++++++++++++
1 files changed, 25 insertions(+), 0 deletions(-)
diff --git a/log_module/log.py b/log_module/log.py
index 74f7cbb..b0ff0fa 100644
--- a/log_module/log.py
+++ b/log_module/log.py
@@ -201,6 +201,19 @@
filter=lambda record: record["extra"].get("name") == "kpl_open_limit_up",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("kpl", "kpl_code_plates"),
+ filter=lambda record: record["extra"].get("name") == "kpl_code_plates",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ # K绾挎棩蹇�
+ logger.add(self.get_path("kbars", "k_bars"),
+ filter=lambda record: record["extra"].get("name") == "k_bars",
+ rotation="00:00", compression="zip", enqueue=True)
+ # 鐩爣绁�
+ logger.add(self.get_path("codes", "target_codes"),
+ filter=lambda record: record["extra"].get("name") == "target_codes",
+ rotation="00:00", compression="zip", enqueue=True)
+
# 鐪嬬洏鏃ュ織
logger.add(self.get_path("kp", "kp_msg"),
filter=lambda record: record["extra"].get("name") == "kp_msg",
@@ -323,6 +336,10 @@
filter=lambda record: record["extra"].get("name") == "stock_of_markets_plate",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("kpl", "stock_of_markets_plate_simple"),
+ filter=lambda record: record["extra"].get("name") == "stock_of_markets_plate_simple",
+ rotation="00:00", compression="zip", enqueue=True)
+
def get_path(self, dir_name, log_name):
path_str = "{}/{}/gp/{}/{}".format(constant.get_path_prefix(), constant.LOG_DIR, dir_name,
log_name) + ".{time:YYYY-MM-DD}.log"
@@ -420,6 +437,13 @@
logger_kp_msg = __mylogger.get_logger("kp_msg")
+logger_kpl_code_plates = __mylogger.get_logger("kpl_code_plates")
+
+logger_k_bars = __mylogger.get_logger("k_bars")
+
+logger_target_codes = __mylogger.get_logger("target_codes")
+
+
logger_redis_debug = __mylogger.get_logger("redis_debug")
logger_profile = __mylogger.get_logger("profile")
@@ -451,6 +475,7 @@
logger_kpl_market_sift_plate = __mylogger.get_logger("kpl_market_sift_plate")
logger_Overall_market_strength_score = __mylogger.get_logger("Overall_market_strength_score")
logger_stock_of_markets_plate = __mylogger.get_logger("stock_of_markets_plate")
+logger_stock_of_markets_plate_simple = __mylogger.get_logger("stock_of_markets_plate_simple")
logger_common = __mylogger.get_logger("common")
--
Gitblit v1.8.0