1. 项目概述从“能跑”到“能用”的因子计算之路做量化策略的朋友尤其是刚入期货这个坑的估计都听过或者自己写过基于均线的策略。听起来很简单不就是算个30日均线然后金叉买死叉卖嘛。我刚开始也是这么想的直到真金白银跑起来才发现从“代码能跑通”到“策略能实盘”之间隔着一整个太平洋的坑。今天要聊的这个“基于米筐数据Python的30日均线策略实现”就是一个非常典型的案例。它表面上是一个入门级的策略实现但内核却是一个完整的因子计算与回测工程化流程的缩影。很多新手包括当年的我会直接把网上搜到的教程代码复制过来用米筐RiceQuant的数据接口拉个收盘价用pandas的.rolling(30).mean()一算回测一看曲线挺漂亮就觉得大功告成了。结果一上实盘或者做更细致的分析各种问题就来了数据有没有复权合约到期换月怎么处理均线计算用的是收盘价还是结算价回测时是收盘价成交还是下一根K线开盘价成交这些细节任何一个没处理好轻则回测结果失真重则直接导致实盘亏损。所以这篇内容我想抛开那些花哨的策略理论就扎扎实实地复盘一下如何用Python和米筐数据把一个看似简单的30日均线因子从数据获取、计算、到策略逻辑实现每一步都做得扎实、可靠、可复现。这不仅是写给期货量化新手的避坑指南也是给有一定经验的朋友做一次工程细节上的查漏补缺。2. 核心需求解析为什么是30日均线与期货在动手敲代码之前我们得先想明白两个问题为什么选择30日均线这个因子以及在期货市场上应用它有什么特殊之处2.1 30日均线的策略逻辑与市场假设30日均线或者说任何周期的移动平均线其核心逻辑是平滑价格序列识别趋势。短期均线如5日、10日对价格反应灵敏但噪音也多长期均线如60日、120日趋势稳定但信号滞后严重。30日这个周期在A股和很多期货品种上被经验性地认为是一个能较好平衡响应速度和趋势稳定性的折中点。它大约覆盖了1.5个月按交易日算的价格信息既能过滤掉大部分日内的随机波动和短期扰动又不会对中期级别的趋势反转反应过于迟钝。我们的策略假设是当价格上穿30日均线时意味着短期动能可能突破了中期平均成本趋势有望向上触发买入信号当价格下穿30日均线时则意味着趋势可能转弱或反转触发卖出或做空信号。这是一个典型的趋势跟踪策略它不预测市场顶部或底部而是试图在趋势确立时入场在趋势结束时离场。在期货市场由于可以做空这个逻辑可以双向运用即上穿做多下穿做空构成一个完整的双向交易系统。2.2 期货数据与策略的特殊性这才是坑最多的地方。股票数据相对“干净”有明确的前复权、后复权处理标的股票代码长期不变。期货则复杂得多合约生命周期与主力连续每个期货合约如rb2410都有固定的到期日。你不能直接对一个即将到期的合约计算30日均线然后长期持有因为你会面临交割。因此量化交易通常交易的是“主力连续合约”或自己构建的“连续合约”它通过拼接不同时期的主力合约来形成一个长期连续的行情序列。米筐数据提供了dominant字段来标识主力合约也提供了futures_continuation函数来生成连续合约。第一个大坑直接对单个合约代码如RB8888这是米筐的指数合约非交易合约进行回测其结果与交易主力连续合约的结果会有显著差异。价格字段的选择股票通常看收盘价。期货呢收盘价close、结算价settlement、均价avg都可以作为计算基准。结算价是当日无负债结算的基础更能代表市场的公允成本许多机构风控和指标计算以结算价为准。而收盘价可能因为尾盘投机盘影响出现较大偏离。第二个大坑用收盘价计算均线、用结算价计算保证金和盈亏会导致策略信号与风控基准错配。保证金与杠杆期货是保证金交易这直接关系到资金管理和回测的真实性。回测中必须考虑动态保证金占用不能简单假设全仓进出。换月滑点与交易成本在主力合约换月时价差Spread可能很大。你的策略信号在旧合约上产生但实际需要平仓旧合约、开仓新合约这个过程会产生额外的滑点和手续费。这部分成本在简单回测中极易被忽略。理解了这些我们才能有的放矢地设计我们的数据处理和回测流程。3. 环境准备与米筐数据接口详解工欲善其事必先利其器。一个稳定、清晰的数据获取环境是量化工作的基石。3.1 Python环境与核心库配置现在不建议大家再从python.org下载原生Python了管理包依赖太麻烦。我强烈推荐使用Miniconda或Anaconda来管理Python环境。创建一个独立的量化环境可以避免不同项目间的库版本冲突。# 创建一个名为qtn_futures的虚拟环境指定Python版本为3.8一个兼容性较好的版本 conda create -n qtn_futures python3.8 # 激活环境 conda activate qtn_futures接下来安装核心库。除了米筐的rqdatac我们还需要数据分析的pandas、numpy以及用于画图的matplotlib。如果你要做更复杂的分析empyrical绩效分析和alphalens因子分析也是不错的选择。# 安装核心库 pip install rqdatac pandas numpy matplotlib # 如果需要安装绩效分析库 pip install empyrical注意rqdatac是米筐提供的官方数据客户端。安装后你需要调用rqdatac.init()进行初始化输入你的用户名和密码米筐官网注册可获得免费基础数据额度。这一步一定要在代码最开始执行并且确保网络通畅。3.2 米筐数据获取的实战技巧与避坑米筐的get_price函数是最常用的数据获取接口但参数很多用不对就是坑。import rqdatac as rq import pandas as pd rq.init(your_username, your_password) # 示例获取螺纹钢主力连续合约的日线数据 # 坑1合约代码。RB8888是加权指数非连续合约。主力连续代码通常为品种代码88如RB88。 # 但更规范的做法是使用futures_continuation函数或直接指定具体合约。 symbol RB88 # 螺纹钢主力连续 # 坑2字段选择。open, high, low, close, volume, open_interest是基础。 # 务必把settlement结算价也取出来。 fields [open, high, low, close, volume, open_interest, settlement] # 坑3频率与时间。期货日线数据end_date最好比当前日期早一天避免获取到不完整的当日数据。 df rq.get_price(symbol, start_date2023-01-01, end_date2024-05-20, # 假设今天是2024-05-21 frequency1d, fieldsfields, adjust_typenone) # 期货通常不需要复权设为none print(df.head())关键解读与避坑点adjust_typenone对于商品期货我们通常不对价格进行复权处理。金融期货如股指期货可能需要考虑分红但米筐的股指期货数据通常已处理。symbol这是最大的坑。对于回测我们更应使用实际可交易的合约序列。一个更专业的做法是先获取一段时间内的主力合约列表然后循环获取每个主力合约在其主力时期的数据再拼接成连续合约。米筐的futures_continuation函数可以简化这个过程但需要理解其规则如滚动日。对于初学者直接使用RB88等主力连续代码进行初步回测是可以的但心里要明白这与真实交易有差距。数据完整性检查拿到数据后务必检查是否有缺失值NaN特别是节假日后的第一个交易日。使用df.isnull().sum()快速查看。4. 30日均线因子的稳健计算数据有了计算均线就是一行代码的事但这一行代码前后有很多细节需要打磨。4.1 基础计算与pandas的rolling陷阱最直接的计算方式# 假设我们决定以结算价作为计算基准 df[ma30_settlement] df[settlement].rolling(window30, min_periods1).mean() # 同样也可以用收盘价计算一条用于对比 df[ma30_close] df[close].rolling(window30, min_periods1).mean()这里min_periods1意味着即使窗口内只有一个有效值也进行计算结果就是它本身。这避免了序列开头出现一大段NaN。第一个陷阱未来函数Look-ahead Bias。.rolling().mean()在默认情况下窗口是“居中”的吗不在pandas的默认设置下.rolling()计算的是“当前点及之前N-1个点”的均值。这本身是符合交易逻辑的用过去30天的数据算今天的均线。但你要极度小心在数据清洗或排序时打乱了时间顺序导致未来的数据“混入”了历史窗口。确保你的DataFrame索引是严格按时间升序排列的。第二个陷阱缺失值处理。如果30天窗口内因为节假日等原因有缺失值rolling会忽略NaN吗默认的.mean()会受NaN影响结果也是NaN。如果你希望窗口内至少有M个有效值才计算就设置min_periodsM。或者可以先使用.fillna(methodffill)进行前向填充但填充逻辑需要根据业务判断。4.2 针对期货数据的进阶处理基于主力合约规则的连续数据构建 这是追求更高仿真度的做法。思路是获取标的如螺纹钢的所有合约识别每日的主力合约通常以持仓量最大为标准然后每日都使用当日主力合约的数据来形成连续价格序列。# 简化示例实际应用需考虑换月日规则 all_contracts [rb2401, rb2405, rb2410, ...] # 应通过rq获取 continuous_data [] for date in trading_dates: # 找出该日期的主力合约伪代码 dominant_contract find_dominant_contract(date, all_contracts) # 获取该合约该日的数据 daily_data get_daily_data(dominant_contract, date) continuous_data.append(daily_data) df_continuous pd.concat(continuous_data)这样构建的df_continuous其价格序列在换月日可能存在跳空缺口因为新旧合约价差但这恰恰是真实交易中需要承担的。因子可视化与初步校验 计算完均线别急着往下写策略。先画图直观感受一下。import matplotlib.pyplot as plt plt.figure(figsize(15,8)) plt.plot(df.index, df[settlement], labelSettlement Price, linewidth1) plt.plot(df.index, df[ma30_settlement], label30D MA (Settlement), linewidth2, alpha0.8) plt.title(RB Main Contract: Price vs 30-Day Moving Average) plt.legend() plt.grid(True, linestyle--, alpha0.5) plt.show()通过看图你可以快速检查均线是否平滑是否存在因数据异常导致的毛刺以及价格与均线的交叉情况是否符合预期。5. 交易策略逻辑的实现与细节信号产生很简单但如何将信号转化为可回测的交易列表里面门道很多。5.1 信号生成与点位处理我们以最简单的“价格上穿均线做多下穿均线做空”为例。# 生成交易信号1为做多-1为做空0为观望 df[signal] 0 # 上穿昨日价格均线今日价格均线 df.loc[(df[settlement].shift(1) df[ma30_settlement].shift(1)) (df[settlement] df[ma30_settlement]), signal] 1 # 下穿昨日价格均线今日价格均线 df.loc[(df[settlement].shift(1) df[ma30_settlement].shift(1)) (df[settlement] df[ma30_settlement]), signal] -1 # 为了回测我们通常需要知道信号发生的位置索引和方向 trade_signals df[df[signal] ! 0].copy() print(trade_signals[[settlement, ma30_settlement, signal]].head())关键细节使用.shift(1)来确保我们用的是“昨日”的均线值进行比较严格避免未来函数。今天的信号只能基于昨天及之前的数据产生。这里用的是settlement结算价和ma30_settlement进行比较。一个重要的实战考量在实际交易中我们通常在收盘后结算价出来之后计算指标、生成信号然后在下一个交易日的开盘或指定时间段内执行。因此回测时信号产生日t日的实际成交价格应该是t1日的开盘价或均价。这是回测能否贴近现实的关键之一。5.2 回测引擎核心逻辑搭建我们不依赖复杂的回测框架自己搭建一个简单的、但能体现核心逻辑的回测循环有助于理解每一笔交易是如何发生的。# 初始化账户和持仓记录 initial_capital 1000000 # 初始资金100万 capital initial_capital position 0 # 持仓手数正为多负为空 trade_list [] # 记录所有交易 commission_rate 0.0003 # 单边手续费率假设万分之三 margin_ratio 0.10 # 保证金比例假设10% slippage 1 # 滑点假设1个最小变动价位 # 假设合约乘数每手吨数螺纹钢是10吨/手 contract_multiplier 10 # 假设最小变动价位是1元/吨 tick_size 1 for i in range(1, len(df)): # 从第1天开始因为需要前一天的数据 current_date df.index[i] prev_signal df.iloc[i-1][signal] # 昨天的信号 today_open df.iloc[i][open] # 今天的开盘价作为成交价假设 # 如果昨天有信号今天开盘执行 if prev_signal ! 0: # 确定交易方向 trade_direction prev_signal # 1为买入开多/平空-1为卖出开空/平多 # 计算目标持仓 target_position trade_direction # 这里简化每次只交易1手。实际应根据资金管理计算手数。 # 计算实际需要变化的手数 position_change target_position - position if position_change ! 0: # 计算成交价考虑滑点 if position_change 0: # 买入 execute_price today_open slippage * tick_size trade_type buy_open if position 0 else buy_close else: # 卖出 execute_price today_open - slippage * tick_size trade_type sell_open if position 0 else sell_close # 计算交易金额、手续费、保证金变化 trade_value abs(position_change) * contract_multiplier * execute_price commission trade_value * commission_rate # 保证金占用开仓增加平仓释放 margin_change trade_value * margin_ratio if open in trade_type else -trade_value * margin_ratio # 更新资金和持仓简化处理未考虑浮动盈亏逐日盯市 capital - commission position target_position # 记录交易 trade_record { date: current_date, type: trade_type, price: execute_price, volume: abs(position_change), commission: commission, position_after: position } trade_list.append(trade_record) # 将交易记录转为DataFrame trades_df pd.DataFrame(trade_list) print(trades_df.head())这个简易回测逻辑包含了信号执行、滑点、手续费、保证金计算等核心要素。它清晰地展示了从信号到交易的完整链路。6. 绩效评估与策略分析交易列表有了我们需要评估这个策略到底行不行。不能只看最终盈亏要从多个维度分析。6.1 关键绩效指标计算我们可以基于每日的持仓和价格计算每日的账户权益曲线进而计算各种指标。# 假设我们根据trades_df和df已经计算出了每日的持仓市值、浮动盈亏、净值和资金曲线equity_curve # equity_curve是一个包含日期和净值的DataFrame # 计算收益率序列 equity_curve[returns] equity_curve[nav].pct_change().fillna(0) # 1. 总收益率 total_return (equity_curve[nav].iloc[-1] / equity_curve[nav].iloc[0]) - 1 # 2. 年化收益率假设一年252个交易日 annual_return (1 total_return) ** (252 / len(equity_curve)) - 1 # 3. 最大回撤Max Drawdown - 这是风险控制的核心指标 nav_series equity_curve[nav].values peak np.maximum.accumulate(nav_series) drawdown (nav_series - peak) / peak max_drawdown np.min(drawdown) # 4. 夏普比率Sharpe Ratio - 风险调整后收益 # 假设无风险利率为0.033% risk_free_rate 0.03 excess_returns equity_curve[returns] - risk_free_rate/252 sharpe_ratio np.sqrt(252) * excess_returns.mean() / excess_returns.std() print(f总收益率: {total_return:.2%}) print(f年化收益率: {annual_return:.2%}) print(f最大回撤: {max_drawdown:.2%}) print(f夏普比率: {sharpe_ratio:.2f})6.2 可视化分析净值曲线与回撤图数字是冰冷的图表是直观的。绘制净值曲线和回撤图是标准动作。fig, axes plt.subplots(2, 1, figsize(15, 10), sharexTrue) # 净值曲线 axes[0].plot(equity_curve.index, equity_curve[nav], labelStrategy NAV, linewidth2) axes[0].plot(equity_curve.index, equity_curve[nav].iloc[0] * (1 df[settlement].pct_change().cumsum()), labelBuy Hold (Settlement), alpha0.7) axes[0].set_title(Strategy Net Asset Value vs Buy Hold) axes[0].set_ylabel(Net Asset Value) axes[0].legend() axes[0].grid(True, linestyle--, alpha0.5) # 回撤曲线 axes[1].fill_between(equity_curve.index, drawdown*100, 0, colorred, alpha0.3) axes[1].plot(equity_curve.index, drawdown*100, colordarkred, linewidth1) axes[1].set_title(Strategy Drawdown) axes[1].set_ylabel(Drawdown (%)) axes[1].set_xlabel(Date) axes[1].grid(True, linestyle--, alpha0.5) # 标注最大回撤 max_dd_idx np.argmin(drawdown) axes[1].axvline(xequity_curve.index[max_dd_idx], colorgrey, linestyle--, alpha0.5) axes[1].text(equity_curve.index[max_dd_idx], drawdown[max_dd_idx]*100/2, fMax DD: {max_drawdown:.2%}, hacenter) plt.tight_layout() plt.show()通过对比策略净值曲线和简单的买入持有Buy Hold曲线你可以直观看出策略是否创造了超额收益。回撤图则能让你一眼看到策略承受的最大压力时期在哪里。7. 避坑指南与常见问题排查这部分是我踩过无数坑后总结的血泪经验可能比前面的代码更有价值。7.1 数据层面的坑坑使用指数合约如RB8888直接回测。现象回测结果异常优异夏普比率高回撤小。原因指数合约是加权合成的平滑了换月缺口和单个合约的极端波动没有反映真实的交易成本和换月冲击。解决使用主力连续合约RB88或自己构建的连续合约。对于初步研究RB88是可接受的但必须在报告中明确指出这一点。坑忽略结算价与收盘价的差异。现象基于收盘价的信号和基于结算价的信号在某些关键日期不一致导致回测结果不稳定。原因期货收盘价有时受尾盘集中交易影响较大而结算价是全天成交量的加权平均更具代表性。交易所的风控、强平都基于结算价。解决统一以结算价作为计算因子和判断信号的基准。在回测成交时再根据实际情况使用次日开盘价或均价。坑数据缺失或异常值。现象均线出现突然的跳变或毛刺。排查定期检查数据。使用df.describe()查看数据分布用df.isnull().sum()检查缺失值。对于节假日前向填充ffill是常用方法但要小心在合约换月时错误填充。7.2 策略逻辑与回测的坑坑未来函数Look-ahead Bias。现象策略在历史回测中表现“神准”实盘一塌糊涂。检查确保任何在时间t使用的数据其生成时间都严格早于或等于t。仔细检查.shift()的使用确保没有误用.rolling的center参数默认False。在回测循环中t日的信号必须只能用t-1日及之前的数据生成并在t日或之后执行。坑忽略交易成本与滑点。现象回测盈利实盘微利或亏损。解决手续费要区分开仓、平仓、平今仓如果有。滑点不能设为0对于流动性一般的品种滑点设置要更保守。在回测结果中可以做一个敏感性分析展示不同手续费和滑点假设下的绩效变化。坑简单的全仓进出资金管理。现象回测中一次大幅回撤就可能击穿账户。解决引入仓位管理。例如固定百分比仓位每次使用固定比例的资金开仓或基于波动率的仓位调整ATR。在回测中动态计算保证金占用和可用资金确保不会因保证金不足而无法开仓。坑没有考虑主力合约换月。现象在回测时间段内策略绩效在某个日期突然大幅跳跃。解决如果你交易的是主力连续合约RB88系统会自动处理换月。但如果你是自己拼接合约必须在换月日进行“平旧仓、开新仓”的操作并在回测中计入这笔交易的滑点和手续费。这是回测中最容易被忽略的真实成本之一。7.3 绩效评估的坑坑过度依赖单一指标如年化收益。现象一个年化收益50%但最大回撤80%的策略几乎不可能被实盘。解决必须综合评估收益与风险。最大回撤Max Drawdown和卡玛比率Calmar Ratio年化收益/最大回撤是比夏普比率更受实战派重视的指标。同时要分析收益的稳定性月度/季度胜率、交易频率是否过于频繁产生大量摩擦成本以及策略在震荡市和趋势市中的不同表现。坑在单一品种、单一参数上过度优化。现象30日均线在螺纹钢2018-2020年表现很好于是你就用了。结果2021年行情一变策略持续亏损。解决进行样本外测试和参数敏感性分析。将数据分为训练集和测试集。在训练集上找到的“最优”参数必须在测试集上依然有效。尝试将均线周期改为28、32、35看看策略绩效是否发生剧烈变化。如果绩效对参数极其敏感即“参数孤岛”那么这个策略很可能缺乏鲁棒性是过度拟合的产物。8. 从回测到模拟的进阶思考当你按照上面的步骤完成了一个相对严谨的回测后这只是一个开始离实盘还有很远。下一步应该是进行模拟交易Paper Trading。接入实时数据将你的策略脚本改造成一个能定时如每天收盘后从米筐获取最新数据、计算信号、并生成交易指令的程序。模拟交易记录在一个Excel或数据库中手动或自动记录每一笔模拟交易包括信号时间、计划交易价格、实际成交价可以用次日开盘价模拟、手续费等。严格模拟真实账户的资金和持仓变动。监控与日志为你的策略添加详细的日志功能记录每一天的数据、计算过程、产生的信号及原因。当模拟结果与回测出现较大偏差时这些日志是排查问题的唯一依据。心态磨练模拟交易最大的价值之一是磨练心态。看着模拟仓位出现大幅浮动盈亏你是否能坚持策略信号是否会忍不住手动干预这个过程能暴露出策略逻辑之外的人性弱点。这个基于30日均线的期货因子策略就像一把尺子能量化出市场的趋势。但尺子本身不会赚钱赚钱的是使用尺子的人以及他如何应对尺子失灵的时刻。我的经验是把80%的精力花在数据清洗、回测逻辑的严谨性、风险控制的设置上这些“笨功夫”才是策略能否从纸面走向实盘的关键。那些看起来最不起眼的细节比如是用结算价还是收盘价换月滑点设几个点往往决定了策略最终的命运。
1. 项目概述从“能跑”到“能用”的因子计算之路做量化策略的朋友尤其是刚入期货这个坑的估计都听过或者自己写过基于均线的策略。听起来很简单不就是算个30日均线然后金叉买死叉卖嘛。我刚开始也是这么想的直到真金白银跑起来才发现从“代码能跑通”到“策略能实盘”之间隔着一整个太平洋的坑。今天要聊的这个“基于米筐数据Python的30日均线策略实现”就是一个非常典型的案例。它表面上是一个入门级的策略实现但内核却是一个完整的因子计算与回测工程化流程的缩影。很多新手包括当年的我会直接把网上搜到的教程代码复制过来用米筐RiceQuant的数据接口拉个收盘价用pandas的.rolling(30).mean()一算回测一看曲线挺漂亮就觉得大功告成了。结果一上实盘或者做更细致的分析各种问题就来了数据有没有复权合约到期换月怎么处理均线计算用的是收盘价还是结算价回测时是收盘价成交还是下一根K线开盘价成交这些细节任何一个没处理好轻则回测结果失真重则直接导致实盘亏损。所以这篇内容我想抛开那些花哨的策略理论就扎扎实实地复盘一下如何用Python和米筐数据把一个看似简单的30日均线因子从数据获取、计算、到策略逻辑实现每一步都做得扎实、可靠、可复现。这不仅是写给期货量化新手的避坑指南也是给有一定经验的朋友做一次工程细节上的查漏补缺。2. 核心需求解析为什么是30日均线与期货在动手敲代码之前我们得先想明白两个问题为什么选择30日均线这个因子以及在期货市场上应用它有什么特殊之处2.1 30日均线的策略逻辑与市场假设30日均线或者说任何周期的移动平均线其核心逻辑是平滑价格序列识别趋势。短期均线如5日、10日对价格反应灵敏但噪音也多长期均线如60日、120日趋势稳定但信号滞后严重。30日这个周期在A股和很多期货品种上被经验性地认为是一个能较好平衡响应速度和趋势稳定性的折中点。它大约覆盖了1.5个月按交易日算的价格信息既能过滤掉大部分日内的随机波动和短期扰动又不会对中期级别的趋势反转反应过于迟钝。我们的策略假设是当价格上穿30日均线时意味着短期动能可能突破了中期平均成本趋势有望向上触发买入信号当价格下穿30日均线时则意味着趋势可能转弱或反转触发卖出或做空信号。这是一个典型的趋势跟踪策略它不预测市场顶部或底部而是试图在趋势确立时入场在趋势结束时离场。在期货市场由于可以做空这个逻辑可以双向运用即上穿做多下穿做空构成一个完整的双向交易系统。2.2 期货数据与策略的特殊性这才是坑最多的地方。股票数据相对“干净”有明确的前复权、后复权处理标的股票代码长期不变。期货则复杂得多合约生命周期与主力连续每个期货合约如rb2410都有固定的到期日。你不能直接对一个即将到期的合约计算30日均线然后长期持有因为你会面临交割。因此量化交易通常交易的是“主力连续合约”或自己构建的“连续合约”它通过拼接不同时期的主力合约来形成一个长期连续的行情序列。米筐数据提供了dominant字段来标识主力合约也提供了futures_continuation函数来生成连续合约。第一个大坑直接对单个合约代码如RB8888这是米筐的指数合约非交易合约进行回测其结果与交易主力连续合约的结果会有显著差异。价格字段的选择股票通常看收盘价。期货呢收盘价close、结算价settlement、均价avg都可以作为计算基准。结算价是当日无负债结算的基础更能代表市场的公允成本许多机构风控和指标计算以结算价为准。而收盘价可能因为尾盘投机盘影响出现较大偏离。第二个大坑用收盘价计算均线、用结算价计算保证金和盈亏会导致策略信号与风控基准错配。保证金与杠杆期货是保证金交易这直接关系到资金管理和回测的真实性。回测中必须考虑动态保证金占用不能简单假设全仓进出。换月滑点与交易成本在主力合约换月时价差Spread可能很大。你的策略信号在旧合约上产生但实际需要平仓旧合约、开仓新合约这个过程会产生额外的滑点和手续费。这部分成本在简单回测中极易被忽略。理解了这些我们才能有的放矢地设计我们的数据处理和回测流程。3. 环境准备与米筐数据接口详解工欲善其事必先利其器。一个稳定、清晰的数据获取环境是量化工作的基石。3.1 Python环境与核心库配置现在不建议大家再从python.org下载原生Python了管理包依赖太麻烦。我强烈推荐使用Miniconda或Anaconda来管理Python环境。创建一个独立的量化环境可以避免不同项目间的库版本冲突。# 创建一个名为qtn_futures的虚拟环境指定Python版本为3.8一个兼容性较好的版本 conda create -n qtn_futures python3.8 # 激活环境 conda activate qtn_futures接下来安装核心库。除了米筐的rqdatac我们还需要数据分析的pandas、numpy以及用于画图的matplotlib。如果你要做更复杂的分析empyrical绩效分析和alphalens因子分析也是不错的选择。# 安装核心库 pip install rqdatac pandas numpy matplotlib # 如果需要安装绩效分析库 pip install empyrical注意rqdatac是米筐提供的官方数据客户端。安装后你需要调用rqdatac.init()进行初始化输入你的用户名和密码米筐官网注册可获得免费基础数据额度。这一步一定要在代码最开始执行并且确保网络通畅。3.2 米筐数据获取的实战技巧与避坑米筐的get_price函数是最常用的数据获取接口但参数很多用不对就是坑。import rqdatac as rq import pandas as pd rq.init(your_username, your_password) # 示例获取螺纹钢主力连续合约的日线数据 # 坑1合约代码。RB8888是加权指数非连续合约。主力连续代码通常为品种代码88如RB88。 # 但更规范的做法是使用futures_continuation函数或直接指定具体合约。 symbol RB88 # 螺纹钢主力连续 # 坑2字段选择。open, high, low, close, volume, open_interest是基础。 # 务必把settlement结算价也取出来。 fields [open, high, low, close, volume, open_interest, settlement] # 坑3频率与时间。期货日线数据end_date最好比当前日期早一天避免获取到不完整的当日数据。 df rq.get_price(symbol, start_date2023-01-01, end_date2024-05-20, # 假设今天是2024-05-21 frequency1d, fieldsfields, adjust_typenone) # 期货通常不需要复权设为none print(df.head())关键解读与避坑点adjust_typenone对于商品期货我们通常不对价格进行复权处理。金融期货如股指期货可能需要考虑分红但米筐的股指期货数据通常已处理。symbol这是最大的坑。对于回测我们更应使用实际可交易的合约序列。一个更专业的做法是先获取一段时间内的主力合约列表然后循环获取每个主力合约在其主力时期的数据再拼接成连续合约。米筐的futures_continuation函数可以简化这个过程但需要理解其规则如滚动日。对于初学者直接使用RB88等主力连续代码进行初步回测是可以的但心里要明白这与真实交易有差距。数据完整性检查拿到数据后务必检查是否有缺失值NaN特别是节假日后的第一个交易日。使用df.isnull().sum()快速查看。4. 30日均线因子的稳健计算数据有了计算均线就是一行代码的事但这一行代码前后有很多细节需要打磨。4.1 基础计算与pandas的rolling陷阱最直接的计算方式# 假设我们决定以结算价作为计算基准 df[ma30_settlement] df[settlement].rolling(window30, min_periods1).mean() # 同样也可以用收盘价计算一条用于对比 df[ma30_close] df[close].rolling(window30, min_periods1).mean()这里min_periods1意味着即使窗口内只有一个有效值也进行计算结果就是它本身。这避免了序列开头出现一大段NaN。第一个陷阱未来函数Look-ahead Bias。.rolling().mean()在默认情况下窗口是“居中”的吗不在pandas的默认设置下.rolling()计算的是“当前点及之前N-1个点”的均值。这本身是符合交易逻辑的用过去30天的数据算今天的均线。但你要极度小心在数据清洗或排序时打乱了时间顺序导致未来的数据“混入”了历史窗口。确保你的DataFrame索引是严格按时间升序排列的。第二个陷阱缺失值处理。如果30天窗口内因为节假日等原因有缺失值rolling会忽略NaN吗默认的.mean()会受NaN影响结果也是NaN。如果你希望窗口内至少有M个有效值才计算就设置min_periodsM。或者可以先使用.fillna(methodffill)进行前向填充但填充逻辑需要根据业务判断。4.2 针对期货数据的进阶处理基于主力合约规则的连续数据构建 这是追求更高仿真度的做法。思路是获取标的如螺纹钢的所有合约识别每日的主力合约通常以持仓量最大为标准然后每日都使用当日主力合约的数据来形成连续价格序列。# 简化示例实际应用需考虑换月日规则 all_contracts [rb2401, rb2405, rb2410, ...] # 应通过rq获取 continuous_data [] for date in trading_dates: # 找出该日期的主力合约伪代码 dominant_contract find_dominant_contract(date, all_contracts) # 获取该合约该日的数据 daily_data get_daily_data(dominant_contract, date) continuous_data.append(daily_data) df_continuous pd.concat(continuous_data)这样构建的df_continuous其价格序列在换月日可能存在跳空缺口因为新旧合约价差但这恰恰是真实交易中需要承担的。因子可视化与初步校验 计算完均线别急着往下写策略。先画图直观感受一下。import matplotlib.pyplot as plt plt.figure(figsize(15,8)) plt.plot(df.index, df[settlement], labelSettlement Price, linewidth1) plt.plot(df.index, df[ma30_settlement], label30D MA (Settlement), linewidth2, alpha0.8) plt.title(RB Main Contract: Price vs 30-Day Moving Average) plt.legend() plt.grid(True, linestyle--, alpha0.5) plt.show()通过看图你可以快速检查均线是否平滑是否存在因数据异常导致的毛刺以及价格与均线的交叉情况是否符合预期。5. 交易策略逻辑的实现与细节信号产生很简单但如何将信号转化为可回测的交易列表里面门道很多。5.1 信号生成与点位处理我们以最简单的“价格上穿均线做多下穿均线做空”为例。# 生成交易信号1为做多-1为做空0为观望 df[signal] 0 # 上穿昨日价格均线今日价格均线 df.loc[(df[settlement].shift(1) df[ma30_settlement].shift(1)) (df[settlement] df[ma30_settlement]), signal] 1 # 下穿昨日价格均线今日价格均线 df.loc[(df[settlement].shift(1) df[ma30_settlement].shift(1)) (df[settlement] df[ma30_settlement]), signal] -1 # 为了回测我们通常需要知道信号发生的位置索引和方向 trade_signals df[df[signal] ! 0].copy() print(trade_signals[[settlement, ma30_settlement, signal]].head())关键细节使用.shift(1)来确保我们用的是“昨日”的均线值进行比较严格避免未来函数。今天的信号只能基于昨天及之前的数据产生。这里用的是settlement结算价和ma30_settlement进行比较。一个重要的实战考量在实际交易中我们通常在收盘后结算价出来之后计算指标、生成信号然后在下一个交易日的开盘或指定时间段内执行。因此回测时信号产生日t日的实际成交价格应该是t1日的开盘价或均价。这是回测能否贴近现实的关键之一。5.2 回测引擎核心逻辑搭建我们不依赖复杂的回测框架自己搭建一个简单的、但能体现核心逻辑的回测循环有助于理解每一笔交易是如何发生的。# 初始化账户和持仓记录 initial_capital 1000000 # 初始资金100万 capital initial_capital position 0 # 持仓手数正为多负为空 trade_list [] # 记录所有交易 commission_rate 0.0003 # 单边手续费率假设万分之三 margin_ratio 0.10 # 保证金比例假设10% slippage 1 # 滑点假设1个最小变动价位 # 假设合约乘数每手吨数螺纹钢是10吨/手 contract_multiplier 10 # 假设最小变动价位是1元/吨 tick_size 1 for i in range(1, len(df)): # 从第1天开始因为需要前一天的数据 current_date df.index[i] prev_signal df.iloc[i-1][signal] # 昨天的信号 today_open df.iloc[i][open] # 今天的开盘价作为成交价假设 # 如果昨天有信号今天开盘执行 if prev_signal ! 0: # 确定交易方向 trade_direction prev_signal # 1为买入开多/平空-1为卖出开空/平多 # 计算目标持仓 target_position trade_direction # 这里简化每次只交易1手。实际应根据资金管理计算手数。 # 计算实际需要变化的手数 position_change target_position - position if position_change ! 0: # 计算成交价考虑滑点 if position_change 0: # 买入 execute_price today_open slippage * tick_size trade_type buy_open if position 0 else buy_close else: # 卖出 execute_price today_open - slippage * tick_size trade_type sell_open if position 0 else sell_close # 计算交易金额、手续费、保证金变化 trade_value abs(position_change) * contract_multiplier * execute_price commission trade_value * commission_rate # 保证金占用开仓增加平仓释放 margin_change trade_value * margin_ratio if open in trade_type else -trade_value * margin_ratio # 更新资金和持仓简化处理未考虑浮动盈亏逐日盯市 capital - commission position target_position # 记录交易 trade_record { date: current_date, type: trade_type, price: execute_price, volume: abs(position_change), commission: commission, position_after: position } trade_list.append(trade_record) # 将交易记录转为DataFrame trades_df pd.DataFrame(trade_list) print(trades_df.head())这个简易回测逻辑包含了信号执行、滑点、手续费、保证金计算等核心要素。它清晰地展示了从信号到交易的完整链路。6. 绩效评估与策略分析交易列表有了我们需要评估这个策略到底行不行。不能只看最终盈亏要从多个维度分析。6.1 关键绩效指标计算我们可以基于每日的持仓和价格计算每日的账户权益曲线进而计算各种指标。# 假设我们根据trades_df和df已经计算出了每日的持仓市值、浮动盈亏、净值和资金曲线equity_curve # equity_curve是一个包含日期和净值的DataFrame # 计算收益率序列 equity_curve[returns] equity_curve[nav].pct_change().fillna(0) # 1. 总收益率 total_return (equity_curve[nav].iloc[-1] / equity_curve[nav].iloc[0]) - 1 # 2. 年化收益率假设一年252个交易日 annual_return (1 total_return) ** (252 / len(equity_curve)) - 1 # 3. 最大回撤Max Drawdown - 这是风险控制的核心指标 nav_series equity_curve[nav].values peak np.maximum.accumulate(nav_series) drawdown (nav_series - peak) / peak max_drawdown np.min(drawdown) # 4. 夏普比率Sharpe Ratio - 风险调整后收益 # 假设无风险利率为0.033% risk_free_rate 0.03 excess_returns equity_curve[returns] - risk_free_rate/252 sharpe_ratio np.sqrt(252) * excess_returns.mean() / excess_returns.std() print(f总收益率: {total_return:.2%}) print(f年化收益率: {annual_return:.2%}) print(f最大回撤: {max_drawdown:.2%}) print(f夏普比率: {sharpe_ratio:.2f})6.2 可视化分析净值曲线与回撤图数字是冰冷的图表是直观的。绘制净值曲线和回撤图是标准动作。fig, axes plt.subplots(2, 1, figsize(15, 10), sharexTrue) # 净值曲线 axes[0].plot(equity_curve.index, equity_curve[nav], labelStrategy NAV, linewidth2) axes[0].plot(equity_curve.index, equity_curve[nav].iloc[0] * (1 df[settlement].pct_change().cumsum()), labelBuy Hold (Settlement), alpha0.7) axes[0].set_title(Strategy Net Asset Value vs Buy Hold) axes[0].set_ylabel(Net Asset Value) axes[0].legend() axes[0].grid(True, linestyle--, alpha0.5) # 回撤曲线 axes[1].fill_between(equity_curve.index, drawdown*100, 0, colorred, alpha0.3) axes[1].plot(equity_curve.index, drawdown*100, colordarkred, linewidth1) axes[1].set_title(Strategy Drawdown) axes[1].set_ylabel(Drawdown (%)) axes[1].set_xlabel(Date) axes[1].grid(True, linestyle--, alpha0.5) # 标注最大回撤 max_dd_idx np.argmin(drawdown) axes[1].axvline(xequity_curve.index[max_dd_idx], colorgrey, linestyle--, alpha0.5) axes[1].text(equity_curve.index[max_dd_idx], drawdown[max_dd_idx]*100/2, fMax DD: {max_drawdown:.2%}, hacenter) plt.tight_layout() plt.show()通过对比策略净值曲线和简单的买入持有Buy Hold曲线你可以直观看出策略是否创造了超额收益。回撤图则能让你一眼看到策略承受的最大压力时期在哪里。7. 避坑指南与常见问题排查这部分是我踩过无数坑后总结的血泪经验可能比前面的代码更有价值。7.1 数据层面的坑坑使用指数合约如RB8888直接回测。现象回测结果异常优异夏普比率高回撤小。原因指数合约是加权合成的平滑了换月缺口和单个合约的极端波动没有反映真实的交易成本和换月冲击。解决使用主力连续合约RB88或自己构建的连续合约。对于初步研究RB88是可接受的但必须在报告中明确指出这一点。坑忽略结算价与收盘价的差异。现象基于收盘价的信号和基于结算价的信号在某些关键日期不一致导致回测结果不稳定。原因期货收盘价有时受尾盘集中交易影响较大而结算价是全天成交量的加权平均更具代表性。交易所的风控、强平都基于结算价。解决统一以结算价作为计算因子和判断信号的基准。在回测成交时再根据实际情况使用次日开盘价或均价。坑数据缺失或异常值。现象均线出现突然的跳变或毛刺。排查定期检查数据。使用df.describe()查看数据分布用df.isnull().sum()检查缺失值。对于节假日前向填充ffill是常用方法但要小心在合约换月时错误填充。7.2 策略逻辑与回测的坑坑未来函数Look-ahead Bias。现象策略在历史回测中表现“神准”实盘一塌糊涂。检查确保任何在时间t使用的数据其生成时间都严格早于或等于t。仔细检查.shift()的使用确保没有误用.rolling的center参数默认False。在回测循环中t日的信号必须只能用t-1日及之前的数据生成并在t日或之后执行。坑忽略交易成本与滑点。现象回测盈利实盘微利或亏损。解决手续费要区分开仓、平仓、平今仓如果有。滑点不能设为0对于流动性一般的品种滑点设置要更保守。在回测结果中可以做一个敏感性分析展示不同手续费和滑点假设下的绩效变化。坑简单的全仓进出资金管理。现象回测中一次大幅回撤就可能击穿账户。解决引入仓位管理。例如固定百分比仓位每次使用固定比例的资金开仓或基于波动率的仓位调整ATR。在回测中动态计算保证金占用和可用资金确保不会因保证金不足而无法开仓。坑没有考虑主力合约换月。现象在回测时间段内策略绩效在某个日期突然大幅跳跃。解决如果你交易的是主力连续合约RB88系统会自动处理换月。但如果你是自己拼接合约必须在换月日进行“平旧仓、开新仓”的操作并在回测中计入这笔交易的滑点和手续费。这是回测中最容易被忽略的真实成本之一。7.3 绩效评估的坑坑过度依赖单一指标如年化收益。现象一个年化收益50%但最大回撤80%的策略几乎不可能被实盘。解决必须综合评估收益与风险。最大回撤Max Drawdown和卡玛比率Calmar Ratio年化收益/最大回撤是比夏普比率更受实战派重视的指标。同时要分析收益的稳定性月度/季度胜率、交易频率是否过于频繁产生大量摩擦成本以及策略在震荡市和趋势市中的不同表现。坑在单一品种、单一参数上过度优化。现象30日均线在螺纹钢2018-2020年表现很好于是你就用了。结果2021年行情一变策略持续亏损。解决进行样本外测试和参数敏感性分析。将数据分为训练集和测试集。在训练集上找到的“最优”参数必须在测试集上依然有效。尝试将均线周期改为28、32、35看看策略绩效是否发生剧烈变化。如果绩效对参数极其敏感即“参数孤岛”那么这个策略很可能缺乏鲁棒性是过度拟合的产物。8. 从回测到模拟的进阶思考当你按照上面的步骤完成了一个相对严谨的回测后这只是一个开始离实盘还有很远。下一步应该是进行模拟交易Paper Trading。接入实时数据将你的策略脚本改造成一个能定时如每天收盘后从米筐获取最新数据、计算信号、并生成交易指令的程序。模拟交易记录在一个Excel或数据库中手动或自动记录每一笔模拟交易包括信号时间、计划交易价格、实际成交价可以用次日开盘价模拟、手续费等。严格模拟真实账户的资金和持仓变动。监控与日志为你的策略添加详细的日志功能记录每一天的数据、计算过程、产生的信号及原因。当模拟结果与回测出现较大偏差时这些日志是排查问题的唯一依据。心态磨练模拟交易最大的价值之一是磨练心态。看着模拟仓位出现大幅浮动盈亏你是否能坚持策略信号是否会忍不住手动干预这个过程能暴露出策略逻辑之外的人性弱点。这个基于30日均线的期货因子策略就像一把尺子能量化出市场的趋势。但尺子本身不会赚钱赚钱的是使用尺子的人以及他如何应对尺子失灵的时刻。我的经验是把80%的精力花在数据清洗、回测逻辑的严谨性、风险控制的设置上这些“笨功夫”才是策略能否从纸面走向实盘的关键。那些看起来最不起眼的细节比如是用结算价还是收盘价换月滑点设几个点往往决定了策略最终的命运。
