Skip to article frontmatterSkip to article content
Freqtrade V2 到 V3 迁移

策略迁移指南

从 V2 到 V3 的策略迁移完整指南

V2 和 V3 之间的策略迁移

为了支持新的市场和交易类型(即空头交易/杠杆交易),接口必须进行一些更改。 如果你打算使用现货市场以外的市场,请将你的策略迁移到新格式。

我们付出了很大努力来保持与现有策略的兼容性,所以如果你只想继续在__现货市场__使用 freqtrade,目前应该不需要任何更改。

你可以使用快速摘要作为检查清单。请参阅下面的详细部分以获取完整的迁移详情。

快速摘要/迁移检查清单

注意:forcesellforcebuyemergencysell 分别改为 force_exitforce_enteremergency_exit

详细说明

populate_buy_trend

populate_buy_trend() 中 - 你需要将分配的列从 'buy' 改为 'enter_long',同时将方法名从 populate_buy_trend 改为 populate_entry_trend

def populate_buy_trend(self, dataframe: DataFrame, metadata: dict) -> DataFrame:
    dataframe.loc[
        (
            (qtpylib.crossed_above(dataframe['rsi'], 30)) &  # 信号:RSI 上穿 30
            (dataframe['tema'] <= dataframe['bb_middleband']) &  # 守卫
            (dataframe['tema'] > dataframe['tema'].shift(1)) &  # 守卫
            (dataframe['volume'] > 0)  # 确保成交量不为 0
        ),
        ['buy', 'buy_tag']] = (1, 'rsi_cross')

    return dataframe

之后:

def populate_entry_trend(self, dataframe: DataFrame, metadata: dict) -> DataFrame:
    dataframe.loc[
        (
            (qtpylib.crossed_above(dataframe['rsi'], 30)) &  # 信号:RSI 上穿 30
            (dataframe['tema'] <= dataframe['bb_middleband']) &  # 守卫
            (dataframe['tema'] > dataframe['tema'].shift(1)) &  # 守卫
            (dataframe['volume'] > 0)  # 确保成交量不为 0
        ),
        ['enter_long', 'enter_tag']] = (1, 'rsi_cross')

    return dataframe

请参阅策略文档了解如何入场和出场空头交易。

populate_sell_trend

populate_buy_trend 类似,populate_sell_trend() 将重命名为 populate_exit_trend()。 我们还将列从 'sell' 改为 'exit_long'

def populate_sell_trend(self, dataframe: DataFrame, metadata: dict) -> DataFrame:
    dataframe.loc[
        (
            (qtpylib.crossed_above(dataframe['rsi'], 70)) &  # 信号:RSI 上穿 70
            (dataframe['tema'] > dataframe['bb_middleband']) &  # 守卫
            (dataframe['tema'] < dataframe['tema'].shift(1)) &  # 守卫
            (dataframe['volume'] > 0)  # 确保成交量不为 0
        ),
        ['sell', 'exit_tag']] = (1, 'some_exit_tag')
    return dataframe

之后:

def populate_exit_trend(self, dataframe: DataFrame, metadata: dict) -> DataFrame:
    dataframe.loc[
        (
            (qtpylib.crossed_above(dataframe['rsi'], 70)) &  # 信号:RSI 上穿 70
            (dataframe['tema'] > dataframe['bb_middleband']) &  # 守卫
            (dataframe['tema'] < dataframe['tema'].shift(1)) &  # 守卫
            (dataframe['volume'] > 0)  # 确保成交量不为 0
        ),
        ['exit_long', 'exit_tag']] = (1, 'some_exit_tag')
    return dataframe

请参阅策略文档了解如何入场和出场空头交易。

custom_sell

custom_sell 已重命名为 custom_exit。 它现在也会在每次迭代时被调用,与当前利润和 exit_profit_only 设置无关。

class AwesomeStrategy(IStrategy):
    def custom_sell(self, pair: str, trade: 'Trade', current_time: 'datetime', current_rate: float,
                    current_profit: float, **kwargs):
        dataframe, _ = self.dp.get_analyzed_dataframe(pair, self.timeframe)
        last_candle = dataframe.iloc[-1].squeeze()
        # ...
class AwesomeStrategy(IStrategy):
    def custom_exit(self, pair: str, trade: 'Trade', current_time: 'datetime', current_rate: float,
                    current_profit: float, **kwargs):
        dataframe, _ = self.dp.get_analyzed_dataframe(pair, self.timeframe)
        last_candle = dataframe.iloc[-1].squeeze()
        # ...

