添加日志

Administrator

2025-04-25 de247893ed5f5ae98f124c3ae5cde7af0276c797

添加日志

 log_module/log.py

@@ -229,6 +229,14 @@
                   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("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("kp", "kp_msg"),
                   filter=lambda record: record["extra"].get("name") == "kp_msg",
@@ -448,6 +456,12 @@

logger_kpl_jx_in = __mylogger.get_logger("kpl_jx_in")

logger_kpl_latest_gaobiao = __mylogger.get_logger("kpl_latest_gaobiao")

logger_plate_special_codes = __mylogger.get_logger("plate_special_codes")





logger_kp_msg = __mylogger.get_logger("kp_msg")

 third_data/code_plate_key_manager.py

@@ -22,7 +22,8 @@
from log_module import async_log_util
from db import redis_manager_delegate as redis_manager, mysql_data_delegate as mysql_data

from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out, logger_kpl_jx_in, logger_debug
from log_module.log import logger_kpl_block_can_buy, logger_kpl_jx_out, logger_kpl_jx_in, logger_debug, \
    logger_kpl_latest_gaobiao
from third_data.kpl_util import KPLPlatManager
from trade import l2_trade_util, trade_constant

@@ -372,6 +373,7 @@
                block_codes[b].add(code)
        print(block_codes)
        cls.__watch_block_high_codes = block_codes
        logger_kpl_latest_gaobiao.info(f"{block_codes}")
        cls.__watch_high_codes.clear()
        for b in block_codes:
            cls.__watch_high_codes |= block_codes[b]

 trade/buy_radical/block_special_codes_manager.py

@@ -5,6 +5,7 @@

import constant
from db import mysql_data_delegate as mysql_data
from log_module.log import logger_plate_special_codes
from third_data import kpl_util
from third_data.history_k_data_util import HistoryKDatasUtils
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager
@@ -36,6 +37,11 @@
            self.__code_blocks_dict[code].add(block)
            temp_dict[block].add(code)
        self.__block_codes_dict = temp_dict
        # 保存辨识度的日志
        try:
            logger_plate_special_codes.info(f"{temp_dict}")
        except:
            pass

    def get_block_codes(self, block):
        return self.__block_codes_dict.get(block, set()) | self.__temp_block_codes_dict.get(block, set())

 trade/buy_radical/radical_buy_data_manager.py

@@ -2004,6 +2004,13 @@
            except Exception as e:
                logger_debug.exception(e)

def pull_pre_deal_big_orders_by_codes(codes):
    for code in codes:
        try:
            pull_pre_deal_big_orders(code)
        except Exception as e:
            logger_debug.exception(e)


def get_l2_big_order_deal_info(code_):
    """

 trade/current_price_process_manager.py

@@ -251,8 +251,7 @@
                dif2 = add_code_set - latest_add_codes
                if dif2:
                    # 新增加的订阅需要拉取之前的大单
                    for c in dif2:
                        __pre_big_order_deal_thread_pool.submit(radical_buy_data_manager.pull_pre_deal_big_orders, c)
                    __pre_big_order_deal_thread_pool.submit(radical_buy_data_manager.pull_pre_deal_big_orders_by_codes, dif2)
                if True:
                    async_log_util.info(logger_l2_codes_subscript,
                                        f"({request_id})预处理新增订阅代码：{dif2}")