详解python websocket获取实时数据的几种常见链接方式

import timefrom websocket import create_connectionurl = 'wss://i.cg.net/wi/ws'while True: # 一直链接，直到连接上就退出循环  time.sleep(2)  try:    ws = create_connection(url)    print(ws)    break  except Exception as e:    print('连接异常：', e)    continuewhile True: # 连接上，退出第一个循环之后，此循环用于一直获取数据  ws.send('{"event":"subscribe", "channel":"btc_usdt.ticker"}')  response = ws.recv()  print(response)

import jsonfrom ws4py.client.threadedclient import WebSocketClientclass CG_Client(WebSocketClient):  def opened(self):    req = '{"event":"subscribe", "channel":"eth_usdt.deep"}'    self.send(req)  def closed(self, code, reason=None):    print("Closed down:", code, reason)  def received_message(self, resp):    resp = json.loads(str(resp))    data = resp['data']    if type(data) is dict:      ask = data['asks'][0]      print('Ask:', ask)      bid = data['bids'][0]      print('Bid:', bid)if __name__ == '__main__':  ws = None  try:    ws = CG_Client('wss://i.cg.net/wi/ws')    ws.connect()    ws.run_forever()  except KeyboardInterrupt:    ws.close()

import websocketwhile True:  ws = websocket.WebSocket()  try:    ws.connect("wss://i.cg.net/wi/ws")    print(ws)    break  except Exception as e:    print('异常：', e)    continueprint('OK')while True:  req = '{"event":"subscribe", "channel":"btc_usdt.deep"}'  ws.send(req)  resp = ws.recv()  print(resp)

import websocketdef on_message(ws, message): # 服务器有数据更新时，主动推送过来的数据  print(message)def on_error(ws, error): # 程序报错时，就会触发on_error事件  print(error)def on_close(ws):  print("Connection closed ……")def on_open(ws): # 连接到服务器之后就会触发on_open事件，这里用于send数据  req = '{"event":"subscribe", "channel":"btc_usdt.deep"}'  print(req)  ws.send(req)if __name__ == "__main__":  websocket.enableTrace(True)  ws = websocket.WebSocketApp("wss://i.cg.net/wi/ws",                on_message=on_message,                on_error=on_error,                on_close=on_close)  ws.on_open = on_open  ws.run_forever(ping_timeout=30)