custom_entry_timeout

check_buy_timeout() 已重命名为 check_entry_timeout()check_sell_timeout() 已重命名为 check_exit_timeout()

class AwesomeStrategy(IStrategy):
    def check_buy_timeout(self, pair: str, trade: 'Trade', order: dict, 
                            current_time: datetime, **kwargs) -> bool:
        return False

    def check_sell_timeout(self, pair: str, trade: 'Trade', order: dict, 
                            current_time: datetime, **kwargs) -> bool:
        return False 
class AwesomeStrategy(IStrategy):
    def check_entry_timeout(self, pair: str, trade: 'Trade', order: 'Order', 
                            current_time: datetime, **kwargs) -> bool:
        return False

    def check_exit_timeout(self, pair: str, trade: 'Trade', order: 'Order', 
                            current_time: datetime, **kwargs) -> bool:
        return False 

custom_stake_amount

新增字符串参数 side - 可以是 "long""short"

class AwesomeStrategy(IStrategy):
    def custom_stake_amount(self, pair: str, current_time: datetime, current_rate: float,
                            proposed_stake: float, min_stake: Optional[float], max_stake: float,
                            entry_tag: Optional[str], **kwargs) -> float:
        # ... 
        return proposed_stake
class AwesomeStrategy(IStrategy):
    def custom_stake_amount(self, pair: str, current_time: datetime, current_rate: float,
                            proposed_stake: float, min_stake: float | None, max_stake: float,
                            entry_tag: str | None, side: str, **kwargs) -> float:
        # ... 
        return proposed_stake

confirm_trade_entry

新增字符串参数 side - 可以是 "long""short"

class AwesomeStrategy(IStrategy):
    def confirm_trade_entry(self, pair: str, order_type: str, amount: float, rate: float,
                            time_in_force: str, current_time: datetime, entry_tag: Optional[str], 
                            **kwargs) -> bool:
      return True

之后:

class AwesomeStrategy(IStrategy):
    def confirm_trade_entry(self, pair: str, order_type: str, amount: float, rate: float,
                            time_in_force: str, current_time: datetime, entry_tag: str | None, 
                            side: str, **kwargs) -> bool:
      return True

confirm_trade_exit

将参数 sell_reason 改为 exit_reason。 为了兼容性,sell_reason 仍将在有限时间内提供。

class AwesomeStrategy(IStrategy):
    def confirm_trade_exit(self, pair: str, trade: Trade, order_type: str, amount: float,
                           rate: float, time_in_force: str, sell_reason: str,
                           current_time: datetime, **kwargs) -> bool:
    return True

之后:

class AwesomeStrategy(IStrategy):
    def confirm_trade_exit(self, pair: str, trade: Trade, order_type: str, amount: float,
                           rate: float, time_in_force: str, exit_reason: str,
                           current_time: datetime, **kwargs) -> bool:
    return True

custom_entry_price

新增字符串参数 side - 可以是 "long""short"

class AwesomeStrategy(IStrategy):
    def custom_entry_price(self, pair: str, current_time: datetime, proposed_rate: float,
                           entry_tag: Optional[str], **kwargs) -> float:
      return proposed_rate

之后:

class AwesomeStrategy(IStrategy):
    def custom_entry_price(self, pair: str, trade: Trade | None, current_time: datetime, proposed_rate: float,
                           entry_tag: str | None, side: str, **kwargs) -> float:
      return proposed_rate

调整交易仓位更改

虽然 adjust-trade-position 本身没有改变,但你不应该再使用 trade.nr_of_successful_buys - 而是使用 trade.nr_of_successful_entries,它也将包括空头入场。

辅助方法

stoploss_from_openstoploss_from_absolute 添加参数 “is_short”。 这应该给出 trade.is_short 的值。

    def custom_stoploss(self, pair: str, trade: 'Trade', current_time: datetime,
                        current_rate: float, current_profit: float, **kwargs) -> float:
        # 一旦利润上升到 10% 以上,将止损保持在开盘价上方 7%
        if current_profit > 0.10:
            return stoploss_from_open(0.07, current_profit)

        return stoploss_from_absolute(current_rate - (candle['atr'] * 2), current_rate)

        return 1

