成功接入美股行情api与港股行情api同步获取

在做多市场行情分析的时候，我一直希望能同时看到美股和港股的价格动向。以前都是分开开几个终端看，后来发现，把数据拉到同一个环境里处理更直观，也方便快速对比。

像我这样做的一个思路是，通过 WebSocket 连接，把不同市场的行情数据分线程接入，然后在内存里整理成表格。以AllTick API为例，建立连接、订阅数据和处理消息的流程可以很直观地管理多市场行情。

建立多市场连接

基本思路是，每个市场开一个 WebSocket 线程，订阅对应的股票代码，接收到的数据统一整理。Python 示例如下：

import websocket import json import pandas as pd from threading import Thread def handle_message(ws, message): data = json.loads(message) # 整理成表格 df = pd.DataFrame(data) print(df.head()) def handle_error(ws, error): print("Error:", error) def handle_close(ws, close_status_code, close_msg): print("连接关闭") def start_socket(): ws_url = "wss://realtime.alltick.co/ws" ws = websocket.WebSocketApp( ws_url, on_message=handle_message, on_error=handle_error, on_close=handle_close ) ws.run_forever() if __name__ == "__main__": Thread(target=start_socket).start()

这段代码可以同时接收美股行情api和港股行情api的数据，通过多线程保证不同市场的数据互不干扰。接收到的数据可以直接整理成表格，便于快速浏览或进一步分析。

数据整理与分析

拿到数据后，我通常会做两件事：整理成表格和计算涨跌幅。这样在观察市场动向时更加直观。示例如下：

像上面这样整理之后，无论是观察短期波动还是进行跨市场对比，都可以直接使用。数据可以在内存中更新，也可以按需写入文件或者数据库，便于后续分析。

多市场同步小技巧

实际操作中发现：

• 用线程处理不同市场行情可以保证数据同步性

• 接收到数据后，先整理成统一表格再处理，比边收边算更稳定

• 对于大规模股票订阅，统一管理订阅列表和回调函数可以减少重复操作

通过这种方式，美股行情api和港股行情api的数据就能同时到手，保持实时更新。对开发者来说，关键是把数据整理成方便使用的格式，而不是单纯看接口或文档。