做美股数据开发那会儿，我特别想抓到每一笔真实的成交。普通行情推送只能看到最后一笔的价格和总量，可我想知道的是每一笔成交的细节——是大单砸下来的，还是散户一点一点吃上去的。刚开始我用轮询，每秒钟去拉一次，效果很差，市场一快起来就漏数据。后来试了WebSocket，才发现这才是逐笔成交该走的路。
逐笔成交数据跟普通行情不一样
很多人分不清逐笔成交和实时快照。快照是一段时间内（比如一秒）的汇总，告诉你这段时间的开盘、最高、最低、收盘和总成交量。逐笔成交则是每一次真实成交的独立记录，包含成交价、成交量、成交时间，有时候还有买卖方向。如果你想看大资金的动作，或者做盘口分析，逐笔数据是绕不过去的。
WebSocket订阅让数据主动来找你
HTTP轮询就像你不停地打电话问“有没有新数据”，WebSocket则是手机一直开着，服务器有消息就直接发给你。对于逐笔成交这种高频数据，WebSocket天然更合适。一条连接保持住，市场每成交一笔，我这边立刻就能收到，延迟极低。而且不用反复建立连接，系统开销小很多。
上手订阅美股逐笔数据
订阅美股api的逐笔成交，核心就是构建一个WebSocket客户端，发送订阅指令，然后处理推送过来的数据。以AllTick API为例，它的接口用起来挺顺手的，代码写起来也不复杂。
python import websocket import json def on_message(ws, message): data = json.loads(message) for trade in data.get("trades", []): symbol = trade.get("symbol") price = trade.get("price") volume = trade.get("volume") timestamp = trade.get("time") print(f"{symbol} 成交价 {price} 数量 {volume} 时间 {timestamp}") def on_open(ws): subscribe = { "action": "subscribe", "symbols": ["AAPL", "MSFT", "GOOGL"] } ws.send(json.dumps(subscribe)) ws = websocket.WebSocketApp( "wss://api.alltick.co/stock/ws", on_open=on_open, on_message=on_message ) ws.run_forever()跑起来之后，只要苹果、微软、谷歌有新的成交发生，终端就会实时打印出来。我通常会把逐笔数据存到一个队列里，避免处理太慢导致积压。
数据到手之后怎么用
逐笔数据量很大，尤其是热门股，高峰期一秒钟可能几十笔。我的做法是按照股票代码分组，每个代码维护一个最近成交的列表。这样不管是要计算加权平均价，还是判断是不是有大单异动，随时都能拿到。
有时候我也会把逐笔数据和盘口数据结合起来。比如看到一笔大额成交，再去对比当时的买卖挂单，就能大概判断这笔单子是主动买入还是卖出。这个在短线策略里挺实用的。
另外，订阅多只股票时，我会用一个字典来存储每个股票最新的几笔成交，界面展示时批量刷新，而不是每来一笔就刷新一次。这样程序跑起来很流畅，数据也不会丢。
一点个人看法
逐笔成交数据不是每个项目都需要。如果你只是做日线级别的回测，或者展示一天的开盘收盘，那普通的K线接口就够了。但如果你真的想看市场最细微的脉动，想捕捉每一笔真实的资金流动，那WebSocket订阅逐笔数据是唯一靠谱的方式。技术选型别贪多，合适自己的场景才是最好的。