之后:

    def custom_stoploss(self, pair: str, trade: 'Trade', current_time: datetime,
                        current_rate: float, current_profit: float, after_fill: bool, 
                        **kwargs) -> float | None:
        # 一旦利润上升到 10% 以上,将止损保持在开盘价上方 7%
        if current_profit > 0.10:
            return stoploss_from_open(0.07, current_profit, is_short=trade.is_short)

        return stoploss_from_absolute(current_rate - (candle['atr'] * 2), current_rate, is_short=trade.is_short, leverage=trade.leverage)

策略/配置设置

order_time_in_force

order_time_in_force 属性从 "buy" 改为 "entry",从 "sell" 改为 "exit"

    order_time_in_force: dict = {
        "buy": "gtc",
        "sell": "gtc",
    }

之后:

    order_time_in_force: dict = {
        "entry": "GTC",
        "exit": "GTC",
    }
order_types

order_types 已将所有措辞从 buy 改为 entry - 从 sell 改为 exit。 并且两个词用 _ 连接。

    order_types = {
        "buy": "limit",
        "sell": "limit",
        "emergencysell": "market",
        "forcesell": "market",
        "forcebuy": "market",
        "stoploss": "market",
        "stoploss_on_exchange": false,
        "stoploss_on_exchange_interval": 60
    }

之后:

    order_types = {
        "entry": "limit",
        "exit": "limit",
        "emergency_exit": "market",
        "force_exit": "market",
        "force_entry": "market",
        "stoploss": "market",
        "stoploss_on_exchange": false,
        "stoploss_on_exchange_interval": 60
    }
策略级别设置
    # 这些值可以在配置中被覆盖。
    use_sell_signal = True
    sell_profit_only = True
    sell_profit_offset: 0.01
    ignore_roi_if_buy_signal = False

之后:

    # 这些值可以在配置中被覆盖。
    use_exit_signal = True
    exit_profit_only = True
    exit_profit_offset: 0.01
    ignore_roi_if_entry_signal = False
unfilledtimeout

unfilledtimeout 已将所有措辞从 buy 改为 entry - 从 sell 改为 exit

unfilledtimeout = {
        "buy": 10,
        "sell": 10,
        "exit_timeout_count": 0,
        "unit": "minutes"
    }

之后:

unfilledtimeout = {
        "entry": 10,
        "exit": 10,
        "exit_timeout_count": 0,
        "unit": "minutes"
    }
order pricing

订单定价有两种变化。bid_strategy 重命名为 entry_pricingask_strategy 重命名为 exit_pricing。 属性 ask_last_balance -> price_last_balancebid_last_balance -> price_last_balance 也被重命名。 此外,价格端现在可以定义为 askbidsameother。 请参阅定价文档了解更多信息。

{
    "bid_strategy": {
        "price_side": "bid",
        "use_order_book": true,
        "order_book_top": 1,
        "ask_last_balance": 0.0,
        "check_depth_of_market": {
            "enabled": false,
            "bids_to_ask_delta": 1
        }
    },
    "ask_strategy":{
        "price_side": "ask",
        "use_order_book": true,
        "order_book_top": 1,
        "bid_last_balance": 0.0
        "ignore_buying_expired_candle_after": 120
    }
}

之后:

{
    "entry_pricing": {
        "price_side": "same",
        "use_order_book": true,
        "order_book_top": 1,
        "price_last_balance": 0.0,
        "check_depth_of_market": {
            "enabled": false,
            "bids_to_ask_delta": 1
        }
    },
    "exit_pricing":{
        "price_side": "same",
        "use_order_book": true,
        "order_book_top": 1,
        "price_last_balance": 0.0
    },
    "ignore_buying_expired_candle_after": 120
}

FreqAI 策略

populate_any_indicators() 方法已被拆分为 feature_engineering_expand_all()feature_engineering_expand_basic()feature_engineering_standard()set_freqai_targets()

对于每个新函数,交易对(和必要的时间框架)将自动添加到列中。 因此,使用新逻辑定义特征变得更加简单。

有关每个方法的完整说明,请转到相应的 freqAI 文档页面


