L2市场行情单独订阅

Administrator

2024-04-19 50797bbdab865297d1c872d7fcb0fd85c6ec1b0e

L2市场行情单独订阅

 huaxin_client/l2_market_client.py

@@ -94,6 +94,7 @@

    # 订阅代码,[代码,...]
    def set_codes_data(self, codes):
        print("订阅代码数量：", len(codes))
        try:
            self.__process_codes_data(codes)
        except Exception as e:
@@ -210,11 +211,11 @@
    logger_system.info("L2进程ID：{}", os.getpid())
    logger_system.info(f"l2_client 线程ID:{tool.get_thread_id()}")
    try:
        log.close_print()
        # log.close_print()
        # 初始化
        data_callback_distribute_manager = CodeDataCallbackDistributeManager(data_callbacks)
        l2_data_upload_manager = L2DataUploadManager(data_callback_distribute_manager)
        __init_l2(l2_data_upload_manager)
        # data_callback_distribute_manager = CodeDataCallbackDistributeManager(data_callbacks)
        # l2_data_upload_manager = L2DataUploadManager(data_callback_distribute_manager)
        __init_l2(None)
        # 订阅L2
        codes_sh, codes_sz = l1_subscript_codes_manager.get_codes()
        codes = set()