当日代码板块日志记录

Administrator

2025-04-30 69b70c8effab52c2b64522759bd68219fd3c505c

当日代码板块日志记录

 l2_test.py

@@ -118,6 +118,8 @@
        codes = set()
        last_trade_day = HistoryKDatasUtils.get_latest_trading_date(1)[0]
        for code in zylt_volume_map:
            if code == '601288':
                print("")
            volume = zylt_volume_map.get(code)
            # 今日涨停价要突破昨日最高价
            k_bars = HistoryKDataManager().get_history_bars(code, last_trade_day)
@@ -141,6 +143,7 @@
        except:
            pass


def run():
    special_codes = __get_special_codes()
    codes_sh, codes_sz = l1_subscript_codes_manager.get_codes()
@@ -159,14 +162,14 @@
    for i in range(cpu_count):
        process = multiprocessing.Process(target=l2_client_test.run,
                                          args=(
                                          codes[i * page_size:(i + 1) * page_size], big_order_queue, big_accurate_order_queue, special_codes,))
                                              codes[i * page_size:(i + 1) * page_size], big_order_queue,
                                              big_accurate_order_queue, special_codes,))

        process.start()
        # 绑核运行
        psutil.Process(process.pid).cpu_affinity([i])
    threading.Thread(target=__run_upload_big_order_task, args=(big_order_upload_queue,), daemon=True).start()
    threading.Thread(target=__save_accurate_big_order, args=(big_accurate_order_queue,), daemon=True).start()


    while True:
        try:

 log_module/log.py

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

        # 看盘日志
        logger.add(self.get_path("kp", "kp_msg"),
                   filter=lambda record: record["extra"].get("name") == "kp_msg",
@@ -477,6 +481,10 @@

logger_plate_special_codes = __mylogger.get_logger("plate_special_codes")

logger_plate_code_plates = __mylogger.get_logger("plate_code_plates")







 third_data/kpl_api.py

@@ -326,7 +326,8 @@


if __name__ == "__main__":
    request_new_blocks_codes([("机器人", "801159")])
    print(getZYLTAmount("601288"))
    # request_new_blocks_codes([("机器人", "801159")])
    # result = getCodesByPlate("801159")  # getHistoryLimitUpInfo("2024-02-19")
    # result = json.loads(result)
    # for d in result["list"]:

 third_data/kpl_data_constant.py

@@ -2,9 +2,9 @@
import constant
from db import redis_manager_delegate as redis_manager
from db.redis_manager_delegate import RedisUtils
from log_module.log import logger_plate_code_plates
from third_data import kpl_util
from third_data.third_blocks_manager import BlockMapManager


from utils import tool, global_util
from utils.kpl_data_db_util import KPLLimitUpDataUtil
@@ -13,7 +13,6 @@
from utils.tool import singleton

open_limit_up_code_dict_for_radical_buy = None


# 新题材
new_blocks = set()
@@ -170,6 +169,8 @@
                print("")
            block_infos = kpl_block_dict.get(code)
            cls.__radical_buy_reasons_dict[code] = cls.__compute_limit_up_reasons(code, block_infos)
        # 将板块保存
        logger_plate_code_plates.info(f"{cls.__radical_buy_reasons_dict}")

    @classmethod
    def __compute_limit_up_reasons(cls, code, block_infos):