From 72c509e4bc814a83a306217d70547107e22837ec Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=96=87=E8=96=87=E5=AE=89?= Date: Wed, 14 Jan 2026 20:39:02 +0800 Subject: [PATCH] a --- trading_system/market_scanner.py | 6 +++--- trading_system/position_manager.py | 8 ++++---- 2 files changed, 7 insertions(+), 7 deletions(-) diff --git a/trading_system/market_scanner.py b/trading_system/market_scanner.py index 575f5c5..fcd9d7c 100644 --- a/trading_system/market_scanner.py +++ b/trading_system/market_scanner.py @@ -280,11 +280,11 @@ class MarketScanner: """ # 使用标准WebSocket try: - if self.client.socket_manager: - # python-binance 中，futures_socket() 需要传递 WebSocket 路径 + if self.client and self.client.client: + # 对于 AsyncClient，直接使用 client 的 futures_socket 方法 # 单个交易对的 ticker 流路径格式：f"{symbol.lower()}@ticker" ws_path = f"{symbol.lower()}@ticker" - async with self.client.socket_manager.futures_socket(ws_path) as stream: + async with self.client.client.futures_socket(ws_path) as stream: async for msg in stream: try: # WebSocket 返回的数据格式：{'e': '24hrTicker', 's': 'BTCUSDT', 'c': '50000.00', ...} diff --git a/trading_system/position_manager.py b/trading_system/position_manager.py index e450bf0..72cda9c 100644 --- a/trading_system/position_manager.py +++ b/trading_system/position_manager.py @@ -745,7 +745,7 @@ class PositionManager: logger.info("实时监控已禁用，跳过启动") return - if not self.client.socket_manager: + if not self.client or not self.client.client: logger.warning("WebSocket未初始化，无法启动实时监控") return @@ -824,7 +824,7 @@ class PositionManager: logger.debug(f"{symbol} 监控任务已存在，跳过") return - if not self.client.socket_manager: + if not self.client or not self.client.client: logger.warning(f"{symbol} WebSocket未初始化，无法启动监控") return @@ -873,10 +873,10 @@ class PositionManager: break # 使用WebSocket订阅价格流 - # python-binance 中，futures_socket() 需要传递 WebSocket 路径 + # 对于 AsyncClient，直接使用 client 的 futures_socket 方法 # 单个交易对的 ticker 流路径格式：f"{symbol.lower()}@ticker" ws_path = f"{symbol.lower()}@ticker" - async with self.client.socket_manager.futures_socket(ws_path) as stream: + async with self.client.futures_socket(ws_path) as stream: logger.debug(f"{symbol} WebSocket连接已建立，开始接收价格更新") retry_count = 0 # 连接成功，重置重试计数