91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

詳解python websocket獲取實時數據的幾種常見鏈接方式

發布時間:2020-08-20 01:37:42 來源:腳本之家 閱讀:346 作者:Jerry_JD 欄目:開發技術

第一種, 使用create_connection鏈接,需要pip install websocket-client (此方法不建議使用,鏈接不穩定,容易斷,并且連接很耗時)

import time
from websocket import create_connection

url = '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)
    continue
while True: # 連接上,退出第一個循環之后,此循環用于一直獲取數據
  ws.send('{"event":"subscribe", "channel":"btc_usdt.ticker"}')
  response = ws.recv()
  print(response)

第二種,運行效果很不錯,很容易連接,獲取數據的速度也挺快

import json
from ws4py.client.threadedclient import WebSocketClient


class 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 websocket

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

第四種,運行效果也可以,run_forever里面有許多參數,需要自己設置

import websocket


def 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)

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

社会| 全椒县| 岢岚县| 凯里市| 鞍山市| 孝昌县| 邓州市| 诏安县| 武宁县| 赞皇县| 景宁| 广南县| 天门市| 同江市| 行唐县| 安溪县| 咸阳市| 台安县| 小金县| 武川县| 遂溪县| 铜山县| 上思县| 镇雄县| 无极县| 三门县| 会理县| 奎屯市| 依兰县| 常德市| 盐津县| 瓮安县| 英德市| 驻马店市| 枣阳市| 恩施市| 北安市| 江城| 墨脱县| 南康市| 新营市|