def populate_any_indicators(
        self, pair, df, tf, informative=None, set_generalized_indicators=False
    ):

        if informative is None:
            informative = self.dp.get_pair_dataframe(pair, tf)

        # 第一个循环自动复制时间周期的指标
        for t in self.freqai_info["feature_parameters"]["indicator_periods_candles"]:

            t = int(t)
            informative[f"%-{pair}rsi-period_{t}"] = ta.RSI(informative, timeperiod=t)
            informative[f"%-{pair}mfi-period_{t}"] = ta.MFI(informative, timeperiod=t)
            informative[f"%-{pair}adx-period_{t}"] = ta.ADX(informative, timeperiod=t)
            informative[f"%-{pair}sma-period_{t}"] = ta.SMA(informative, timeperiod=t)
            informative[f"%-{pair}ema-period_{t}"] = ta.EMA(informative, timeperiod=t)

            bollinger = qtpylib.bollinger_bands(
                qtpylib.typical_price(informative), window=t, stds=2.2
            )
            informative[f"{pair}bb_lowerband-period_{t}"] = bollinger["lower"]
            informative[f"{pair}bb_middleband-period_{t}"] = bollinger["mid"]
            informative[f"{pair}bb_upperband-period_{t}"] = bollinger["upper"]

            informative[f"%-{pair}bb_width-period_{t}"] = (
                informative[f"{pair}bb_upperband-period_{t}"]
                - informative[f"{pair}bb_lowerband-period_{t}"]
            ) / informative[f"{pair}bb_middleband-period_{t}"]
            informative[f"%-{pair}close-bb_lower-period_{t}"] = (
                informative["close"] / informative[f"{pair}bb_lowerband-period_{t}"]
            )

            informative[f"%-{pair}roc-period_{t}"] = ta.ROC(informative, timeperiod=t)

            informative[f"%-{pair}relative_volume-period_{t}"] = (
                informative["volume"] / informative["volume"].rolling(t).mean()
            ) # (1)

        informative[f"%-{pair}pct-change"] = informative["close"].pct_change()
        informative[f"%-{pair}raw_volume"] = informative["volume"]
        informative[f"%-{pair}raw_price"] = informative["close"]
        # (2)

        indicators = [col for col in informative if col.startswith("%")]
        # 这个循环复制并移动所有指标,为数据添加时效性
        for n in range(self.freqai_info["feature_parameters"]["include_shifted_candles"] + 1):
            if n == 0:
                continue
            informative_shift = informative[indicators].shift(n)
            informative_shift = informative_shift.add_suffix("_shift-" + str(n))
            informative = pd.concat((informative, informative_shift), axis=1)

        df = merge_informative_pair(df, informative, self.config["timeframe"], tf, ffill=True)
        skip_columns = [
            (s + "_" + tf) for s in ["date", "open", "high", "low", "close", "volume"]
        ]
        df = df.drop(columns=skip_columns)

        # 在这里添加通用指标(因为在实盘中,它将调用此函数在训练期间填充指标)。注意我们如何确保不多次添加它们
        if set_generalized_indicators:
            df["%-day_of_week"] = (df["date"].dt.dayofweek + 1) / 7
            df["%-hour_of_day"] = (df["date"].dt.hour + 1) / 25
            # (3)

            # 用户通过在前面添加 &- 来添加目标(见下面的约定)
            df["&-s_close"] = (
                df["close"]
                .shift(-self.freqai_info["feature_parameters"]["label_period_candles"])
                .rolling(self.freqai_info["feature_parameters"]["label_period_candles"])
                .mean()
                / df["close"]
                - 1
            )  # (4)

        return df
  1. 特征 - 移到 feature_engineering_expand_all
  2. 基本特征,不在 indicator_periods_candles 中扩展 - 移到 feature_engineering_expand_basic()
  3. 不应扩展的标准特征 - 移到 feature_engineering_standard()
  4. 目标 - 移到 set_freqai_targets()

freqai - 特征工程扩展全部

