| | |
| | | codes_sz.append(code.encode("utf-8")) |
| | | else: |
| | | codes_sh.append(code.encode("utf-8")) |
| | | print("获取订阅目标代数量:", len(codes_sh), len(codes_sz)) |
| | | return codes_sh, codes_sz |
| | | except ConnectionResetError: |
| | | SendResponseSkManager.del_send_response_sk(type_) |
| | |
| | | |
| | | |
| | | def run(pipe_l2): |
| | | time.sleep(10) |
| | | codes_sh = [] |
| | | codes_sz = [] |
| | | for i in range(3): |
| | | try: |
| | | codes_sh, codes_sz = get_level1_codes() |
| | | except: |
| | | time.sleep(2) |
| | | time.sleep(4) |
| | | |
| | | # 打印接口版本号 |
| | | print(xmdapi.CTORATstpXMdApi_GetApiVersion()) |
| | |
| | | api = xmdapi.CTORATstpXMdApi_CreateTstpXMdApi(xmdapi.TORA_TSTP_MST_MCAST) |
| | | |
| | | # 创建回调对象 |
| | | spi = MdSpi(api,codes_sh,codes_sz) |
| | | spi = MdSpi(api, codes_sh, codes_sz) |
| | | |
| | | # 注册回调接口 |
| | | api.RegisterSpi(spi) |