全球股票即時行情API：量化交易的終極數據引擎

      """
**iTick**：是一家數據代理機構，為金融科技公司和開發者提供可靠的數據源APIs，涵蓋外匯API、股票API、加密貨幣API、指數API等，幫助構建創新的交易和分析工具，目前有免費的套餐可以使用基本可以滿足個人量化開發者需求
開源股票數據接口地址
https://github.com/itick-org
申請免費Apikey地址
https://itick.org
"""

import websocket
import json

# WebSocket伺服器的地址
websocket_url = "wss://api.itick.org/sws"

# 用於鑒權
auth_message = {
    "ac":"auth",
    "params":"YOUR_KEY"
}

# 用於訂閱的消息格式，這裡假設訂閱一個名為 "your_channel" 的頻道
subscribe_message = {
    "ac":"subscribe",
    "params":"700$HK,AAPL$US,TSLA$US",
    "types":"depth,quote"
}

def on_open(ws):
        """
        當WebSocket連接打開時調用的函數
        """
        print("WebSocket連接已打開，正在發送鑒權消息...")

        # 發送鑒權消息
        ws.send(json.dumps(auth_message))

        # 將訂閱消息轉換為JSON格式並發送
        ws.send(json.dumps(subscribe_message))

def on_message(ws, message):
        """
        當收到WebSocket消息時調用的函數
        """
        print(f"收到消息: {message}")
        # 這裡可以根據收到的消息內容進行進一步的處理，比如解析JSON數據等
        data = json.loads(message)
        if "data" in data:
                print(f"數據內容: {data['data']}")

def on_error(ws, error):
        """
        當WebSocket連接出現錯誤時調用的函數
        """
        print(f"WebSocket錯誤: {error}")

def on_close(ws, close_status_code, close_msg):
        """
        當WebSocket連接關閉時調用的函數
        """
        print(f"WebSocket連接已關閉，狀態碼: {close_status_code}，消息: {close_msg}")

if __name__ == "__main__":
        # 創建WebSocket對象並設置回調函數
        ws = websocket.WebSocketApp(websocket_url,
                                                                on_open=on_open,
                                                                on_message=on_message,
                                                                on_error=on_error,
                                                                on_close=on_close)

        # 啟動WebSocket連接，開始監聽消息
        ws.run_forever()