From ffed50b59629854d4f5a19ece14dc5b928d06b85 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 03 七月 2025 18:20:01 +0800
Subject: [PATCH] bug修复
---
log_module/log.py | 67 +++++++++++++++++++++++++++++++++
1 files changed, 67 insertions(+), 0 deletions(-)
diff --git a/log_module/log.py b/log_module/log.py
index 53eeca9..f245283 100644
--- a/log_module/log.py
+++ b/log_module/log.py
@@ -48,6 +48,10 @@
filter=lambda record: record["extra"].get("name") == "pre_close_price",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("code_attribute", "zylt_gb"),
+ filter=lambda record: record["extra"].get("name") == "codes_zyltgb",
+ rotation="00:00", compression="zip", enqueue=True)
+
# 鏄剧ず鍦ㄦ帶鍒跺彴
# logger.add(sys.stdout,
# filter=lambda record: record["extra"].get("name") == "l2_trade", enqueue=True)
@@ -122,6 +126,10 @@
logger.add(self.get_path("l2", "l2_radical_buy"),
filter=lambda record: record["extra"].get("name") == "l2_radical_buy",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("l2", "l2_radical_buy_data"),
+ filter=lambda record: record["extra"].get("name") == "l2_radical_buy_data",
rotation="00:00", compression="zip", enqueue=True)
logger.add(self.get_path("juejin", "juejin_tick"),
@@ -205,6 +213,12 @@
filter=lambda record: record["extra"].get("name") == "kpl_limit_up",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_path("kpl", "kpl_new_blocks"),
+ filter=lambda record: record["extra"].get("name") == "kpl_new_blocks",
+ 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)
@@ -219,6 +233,26 @@
logger.add(self.get_path("kpl", "kpl_jx_out"),
filter=lambda record: record["extra"].get("name") == "kpl_jx_out",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_jx_in"),
+ filter=lambda record: record["extra"].get("name") == "kpl_jx_in",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_latest_gaobiao"),
+ filter=lambda record: record["extra"].get("name") == "kpl_latest_gaobiao",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("kpl", "kpl_market_strong"),
+ filter=lambda record: record["extra"].get("name") == "kpl_market_strong",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("plates", "special_codes"),
+ filter=lambda record: record["extra"].get("name") == "plate_special_codes",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_path("plates", "code_plates"),
+ filter=lambda record: record["extra"].get("name") == "plate_code_plates",
rotation="00:00", compression="zip", enqueue=True)
# 鐪嬬洏鏃ュ織
@@ -298,6 +332,14 @@
logger.add(self.get_local_huaxin_path("l2", "transaction"),
filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction",
rotation="00:00", compression="zip", enqueue=True)
+ logger.add(self.get_local_huaxin_path("l2", "transaction_big_order"),
+ filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction_for_big_order",
+ rotation="00:00", compression="zip", enqueue=True)
+
+ logger.add(self.get_local_huaxin_path("l2", "transaction_accurate_big_order"),
+ filter=lambda record: record["extra"].get("name") == "local_huaxin_transaction_for_accurate_big_order",
+ rotation="00:00", compression="zip", enqueue=True)
+
logger.add(self.get_local_huaxin_path("l2", "orderdetail"),
filter=lambda record: record["extra"].get("name") == "local_huaxin_orderdetail",
rotation="00:00", compression="zip", enqueue=True)
@@ -426,6 +468,8 @@
logger_kpl_limit_up = __mylogger.get_logger("kpl_limit_up")
+logger_kpl_new_blocks = __mylogger.get_logger("kpl_new_blocks")
+
logger_kpl_debug = __mylogger.get_logger("kpl_debug")
logger_kpl_block_can_buy = __mylogger.get_logger("kpl_block_can_buy")
@@ -433,6 +477,23 @@
logger_kpl_open_limit_up = __mylogger.get_logger("kpl_open_limit_up")
logger_kpl_jx_out = __mylogger.get_logger("kpl_jx_out")
+
+logger_kpl_jx_in = __mylogger.get_logger("kpl_jx_in")
+
+logger_kpl_latest_gaobiao = __mylogger.get_logger("kpl_latest_gaobiao")
+
+# 寮�鐩樺暒甯傚満寮哄害
+logger_kpl_market_strong = __mylogger.get_logger("kpl_market_strong")
+
+
+
+logger_plate_special_codes = __mylogger.get_logger("plate_special_codes")
+
+logger_plate_code_plates = __mylogger.get_logger("plate_code_plates")
+
+
+
+
@@ -447,6 +508,8 @@
logger_buy_strategy = __mylogger.get_logger("buy_strategy")
logger_l2_radical_buy = __mylogger.get_logger("l2_radical_buy")
+
+logger_l2_radical_buy_data = __mylogger.get_logger("l2_radical_buy_data")
# -------------------------------鍗庨懌鏃ュ織---------------------------------
hx_logger_l2_orderdetail = __mylogger.get_logger("hx_l2_orderdetail")
@@ -469,6 +532,8 @@
# -------------------------------鍗庨懌鏈湴鏃ュ織---------------------------------
logger_local_huaxin_l2_transaction = __mylogger.get_logger("local_huaxin_transaction")
+logger_local_huaxin_l2_transaction_big_order = __mylogger.get_logger("local_huaxin_transaction_for_big_order")
+logger_local_huaxin_l2_transaction_accurate_big_order = __mylogger.get_logger("local_huaxin_transaction_for_accurate_big_order")
logger_local_huaxin_l2_orderdetail = __mylogger.get_logger("local_huaxin_orderdetail")
logger_local_huaxin_l2_upload = __mylogger.get_logger("local_huaxin_upload")
logger_local_huaxin_l2_error = __mylogger.get_logger("local_huaxin_error")
@@ -483,6 +548,8 @@
# 鏀剁洏浠锋棩蹇�
logger_pre_close_price = __mylogger.get_logger("pre_close_price")
+logger_codes_zyltgb = __mylogger.get_logger("codes_zyltgb")
+
def close_print():
--
Gitblit v1.8.0