up

freqtrade/templates/freqaiprimer.py

@@ -114,26 +114,26 @@ class FreqaiPrimer(IStrategy):
     def linear_map(value, from_min, from_max, to_min, to_max):
         return (value - from_min) / (from_max - from_min) * (to_max - to_min) + to_min
 
-def __init__(self, config: dict, *args, **kwargs):
-    super().__init__(config, *args, **kwargs)
-    # 读取 Redis 配置
-    self.redis_url = config.get('redis', {}).get('url', None)
-    if self.redis_url:
-        logger.info(f"✅ 成功读取 Redis 配置: {self.redis_url}")
-    else:
-        logger.warning("⚠️ 未找到 Redis 配置")
-        # 配置日志格式，包含时间戳
-        logging.basicConfig(
-            format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
-            level=logging.info,
-            datefmt='%Y-%m-%d %H:%M:%S,%f'[:-3]  # 毫秒精度
-        )
-        logger.info("✅ 策略已初始化，日志级别设置为 DEBUG")
-        self.trailing_stop_enabled = False
-        self.pair_stats = {}
-        self.stats_logged = False
-        self.fit_live_predictions_candles = self.freqai_info.get("fit_live_predictions_candles", 100)
-        self.last_entry_time = {}  # 记录每个币种的最后入场时间
+    def __init__(self, config: dict, *args, **kwargs):
+        super().__init__(config, *args, **kwargs)
+        # 读取 Redis 配置
+        self.redis_url = config.get('redis', {}).get('url', None)
+        if self.redis_url:
+            logger.info(f"✅ 成功读取 Redis 配置: {self.redis_url}")
+        else:
+            logger.warning("⚠️ 未找到 Redis 配置")
+            # 配置日志格式，包含时间戳
+            logging.basicConfig(
+                format='%(asctime)s - %(name)s - %(levelname)s - %(message)s',
+                level=logging.info,
+                datefmt='%Y-%m-%d %H:%M:%S,%f'[:-3]  # 毫秒精度
+            )
+            logger.info("✅ 策略已初始化，日志级别设置为 DEBUG")
+            self.trailing_stop_enabled = False
+            self.pair_stats = {}
+            self.stats_logged = False
+            self.fit_live_predictions_candles = self.freqai_info.get("fit_live_predictions_candles", 100)
+            self.last_entry_time = {}  # 记录每个币种的最后入场时间
 
     def feature_engineering_expand_all(self, dataframe: DataFrame, period: int, metadata: dict, **kwargs) -> DataFrame:
         dataframe["%-rsi-period"] = ta.RSI(dataframe, timeperiod=period)