特征现在会自动扩展。因此,需要删除扩展循环以及 {pair} / {timeframe} 部分。

    def feature_engineering_expand_all(self, dataframe, period, **kwargs) -> DataFrame::
        """
        *仅在使用 FreqAI 启用的策略时有效*
        此函数将根据配置定义的 `indicator_periods_candles`、`include_timeframes`、`include_shifted_candles` 和 `include_corr_pairs` 自动扩展定义的特征。
        换句话说,在此函数中定义的单个特征将自动扩展为总共
        `indicator_periods_candles` * `include_timeframes` * `include_shifted_candles` *
        `include_corr_pairs` 个添加到模型的特征。

        所有特征必须以 `%` 开头才能被 FreqAI 内部识别。

        有关这些配置定义的参数如何加速特征工程的更多详细信息,请参阅文档:

        https://www.freqtrade.io/en/latest/freqai-parameter-table/#feature-parameters

        https://www.freqtrade.io/en/latest/freqai-feature-engineering/#defining-the-features

        :param df: 将接收特征的策略数据框
        :param period: 指标的周期 - 使用示例:
        dataframe["%-ema-period"] = ta.EMA(dataframe, timeperiod=period)
        """

        dataframe["%-rsi-period"] = ta.RSI(dataframe, timeperiod=period)
        dataframe["%-mfi-period"] = ta.MFI(dataframe, timeperiod=period)
        dataframe["%-adx-period"] = ta.ADX(dataframe, timeperiod=period)
        dataframe["%-sma-period"] = ta.SMA(dataframe, timeperiod=period)
        dataframe["%-ema-period"] = ta.EMA(dataframe, timeperiod=period)

        bollinger = qtpylib.bollinger_bands(
            qtpylib.typical_price(dataframe), window=period, stds=2.2
        )
        dataframe["bb_lowerband-period"] = bollinger["lower"]
        dataframe["bb_middleband-period"] = bollinger["mid"]
        dataframe["bb_upperband-period"] = bollinger["upper"]

        dataframe["%-bb_width-period"] = (
            dataframe["bb_upperband-period"]
            - dataframe["bb_lowerband-period"]
        ) / dataframe["bb_middleband-period"]
        dataframe["%-close-bb_lower-period"] = (
            dataframe["close"] / dataframe["bb_lowerband-period"]
        )

        dataframe["%-roc-period"] = ta.ROC(dataframe, timeperiod=period)

        dataframe["%-relative_volume-period"] = (
            dataframe["volume"] / dataframe["volume"].rolling(period).mean()
        )

        return dataframe

Freqai - 特征工程基础

基本特征。确保从特征中删除 {pair} 部分。

    def feature_engineering_expand_basic(self, dataframe: DataFrame, **kwargs) -> DataFrame::
        """
        *仅在使用 FreqAI 启用的策略时有效*
        此函数将根据配置定义的 `include_timeframes`、`include_shifted_candles` 和 `include_corr_pairs` 自动扩展定义的特征。
        换句话说,在此函数中定义的单个特征将自动扩展为总共
        `include_timeframes` * `include_shifted_candles` * `include_corr_pairs`
        个添加到模型的特征。

        此处定义的特征将*不会*在用户定义的 `indicator_periods_candles` 上自动复制

        所有特征必须以 `%` 开头才能被 FreqAI 内部识别。

        有关这些配置定义的参数如何加速特征工程的更多详细信息,请参阅文档:

        https://www.freqtrade.io/en/latest/freqai-parameter-table/#feature-parameters

        https://www.freqtrade.io/en/latest/freqai-feature-engineering/#defining-the-features

        :param df: 将接收特征的策略数据框
        dataframe["%-pct-change"] = dataframe["close"].pct_change()
        dataframe["%-ema-200"] = ta.EMA(dataframe, timeperiod=200)
        """
        dataframe["%-pct-change"] = dataframe["close"].pct_change()
        dataframe["%-raw_volume"] = dataframe["volume"]
        dataframe["%-raw_price"] = dataframe["close"]
        return dataframe

FreqAI - 特征工程标准

    def feature_engineering_standard(self, dataframe: DataFrame, **kwargs) -> DataFrame:
        """
        *仅在使用 FreqAI 启用的策略时有效*
        此可选函数将使用基本时间框架的数据框调用一次。
        这是要调用的最终函数,这意味着进入此函数的数据框将包含所有其他
        freqai_feature_engineering_* 函数创建的所有特征和列。

        此函数是进行自定义异国特征提取的好地方(例如 tsfresh)。
        此函数是任何不应自动扩展的特征的好地方(例如星期几)。

        所有特征必须以 `%` 开头才能被 FreqAI 内部识别。

        有关特征工程的更多详细信息:

        https://www.freqtrade.io/en/latest/freqai-feature-engineering

        :param df: 将接收特征的策略数据框
        使用示例:dataframe["%-day_of_week"] = (dataframe["date"].dt.dayofweek + 1) / 7
        """
        dataframe["%-day_of_week"] = dataframe["date"].dt.dayofweek
        dataframe["%-hour_of_day"] = dataframe["date"].dt.hour
        return dataframe

FreqAI - 设置目标

