做行情系统时我遇到过一个比较常见的问题实时行情一直正常但因为网络波动导致连接断开几秒本地保存的数据就出现了缺口。这种情况在加密货币行情里比较明显因为市场交易不会停止。如果缺少一段数据后面生成K线、计算指标时可能出现偏差。后来我发现数据恢复的关键不是简单重新连接而是利用时间戳找到缺失位置让本地数据和行情数据重新对应。数据中断后为什么容易出现错位很多行情接口会通过WebSocket推送实时数据这种方式延迟较低但连接稳定性会受到网络影响。比如本地正在接收行情时间状态10:00:00正常接收10:00:01正常接收10:00:02连接断开10:00:03-10:00:08数据缺失10:00:09恢复连接重新连接后系统只能继续接收最新数据中间缺少的行情不会自动回来。如果直接保存恢复后的数据本地记录会出现时间断层。所以需要先判断缺失区间再补充对应时间的数据。利用时间戳找到缺失范围我一般会给每条行情记录保存时间戳字段例如{ symbol: BTCUSDT, price: 68000.5, timestamp: 1783425602000 }程序运行过程中会持续记录最新一条数据的timestamp。当连接恢复后将本地最后时间和当前行情时间进行比较本地时间1783425602000最新时间1783425609000如果中间存在差距就说明可能有数据遗漏。这时可以根据时间范围重新获取数据再按照timestamp排序写入数据库让行情重新连续起来。数据恢复时需要注意什么补数据时最容易出现的问题就是重复保存。很多行情价格可能连续几秒保持不变如果只通过价格判断是否重复会误删正常数据。更合适的方法是使用unique_key symbol timestamp通过交易品种和时间戳组合判断数据是否已经存在。另外不同接口返回的时间格式可能不同有的是秒级时间戳有的是毫秒级时间戳。进入系统后统一转换可以减少后续处理中的麻烦。以通过WebSocket获取实时tick数据为例使用AllTick API接入行情时可以根据返回数据中的时间字段保存最新位置再根据断线期间的时间范围补充缺失数据。import websocket import json def on_message(ws, message): data json.loads(message) symbol data.get(symbol) timestamp data.get(timestamp) print(symbol, timestamp) ws websocket.WebSocketApp( wss://apis.alltick.co/websocket-api/stock-websocket-interface-api/transaction-quote-subscription, on_messageon_message ) ws.run_forever()建立简单的数据恢复机制在实际项目里我会把实时接收和数据恢复分开处理。实时部分负责接收最新行情并保存最后时间戳恢复部分负责检查时间缺口再补齐中断期间的数据。整个流程可以简单理解为步骤作用记录最后时间确定数据位置检测时间差发现缺失范围补充历史数据恢复中断行情时间排序去重保证数据准确这种方式不会依赖人工检查也能避免因为短暂网络异常导致整个行情链路出现问题。我的经验行情系统真正稳定不只是看平时能不能收到数据还要看异常情况下能不能恢复。对于加密货币api来说时间戳并不是简单的时间记录它连接了实时行情、本地存储和历史数据三个部分。把时间校准机制设计好即使遇到短暂中断也能让数据保持完整为后续分析和策略运行提供更可靠的基础。