低吸日志收集

Administrator

2025-04-25 ec8e3e61886a88b48ebd3c0575d23bbfec3d791e

低吸日志收集

 code_attribute/global_data_loader.py

@@ -1,5 +1,6 @@
from code_attribute import code_volumn_manager, gpcode_manager
from db.mysql_data_delegate import Mysqldb
from log_module.log import logger_codes_zyltgb
from utils import global_util, ths_industry_util
from code_attribute.code_data_util import ZYLTGBUtil

@@ -36,6 +37,10 @@
    if fresults:
        for result in fresults:
            global_util.zylt_volume_map[result[0]] = result[1]
        try:
            logger_codes_zyltgb.info(f"{global_util.zylt_volume_map}")
        except:
            pass


# 加载名称代码隐射

 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)
@@ -231,6 +235,10 @@

        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"),
@@ -458,6 +466,11 @@

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")


@@ -514,6 +527,8 @@

# 收盘价日志
logger_pre_close_price = __mylogger.get_logger("pre_close_price")
logger_codes_zyltgb = __mylogger.get_logger("codes_zyltgb")



def close_print():

 servers/data_server.py

@@ -12,7 +12,8 @@
from code_attribute.gpcode_manager import BlackListCodeManager, HumanRemoveForbiddenManager
from l2.huaxin import huaxin_target_codes_manager
from l2.l2_transaction_data_manager import HuaXinBuyOrderManager
from log_module.log import logger_system, logger_debug, logger_kpl_limit_up, logger_request_api
from log_module.log import logger_system, logger_debug, logger_kpl_limit_up, logger_request_api, \
    logger_kpl_market_strong
from third_data.custom_block_in_money_manager import CodeInMoneyManager
from third_data.kpl_data_constant import LimitUpCodesBlockRecordManager, LimitUpDataConstant, \
    ContainsLimitupCodesBlocksManager
@@ -1234,11 +1235,10 @@
                RealTimeKplMarketData.set_market_jingxuan_out_blocks(result_list)
        elif type_ == KPLDataType.MARKET_STRONG.value:
            strong = data["data"]
            logger_debug.debug("开盘啦市场强度：{}", strong)
            logger_kpl_market_strong.info(strong)
            # 保存市场热度
            if strong is not None:
                RealTimeKplMarketData.set_market_strong(strong)

        return json.dumps({"code": 0})

    def __send_response(self, data):