目标现在有了自己的专用方法。

    def set_freqai_targets(self, dataframe: DataFrame, **kwargs) -> DataFrame:
        """
        *仅在使用 FreqAI 启用的策略时有效*
        设置模型目标的必需函数。
        所有目标必须以 `&` 开头才能被 FreqAI 内部识别。

        有关特征工程的更多详细信息:

        https://www.freqtrade.io/en/latest/freqai-feature-engineering

        :param df: 将接收目标的策略数据框
        使用示例:dataframe["&-target"] = dataframe["close"].shift(-1) / dataframe["close"]
        """
        dataframe["&-s_close"] = (
            dataframe["close"]
            .shift(-self.freqai_info["feature_parameters"]["label_period_candles"])
            .rolling(self.freqai_info["feature_parameters"]["label_period_candles"])
            .mean()
            / dataframe["close"]
            - 1
            )

        return dataframe

FreqAI - 新数据管道

如果你创建了自己的自定义 IFreqaiModel,带有自定义 train()/predict() 函数,并且你仍然依赖 data_cleaning_train/predict(),那么你需要迁移到新的管道。如果你的模型依赖 data_cleaning_train/predict(),那么你不需要担心这个迁移。这意味着这个迁移指南只与很小一部分高级用户相关。如果你偶然看到这个指南,欢迎在 Freqtrade discord 服务器上深入询问你的问题。

转换涉及首先删除 data_cleaning_train/predict(),并用 define_data_pipeline()define_label_pipeline() 函数替换它们到你的 IFreqaiModel 类:

class MyCoolFreqaiModel(BaseRegressionModel):
    """
    你在 Freqtrade 版本 2023.6 之前制作的一些很酷的自定义 IFreqaiModel
    """
    def train(
        self, unfiltered_df: DataFrame, pair: str, dk: FreqaiDataKitchen, **kwargs
    ) -> Any:

        # ... 你的自定义内容

        # 删除这些行
        # data_dictionary = dk.make_train_test_datasets(features_filtered, labels_filtered)
        # self.data_cleaning_train(dk)
        # data_dictionary = dk.normalize_data(data_dictionary)
        # (1)

        # 添加这些行。现在我们自己控制管道的 fit/transform
        dd = dk.make_train_test_datasets(features_filtered, labels_filtered)
        dk.feature_pipeline = self.define_data_pipeline(threads=dk.thread_count)
        dk.label_pipeline = self.define_label_pipeline(threads=dk.thread_count)

        (dd["train_features"],
         dd["train_labels"],
         dd["train_weights"]) = dk.feature_pipeline.fit_transform(dd["train_features"],
                                                                  dd["train_labels"],
                                                                  dd["train_weights"])

        (dd["test_features"],
         dd["test_labels"],
         dd["test_weights"]) = dk.feature_pipeline.transform(dd["test_features"],
                                                             dd["test_labels"],
                                                             dd["test_weights"])

        dd["train_labels"], _, _ = dk.label_pipeline.fit_transform(dd["train_labels"])
        dd["test_labels"], _, _ = dk.label_pipeline.transform(dd["test_labels"])

        # ... 你的自定义代码

        return model

    def predict(
        self, unfiltered_df: DataFrame, dk: FreqaiDataKitchen, **kwargs
    ) -> tuple[DataFrame, npt.NDArray[np.int_]]:

        # ... 你的自定义内容

        # 删除这些行:
        # self.data_cleaning_predict(dk)
        # (2)

        # 添加这些行:
        dk.data_dictionary["prediction_features"], outliers, _ = dk.feature_pipeline.transform(
            dk.data_dictionary["prediction_features"], outlier_check=True)

        # 删除这行
        # pred_df = dk.denormalize_labels_from_metadata(pred_df)
        # (3)

        # 用这些行替换
        pred_df, _, _ = dk.label_pipeline.inverse_transform(pred_df)
        if self.freqai_info.get("DI_threshold", 0) > 0:
            dk.DI_values = dk.feature_pipeline["di"].di_values
        else:
            dk.DI_values = np.zeros(outliers.shape[0])
        dk.do_predict = outliers

        # ... 你的自定义代码
        return (pred_df, dk.do_predict)
  1. 数据规范化和清理现在与新管道定义统一。这是在新的 define_data_pipeline()define_label_pipeline() 函数中创建的。不再使用 data_cleaning_train()data_cleaning_predict() 函数。如果你愿意,你可以覆盖 define_data_pipeline() 来创建自己的自定义管道。
  2. 数据规范化和清理现在与新管道定义统一。这是在新的 define_data_pipeline()define_label_pipeline() 函数中创建的。不再使用 data_cleaning_train()data_cleaning_predict() 函数。如果你愿意,你可以覆盖 define_data_pipeline() 来创建自己的自定义管道。
  3. 数据反规范化使用新管道完成。用下面的行替换。