From a371e50a3e7ad2a754502c426e3194a354354d00 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=96=87=E8=96=87=E5=AE=89?= Date: Sat, 21 Feb 2026 10:47:39 +0800 Subject: [PATCH] =?UTF-8?q?feat(config,=20strategy):=20=E5=A2=9E=E5=BC=BA?= =?UTF-8?q?=E5=A4=9A=E8=B4=A6=E5=8F=B7=E9=94=99=E5=B3=B0=E6=89=AB=E6=8F=8F?= =?UTF-8?q?=E9=80=BB=E8=BE=91?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 在 `config.py` 中新增随机延迟配置，允许在多账号环境下实现更灵活的错峰扫描策略。更新了 `strategy.py` 中的相关逻辑，支持随机延迟与固定步长延迟两种模式，提升了系统在低配服务器上的性能与稳定性。此改进有助于优化资源管理与并发处理能力。 --- trading_system/config.py | 7 +++++-- trading_system/strategy.py | 20 +++++++++++++++----- 2 files changed, 20 insertions(+), 7 deletions(-) diff --git a/trading_system/config.py b/trading_system/config.py index fbe1373..3d910bc 100644 --- a/trading_system/config.py +++ b/trading_system/config.py @@ -220,8 +220,11 @@ DEFAULT_TRADING_CONFIG = { 'SCAN_LIMIT_KLINE_SUBSCRIBE': True, # 限制 K 线订阅：只在缓存完全没有数据时才订阅，避免订阅过多导致负载上升 # 多账号/低配服务器（如 2 CPU 4G）：降低并发与错峰扫描，避免 CPU 打满 'SCAN_CONCURRENT_SYMBOLS': 2, # 扫描时同时分析多少个交易对（2 CPU 4G 多账号建议 2，单账号可 3～5） - 'SCAN_STAGGER_BY_ACCOUNT': True, # 多账号时按 account_id 错峰首次扫描，避免多进程同时扫 - 'SCAN_STAGGER_SEC': 60, # 每多一个账号延迟的秒数（account_id-1 * 此值），如 4 账号则 0/60/120/180 秒后开扫 + 'SCAN_STAGGER_BY_ACCOUNT': True, # 多账号时错峰首次扫描，避免多进程同时扫 + 'SCAN_STAGGER_RANDOM': True, # True=随机延迟(更分散)，False=按 account_id 固定步长延迟 + 'SCAN_STAGGER_MIN_SEC': 10, # 随机延迟下限（秒） + 'SCAN_STAGGER_MAX_SEC': 120, # 随机延迟上限（秒） + 'SCAN_STAGGER_SEC': 60, # 非随机模式下每账号步长（account_id-1 * 此值） 'KLINE_INTERVAL': '1h', 'PRIMARY_INTERVAL': '4h', # 主周期4小时，过滤噪音 'CONFIRM_INTERVAL': '1d', # 确认周期日线，看大趋势 diff --git a/trading_system/strategy.py b/trading_system/strategy.py index 646e972..3553b8b 100644 --- a/trading_system/strategy.py +++ b/trading_system/strategy.py @@ -78,13 +78,23 @@ class TradingStrategy: # 多账号错峰：避免多进程同时扫描导致 CPU 打满（2 CPU 4G 等低配服务器） import os + import random stagger_enabled = config.TRADING_CONFIG.get('SCAN_STAGGER_BY_ACCOUNT', False) - stagger_sec = int(config.TRADING_CONFIG.get('SCAN_STAGGER_SEC', 60) or 60) + stagger_random = config.TRADING_CONFIG.get('SCAN_STAGGER_RANDOM', True) account_id = int(os.getenv('ATS_ACCOUNT_ID') or os.getenv('ACCOUNT_ID') or 1) - if stagger_enabled and account_id > 1 and stagger_sec > 0: - delay = (account_id - 1) * stagger_sec - logger.info(f"多账号错峰：account_id={account_id}，延迟 {delay} 秒后开始首次扫描") - await asyncio.sleep(delay) + if stagger_enabled: + if stagger_random: + min_sec = max(0, int(config.TRADING_CONFIG.get('SCAN_STAGGER_MIN_SEC', 10) or 10)) + max_sec = max(min_sec, int(config.TRADING_CONFIG.get('SCAN_STAGGER_MAX_SEC', 120) or 120)) + delay = random.randint(min_sec, max_sec) + logger.info(f"多账号错峰：account_id={account_id}，随机延迟 {delay} 秒后开始首次扫描（范围 {min_sec}～{max_sec}s）") + else: + stagger_sec = int(config.TRADING_CONFIG.get('SCAN_STAGGER_SEC', 60) or 60) + delay = (account_id - 1) * stagger_sec if account_id > 1 else 0 + if delay > 0: + logger.info(f"多账号错峰：account_id={account_id}，延迟 {delay} 秒后开始首次扫描") + if delay > 0: + await asyncio.sleep(delay) try: while self.running: