有没有大佬帮我解释下这个代码

basketmn

1. from websocket import create_connection
   
2. import gzip
   
3. import time
   
4. import json
   
5. from concurrent.futures import ThreadPoolExecutor
   
6. 
   
7. 
   
8. 
   
9. def get_ws_clinet():
   
10. 
    
11.     while True:
    
12.         try:
    
13.             ws = create_connection("wss://api.huobipro.com/ws")
    
14.             return ws
    
15.         except Exception as e:
    
16.             print('connect ws error,retry...')
    
17.             time.sleep(5)
    
18. 
    
19. 
    
20. def get_subscribe_data(trade):
    
21. 
    
22.     name = trade['sub'].split(".")[1]
    
23.     ws = get_ws_clinet()
    
24. 
    
25.     trade_json = json.dumps(trade)
    
26. 
    
27.     ws.send(trade_json)
    
28. 
    
29.     while True:
    
30.         compressData = ws.recv()
    
31.         result_json = gzip.decompress(compressData).decode('utf-8')
    
32. 
    
33.         result = json.loads(result_json)
    
34. 
    
35.         # {"ch":"market.btcusdt.kline.1min","ts":1609249181634,"tick":{"id":1609249140,"open":26846.04,"close":26865.54,"low":26844.23,"high":26865.55,"amount":4.39722167701809,"vol":118064.40113187107,"count":280}}
    
36. 
    
37.         data = result.get("tick", {})
    
38. 
    
39.         # 如果没有数据，表示websocket服务主动断开了连接，所以要保持心跳
    
40.         if not data:
    
41.             # 获取服务器发过来的心跳时间戳
    
42.             ts = result.get("pong", None) or result.get("ts", None)
    
43. 
    
44.             if not ts:
    
45.                 # 重新发起订阅请求
    
46.                 ws.send(trade_json)
    
47.                 continue
    
48.             else:
    
49.                 # 响应服务器心跳
    
50.                 ws.send(json.dumps({"ping": result.get("ts")}))
    
51.                 continue
    
52. 
    
53.         # print(data)
    
54. 
    
55.         bt_close = data.get("close")
    
56.         #a = data[1]
    
57. 
    
58. 
    
59.         print(name, '-----------',bt_close,type(bt_close))
    
60.         a = open("G:\lianghua\lianghua1.txt", 'w')
    
61.         a.write(name, '-----------',bt_close)
    
62.         a.close()
    
63. 
    
64. 
    
65. 
    
66. 
    
67. if __name__ == '__main__':
    
68. 
    
69.     # ws_client = get_ws_clinet()
    
70.     #
    
71.     # get_subscribe_data(ws_client)
    
72.     trades = [
    
73.         {"sub": "market.btcusdt.kline.1min", "id": "id10"},
    
74.         {"sub": "market.ethusdt.kline.1min", "id": "id10"},
    
75.         {"sub": "market.linkusdt.kline.1min", "id": "id10"},
    
76.         {"sub": "market.bchusdt.kline.1min", "id": "id10"},
    
77.         {"sub": "market.ltcusdt.kline.1min", "id": "id10"},
    
78.         {"sub": "market.bsvusdt.kline.1min", "id": "id10"},
    
79.         {"sub": "market.bsvusdt.kline.1min", "id": "id10"},
    
80.         {"sub": "market.adausdt.kline.1min", "id": "id10"},
    
81.         {"sub": "market.eosusdt.kline.1min", "id": "id10"},
    
82.     ]
    
83. 
    
84.     excuter = ThreadPoolExecutor()
    
85. 
    
86.     for trade in trades:
    
87.         excuter.submit(get_subscribe_data, trade)
    
88. 
    

复制代码

basketmn

最好是一步步解释下，谢谢！

basketmn

大佬，出来帮我解答下，感谢，感谢！

basketmn

顶