| | |
|---|
| | | |
|---|
| | | # 订阅代码,[代码,...] |
|---|
| | | def set_codes_data(self, codes): |
|---|
| | | print("订阅代码数量：", len(codes)) |
|---|
| | | try: |
|---|
| | | self.__process_codes_data(codes) |
|---|
| | | except Exception as e: |
|---|
| | |
|---|
| | | 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() |
|---|
