From ca959c1f8a0e81c6caf94e97a20629e695ffc1ac Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=96=87=E8=96=87=E5=AE=89?= Date: Sat, 14 Feb 2026 13:57:04 +0800 Subject: [PATCH] 1 --- API_KEY_与IP限频说明.md | 72 ++++++++++++++++++++++++++++++++++++ backend/api/routes/stats.py | 68 +++++++++++++++++++++------------- trading_system/strategy.py | 12 +++++- 3 files changed, 125 insertions(+), 27 deletions(-) create mode 100644 API_KEY_与IP限频说明.md diff --git a/API_KEY_与IP限频说明.md b/API_KEY_与IP限频说明.md new file mode 100644 index 0000000..9db3cd8 --- /dev/null +++ b/API_KEY_与IP限频说明.md @@ -0,0 +1,72 @@ +# API Key 使用方式与 IP 限频说明 + +## 一、获取余额、市场报价：每个账号用自己的 API Key 吗？ + +**是的。每个账号都用自己配置的 API Key。** + +### 1. 后端 Web API（前端请求「我的余额」「持仓」等） + +- 请求会带上当前登录用户/选择的 **account_id**。 +- 后端用 `Account.get_credentials(account_id)` 取**该账号**的 `BINANCE_API_KEY` / `BINANCE_API_SECRET`。 +- 用这份 Key 创建 `BinanceClient`，再调 `get_account_balance()`、`get_ticker_24h()`、持仓、下单等。 +- **结论**：账号 A 的请求用 A 的 Key，账号 B 用 B 的 Key，互不混用。 + +### 2. 交易进程（自动交易 / 扫描） + +- 每个账号一个独立进程（由 supervisor 按 account 起多个 `trading_system.main`）。 +- 每个进程启动时通过环境变量 **`ATS_ACCOUNT_ID`** 指定自己是哪个账号。 +- 配置通过 `ConfigManager.for_account(account_id)` 读取，其中 **BINANCE_API_KEY / BINANCE_API_SECRET** 来自该 account_id 在 `accounts` 表里配置的密钥。 +- 该进程内所有调用（**获取余额、获取交易对列表、获取行情 ticker/K 线、下单**）都用**同一个 BinanceClient**，即**该账号的 API Key**。 +- **结论**：每个账号的扫描与交易都只用自己的 Key，没有“统一一个 Key”的情况。 + +### 3. 推荐服务（仅行情、不下单） + +- `recommendations_main` deliberately 使用 **空 API Key**（`BinanceClient(api_key="", api_secret="")`），只调**公开接口**（行情、K 线等），不占用任何账号的 Key，也不读 account 的密钥。 + +--- + +## 二、-1003「IP 被封」和「轮转 API Key」的关系 + +错误示例：`APIError(code=-1003): Way too many requests; IP(43.199.103.162) banned until ...` + +- 这里限制的是 **IP**，不是某个 API Key。 +- 所有从你这台服务器（同一出口 IP）发出的请求，不管用哪个账号的 Key，都会算在**同一个 IP** 上。 +- 所以：**换用不同账号的 API Key 轮转，不能绕过或解除 IP 封禁**；封禁期间用哪个 Key 都会失败。 + +轮转 Key 只有在币安按 **API Key** 维度限频时才有用；当前你遇到的是 **IP 维度** 的封禁，所以轮转无法解决“等多久才能用”的问题，只能等该 IP 解封时间到期。 + +--- + +## 三、为什么多账号时更容易触发 IP 封禁？ + +- 每个账号一个进程，**每个进程都会自己做一整轮市场扫描**： + - `get_all_usdt_pairs()` + - 对大量交易对再请求 K 线、ticker 等 +- 若有 3 个账号，同一台机器上就是 **3 份完整扫描**，请求量约等于单账号的 3 倍，且都从**同一 IP** 发出，更容易触发「Way too many requests」和 IP 封禁。 + +--- + +## 四、可以怎么做来减少封禁 / 尽快恢复使用？ + +1. **解封前** + - 等日志里 `banned until` 的时间戳过期（参见 `BINANCE_IP_BAN_1003.md` 里用脚本算「还要等多久」）。 + +2. **解封后降低同一 IP 的请求量** + - 拉大 **SCAN_INTERVAL**（如 900 → 1200 或 1800 秒）。 + - 适当减小 **MAX_SCAN_SYMBOLS** / **TOP_N_SYMBOLS**。 + - 多账号时，考虑**只用一个进程做扫描、结果写入 Redis，各账号进程只读**，这样行情/扫描请求只打一份，从同一 IP 出去的请求会少很多（需改架构，可后续做）。 + +3. **轮转 API Key** + - 对**解除当前这次 IP 封禁**没有帮助。 + - 若未来遇到的是「按 Key 限频」而不是「按 IP 封禁」，再考虑按 Key 轮转或分摊请求才有意义。 + +--- + +## 五、总结表 + +| 能力 | 谁在调用 | 用的 API Key | +|----------------|----------------|----------------------| +| 获取余额 | 后端 / 交易进程 | 当前 account_id 的 Key | +| 获取市场报价等 | 交易进程 | 当前 account_id 的 Key | +| 推荐服务行情 | recommendations_main | 空 Key（仅公开接口） | +| -1003 IP 封禁 | - | 轮转 Key **无法**绕过，需等解封并降请求量 | diff --git a/backend/api/routes/stats.py b/backend/api/routes/stats.py index 64de3db..b71b787 100644 --- a/backend/api/routes/stats.py +++ b/backend/api/routes/stats.py @@ -105,33 +105,51 @@ async def get_dashboard_data(account_id: int = Depends(get_account_id)): account_data = None account_error = None - # [EMERGENCY FIX] 强制使用数据库快照，停止实时API请求以解决 -1003 IP Ban 问题 - logger.warning(f"检测到潜在的 API 限流风险，强制使用数据库快照 (account_id={account_id})") - - # 回退到数据库快照 + # 优先请求币安实时余额；失败时（如 -1003 IP 封禁）再回退到数据库快照 try: - snapshots = AccountSnapshot.get_recent(1, account_id=account_id) - if snapshots: - account_data = { - "total_balance": snapshots[0].get('total_balance', 0), - "available_balance": snapshots[0].get('available_balance', 0), - "total_position_value": snapshots[0].get('total_position_value', 0), - "total_pnl": snapshots[0].get('total_pnl', 0), - "open_positions": snapshots[0].get('open_positions', 0) - } - logger.info("使用数据库快照作为账户数据") + from api.routes.account import get_realtime_account_data + account_data = await get_realtime_account_data(account_id=account_id) + if account_data and account_data.get('total_balance') is not None: + logger.info("使用币安实时账户数据") else: - logger.warning("数据库中没有账户快照数据") - # 构造一个空的账户数据结构，避免前端报错 - account_data = { - "total_balance": 0, - "available_balance": 0, - "total_position_value": 0, - "total_pnl": 0, - "open_positions": 0 - } - except Exception as db_error: - logger.error(f"从数据库获取账户快照失败: {db_error}") + account_data = None + account_error = "实时余额返回为空" + except Exception as live_err: + account_error = str(live_err) + logger.warning(f"获取实时账户数据失败 (account_id={account_id})，回退到数据库快照: {live_err}") + + # 实时请求失败或无数据时，使用数据库快照 + if not account_data or account_data.get('total_balance') is None: + try: + snapshots = AccountSnapshot.get_recent(1, account_id=account_id) + if snapshots: + account_data = { + "total_balance": snapshots[0].get('total_balance', 0), + "available_balance": snapshots[0].get('available_balance', 0), + "total_position_value": snapshots[0].get('total_position_value', 0), + "total_pnl": snapshots[0].get('total_pnl', 0), + "open_positions": snapshots[0].get('open_positions', 0) + } + logger.info("使用数据库快照作为账户数据") + else: + if not account_data: + account_data = {} + account_data.setdefault("total_balance", 0) + account_data.setdefault("available_balance", 0) + account_data.setdefault("total_position_value", 0) + account_data.setdefault("total_pnl", 0) + account_data.setdefault("open_positions", 0) + logger.warning("数据库中没有账户快照数据，仪表板显示 0；交易进程会定期写入快照") + except Exception as db_error: + logger.error(f"从数据库获取账户快照失败: {db_error}") + if not account_data: + account_data = { + "total_balance": 0, + "available_balance": 0, + "total_position_value": 0, + "total_pnl": 0, + "open_positions": 0 + } # 获取持仓数据（强制使用数据库记录） open_trades = [] diff --git a/trading_system/strategy.py b/trading_system/strategy.py index 8e188aa..bc2850d 100644 --- a/trading_system/strategy.py +++ b/trading_system/strategy.py @@ -265,7 +265,7 @@ class TradingStrategy: if cache_size > 0: logger.info(f"价格缓存: {cache_size}个交易对") - # 记录账户快照到数据库 + # 记录账户快照到数据库（带 account_id，仪表板在实时 API 失败时会按账号读快照） try: import sys from pathlib import Path @@ -274,12 +274,20 @@ class TradingStrategy: if backend_path.exists(): sys.path.insert(0, str(backend_path)) from database.models import AccountSnapshot + aid = getattr(self.position_manager, 'account_id', None) + if aid is None: + import os + try: + aid = int(os.getenv("ATS_ACCOUNT_ID") or os.getenv("ACCOUNT_ID") or 1) + except Exception: + aid = 1 AccountSnapshot.create( total_balance=summary['totalBalance'], available_balance=summary['availableBalance'], total_position_value=sum(abs(p['positionAmt'] * p['entryPrice']) for p in summary.get('positions', [])), total_pnl=summary['totalPnL'], - open_positions=summary['totalPositions'] + open_positions=summary['totalPositions'], + account_id=aid ) except Exception as e: logger.debug(f"记录账户快照失败: {e}")