全球股票实时行情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()