實時金融股票數據對於投資者和交易員來説至關重要。通過使用WebSocket接入方法，可以輕鬆獲取實時金融股票類數據並及時做出決策。WebSocket是一種高效的雙向通信協議，它允許數據的實時推送，避免了不斷的輪詢請求。這種接入方法具有多個優勢。
1、首先，它提供了快速的股票數據傳輸速度，確保您獲取到最新的市場行情數據。其次，WebSocket允許您訂閲特定的股票數據源或股票數據產品，只接收您感興趣的信息，提高了數據的效率和可用性。
2、此外，WebSocket接口通常具有穩定的連接性，能夠處理大量的數據推送，滿足高頻交易和實時分析的需求。
3、通過使用實時金融數據API接口的WebSocket接入方法，您可以更好地監測市場數據動態，及時抓住交易機會，為您的金融決策提供有力支持。
接入步驟
通過API地址傳參建立連接
先按照下面地址申請token: https://infoway.io
Github項目地址：https://github.com/infoway-api/realtime-market-data-api
按照下面代碼建立連接
股票產品訂閲地址：
wss://data.infoway.io/ws?business=stock&apikey=YourAPIKey
數字幣產品訂閲地址：
wss://data.infoway.io/ws?business=crypto&apikey=YourAPIKey
外匯、期貨等產品訂閲地址：
wss://data.infoway.io/ws?business=common&apikey=YourAPIKey
建立連接之後，就可以訂閲具體的接口數據了，具體調用方式看第二步
查看code產品列表
該接口可查詢以下品類:
- 美股數據
- 港股數據
- A股數據
- 外匯數據
- 貴金屬數據
- 商品數據
- 數字幣數據
更詳細的產品列表可以在官網下載。
開始真正的訂閲實時行情數據源報價
當你選擇好產品code列表後就可以開始真正的訂閲實時行情數據源報價了。
請看下面的實例代碼：
import json
import time
import schedule
import threading
import websocket
from loguru import logger
class WebsocketExample:
def __init__(self):
self.session = None
self.ws_url = "wss://data.infoway.io/ws?business=crypto&apikey=yourApikey"
self.reconnecting = False
self.is_ws_connected = False # 添加連接狀態標誌
def connect_all(self):
"""建立WebSocket連接並啓動自動重連機制"""
try:
self.connect(self.ws_url)
self.start_reconnection(self.ws_url)
except Exception as e:
logger.error(f"Failed to connect to {self.ws_url}: {str(e)}")
def start_reconnection(self, url):
"""啓動定時重連檢查"""
def check_connection():
if not self.is_connected():
logger.debug("Reconnection attempt...")
self.connect(url)
# 使用線程定期檢查連接狀態
schedule.every(10).seconds.do(check_connection)
def run_scheduler():
while True:
schedule.run_pending()
time.sleep(1)
threading.Thread(target=run_scheduler, daemon=True).start()
def is_connected(self):
"""檢查WebSocket連接狀態"""
return self.session and self.is_ws_connected
def connect(self, url):
"""建立WebSocket連接"""
try:
if self.is_connected():
self.session.close()
self.session = websocket.WebSocketApp(
url,
on_open=self.on_open,
on_message=self.on_message,
on_error=self.on_error,
on_close=self.on_close
)
# 啓動WebSocket連接（非阻塞模式）
threading.Thread(target=self.session.run_forever, daemon=True).start()
except Exception as e:
logger.error(f"Failed to connect to the server: {str(e)}")
def on_open(self, ws):
"""WebSocket連接建立成功後的回調"""
logger.info(f"Connection opened")
self.is_ws_connected = True # 設置連接狀態為True
try:
# 發送實時成交明細訂閲請求
trade_send_obj = {
"code": 10000,
"trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
"data": {"codes": "BTCUSDT"}
}
self.send_message(trade_send_obj)
# 不同請求之間間隔一段時間
time.sleep(5)
# 發送實時盤口數據訂閲請求
depth_send_obj = {
"code": 10003,
"trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
"data": {"codes": "BTCUSDT"}
}
self.send_message(depth_send_obj)
# 不同請求之間間隔一段時間
time.sleep(5)
# 發送實時K線數據訂閲請求
kline_data = {
"arr": [
{
"type": 1,
"codes": "BTCUSDT"
}
]
}
kline_send_obj = {
"code": 10006,
"trace": "01213e9d-90a0-426e-a380-ebed633cba7a",
"data": kline_data
}
self.send_message(kline_send_obj)
# 啓動定時心跳任務
schedule.every(30).seconds.do(self.ping)
except Exception as e:
logger.error(f"Error sending initial messages: {str(e)}")
def on_message(self, ws, message):
"""接收消息的回調"""
try:
logger.info(f"Message received: {message}")
except Exception as e:
logger.error(f"Error processing message: {str(e)}")
def on_close(self, ws, close_status_code, close_msg):
"""連接關閉的回調"""
logger.info(f"Connection closed: {close_status_code} - {close_msg}")
self.is_ws_connected = False # 設置連接狀態為False
def on_error(self, ws, error):
"""錯誤處理的回調"""
logger.error(f"WebSocket error: {str(error)}")
self.is_ws_connected = False # 發生錯誤時設置連接狀態為False
def send_message(self, message_obj):
"""發送消息到WebSocket服務器"""
if self.is_connected():
try:
self.session.send(json.dumps(message_obj))
except Exception as e:
logger.error(f"Error sending message: {str(e)}")
else:
logger.warning("Cannot send message: Not connected")
def ping(self):
"""發送心跳包"""
ping_obj = {
"code": 10010,
"trace": "01213e9d-90a0-426e-a380-ebed633cba7a"
}
self.send_message(ping_obj)
# 使用示例
if __name__ == "__main__":
ws_client = WebsocketExample()
ws_client.connect_all()
# 保持主線程運行
try:
while True:
schedule.run_pending()
time.sleep(1)
except KeyboardInterrupt:
logger.info("Exiting...")
if ws_client.is_connected():
ws_client.session.close()解析推送數據
實時K線解析
{
"s": "002594.SZ", //產品代碼
"respList": [
{
"t": "1751958000", //秒時間戳（UTC+8）
"h": "326.880", //最高價
"o": "326.880", //開盤價
"l": "326.880", //最低價
"c": "326.880", //收盤價
"v": "1410", //成交量
"vw": "460900.80", //成交額
"pc": "0.00%", //漲跌幅
"pca": "0.000" //漲跌額
}
]
}最新成交報價解析
{
"s": "AMZN.US", //產品代碼
"t": 1752883185720, //毫秒時間戳(UTC+8)
"p": "225.975", //交易價格
"v": "1", //成交量
"vw": "225.975", //成交額
"td": 0 //交易方向 1：BUY 2：SELL 0：默認值
}最新5檔深度數據解析
{
"s": "002594.SZ", //產品代碼
"t": 1751958003335, //毫秒時間戳(UTC+8)
"a": [ //買盤
[
"326.89", //買一價
"326.90", //買二價
"326.91", //買三價
"326.92", //買四價
"326.93" //買五價
],
[
"8", //買一量
"30", //買二量
"10", //買三量
"1", //買四量
"22" //買五量
]
],
"b": [ //賣盤
[
"326.88", //賣一價
"326.87", //賣二價
"326.86", //賣三價
"326.85", //賣四價
"326.84" //賣五價
],
[
"1452", //賣一量
"77", //賣二量
"188", //賣三量
"37", //賣四量
"21" //賣五量
]
]
}
錯誤碼説明
500: 服務異常
501：請求頻率超出一分鐘限制
505：產品數量超出限制
506：參數缺失
515：參數不是json格式
513：Websocket心跳超時
401：認證錯誤，API Key不正確，或者未將API Key放置在指定header或query中
404：API接口不存在
429：請求頻率限制，請求不符合您當前套餐配額
499：客户端主動中斷，通常發生在網絡不穩定的地區，請在良好網絡環境連接
524：源服務器連接超時，通常發生在我們加速代理提供商到我們服務器之間不穩定導致，一般很快就能恢復
Websocket的優勢
通過實時金融數據API接口的WebSocket接入方法，您可以享受到及時、高效的金融數據API服務。這種接入方式為投資者和交易員提供了許多優勢和便利。
1、首先，實時數據的獲取使您能夠緊跟市場的變化，及時獲取到最新的股票價格、交易量等關鍵信息。這對於制定交易決策和執行高頻交易策略至關重要。其次，WebSocket的雙向通信特性使您能夠實時訂閲和接收您感興趣的數據源或產品，避免了不必要的數據冗餘和網絡資源浪費。
2、此外，WebSocket接口通常具有較低的延遲和可靠的連接性，能夠處理大規模的數據推送，確保您獲取到準確的實時數據。
3、最重要的是，這種接入方法為您提供了強大的靈活性和定製化能力，您可以根據自己的需要和策略要求訂閲特定的數據，進行個性化的數據分析和決策支持。
綜上所述，實時金融數據API接口的WebSocket接入方法是現代金融交易和投資領域中不可或缺的工具，它為用户提供了快速、可靠的數據傳輸和個性化的數據訂閲服務，幫助他們在競爭激烈的市場中搶佔先機，實現更好的投資回報。
