Python虚拟环境中On-Tick回调未执行问题排查

1. WebSocket连接生命周期问题 #

你的代码在建立WebSocket连接、订阅行情后，立刻调用了breeze.ws_disconnect()，导致连接刚建立就被断开，回调函数on_ticks根本没有足够时间接收并处理数据。

• 本地环境可能因运行延迟刚好能触发少量回调，但虚拟环境执行效率更高，直接跳过了回调阶段。
• 修复方案：添加等待逻辑，让程序在断开前留足时间接收数据，比如：

  import time
  
  # ... 订阅行情代码后
  print("Subscribed to ADAENT options")
  time.sleep(15)  # 等待15秒接收数据
  breeze.ws_disconnect()
  

  如果BreezeConnect基于异步事件循环，需启动循环维持连接，比如使用asyncio的事件循环（根据库的实际实现调整）。

2. API凭证配置不一致 #

代码中api_key、api_secret、session_token均为空字符串，实际运行时：

• 本地环境可能通过环境变量、配置文件等方式注入了有效凭证，但虚拟环境未正确配置，导致会话生成失败，WebSocket无法正常接收数据。
• 排查：确认虚拟环境中使用的凭证与本地一致且有效，可在generate_session后添加会话有效性校验。

3. 输出被Django命令环境抑制 #

Django管理命令在虚拟环境运行时，标准输出（print）可能被重定向或日志级别限制，导致回调的打印内容无法显示。

• 替换print为Django日志系统，确保输出能被捕获：

  from django.core.management.base import BaseCommand
  import logging
  
  logger = logging.getLogger(__name__)
  
  class Command(BaseCommand):
      def handle(self, *args: Any, **options: Any):
          # ...
          def on_ticks(ticks):
              logger.info("Ticks: {}".format(ticks))
          # ...
  

  之后查看Django的日志输出确认是否有数据。

4. 依赖包版本差异 #

本地与虚拟环境的WebSocket相关依赖（如websocket-client、asyncio等）版本不一致，导致虚拟环境中WebSocket连接逻辑异常。

• 排查：分别在两个环境执行pip freeze，对比依赖版本，确保关键包版本一致。

5. 网络/防火墙限制 #

虚拟环境所在环境（如服务器、容器）存在防火墙、代理，阻止了WebSocket连接或数据传输，导致无法接收行情数据。

• 排查：在虚拟环境中测试能否连接Breeze的WebSocket服务器，比如使用wscat工具（需安装）：

  wscat -c wss://<breeze-websocket-endpoint>
  

内容的提问来源于stack exchange，提问作者servicenet