CAi 标准差策略
该策略是将 MQL5 专家 Exp_i-CAi_StDev 移植到 StockSharp 平台的示例。它利用移动平均线和标准差通道来识别突破并在价格回到通道内时退出。
策略逻辑
- 计算指定周期内的简单移动平均线(SMA)。
- 计算同一周期内收盘价的标准差。
- 在 SMA 周围构建两组通道:
- 入场通道:SMA ±
OpenMultiplier× StdDev。 - 出场通道:SMA ±
CloseMultiplier× StdDev。
- 入场通道:SMA ±
- 当价格收盘高于上方入场通道时开多单。
- 当价格收盘低于下方入场通道时开空单。
- 当价格跌破上方出场通道时平多单。
- 当价格升破下方出场通道时平空单。
参数
| 名称 | 描述 | 默认值 |
|---|---|---|
MaLength |
SMA 与标准差的计算周期 | 12 |
StdDevPeriod |
标准差指标的周期 | 9 |
OpenMultiplier |
入场通道的倍数 | 2.5 |
CloseMultiplier |
出场通道的倍数 | 1.5 |
CandleType |
策略使用的K线类型 | 5分钟K线 |
说明
- 策略使用高层 API,通过
Bind获取指标值。 - 仅处理已完成的K线,以避免过早信号。
- 源代码中的注释全部为英文。
using System;
using System.Collections.Generic;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Strategy based on moving average and standard deviation bands.
/// Opens positions when price breaks outside a wide band
/// and closes them when price returns inside a narrower band.
/// </summary>
public class CaiStandardDeviationStrategy : Strategy
{
private readonly StrategyParam<int> _maLength;
private readonly StrategyParam<int> _stdDevPeriod;
private readonly StrategyParam<decimal> _openMultiplier;
private readonly StrategyParam<decimal> _closeMultiplier;
private readonly StrategyParam<DataType> _candleType;
public int MaLength { get => _maLength.Value; set => _maLength.Value = value; }
public int StdDevPeriod { get => _stdDevPeriod.Value; set => _stdDevPeriod.Value = value; }
public decimal OpenMultiplier { get => _openMultiplier.Value; set => _openMultiplier.Value = value; }
public decimal CloseMultiplier { get => _closeMultiplier.Value; set => _closeMultiplier.Value = value; }
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public CaiStandardDeviationStrategy()
{
_maLength = Param(nameof(MaLength), 12)
.SetDisplay("MA Length", "Moving average length", "Parameters")
.SetOptimize(5, 50, 5);
_stdDevPeriod = Param(nameof(StdDevPeriod), 9)
.SetDisplay("StdDev Period", "Standard deviation period", "Parameters")
.SetOptimize(5, 50, 5);
_openMultiplier = Param(nameof(OpenMultiplier), 2.5m)
.SetDisplay("Open Multiplier", "StdDev multiplier for entries", "Parameters")
.SetOptimize(1m, 3m, 0.5m);
_closeMultiplier = Param(nameof(CloseMultiplier), 1.5m)
.SetDisplay("Close Multiplier", "StdDev multiplier for exits", "Parameters")
.SetOptimize(0.5m, 2m, 0.5m);
_candleType = Param(nameof(CandleType), TimeSpan.FromHours(4).TimeFrame())
.SetDisplay("Candle Type", "Type of candles used", "Parameters");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
var sma = new SimpleMovingAverage { Length = MaLength };
var stdDev = new StandardDeviation { Length = StdDevPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(sma, stdDev, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, sma);
DrawIndicator(area, stdDev);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal smaValue, decimal stdDevValue)
{
if (candle.State != CandleStates.Finished)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
var upperOpen = smaValue + OpenMultiplier * stdDevValue;
var lowerOpen = smaValue - OpenMultiplier * stdDevValue;
var upperClose = smaValue + CloseMultiplier * stdDevValue;
var lowerClose = smaValue - CloseMultiplier * stdDevValue;
if (Position <= 0 && candle.ClosePrice > upperOpen)
BuyMarket();
if (Position >= 0 && candle.ClosePrice < lowerOpen)
SellMarket();
if (Position > 0 && candle.ClosePrice < upperClose)
SellMarket();
if (Position < 0 && candle.ClosePrice > lowerClose)
BuyMarket();
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
from System import TimeSpan
from StockSharp.Messages import DataType, CandleStates
from StockSharp.Algo.Indicators import SimpleMovingAverage, StandardDeviation
from StockSharp.Algo.Strategies import Strategy
class cai_standard_deviation_strategy(Strategy):
def __init__(self):
super(cai_standard_deviation_strategy, self).__init__()
self._ma_length = self.Param("MaLength", 12) \
.SetDisplay("MA Length", "Moving average length", "Parameters")
self._std_dev_period = self.Param("StdDevPeriod", 9) \
.SetDisplay("StdDev Period", "Standard deviation period", "Parameters")
self._open_multiplier = self.Param("OpenMultiplier", 2.5) \
.SetDisplay("Open Multiplier", "StdDev multiplier for entries", "Parameters")
self._close_multiplier = self.Param("CloseMultiplier", 1.5) \
.SetDisplay("Close Multiplier", "StdDev multiplier for exits", "Parameters")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromHours(4))) \
.SetDisplay("Candle Type", "Type of candles used", "Parameters")
@property
def ma_length(self):
return self._ma_length.Value
@property
def std_dev_period(self):
return self._std_dev_period.Value
@property
def open_multiplier(self):
return self._open_multiplier.Value
@property
def close_multiplier(self):
return self._close_multiplier.Value
@property
def candle_type(self):
return self._candle_type.Value
def OnStarted2(self, time):
super(cai_standard_deviation_strategy, self).OnStarted2(time)
sma = SimpleMovingAverage()
sma.Length = self.ma_length
std_dev = StandardDeviation()
std_dev.Length = self.std_dev_period
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(sma, std_dev, self.process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, sma)
self.DrawIndicator(area, std_dev)
self.DrawOwnTrades(area)
def process_candle(self, candle, sma_value, std_dev_value):
if candle.State != CandleStates.Finished:
return
sma_value = float(sma_value)
std_dev_value = float(std_dev_value)
open_mult = float(self.open_multiplier)
close_mult = float(self.close_multiplier)
upper_open = sma_value + open_mult * std_dev_value
lower_open = sma_value - open_mult * std_dev_value
upper_close = sma_value + close_mult * std_dev_value
lower_close = sma_value - close_mult * std_dev_value
close_price = float(candle.ClosePrice)
if self.Position <= 0 and close_price > upper_open:
self.BuyMarket()
if self.Position >= 0 and close_price < lower_open:
self.SellMarket()
if self.Position > 0 and close_price < upper_close:
self.SellMarket()
if self.Position < 0 and close_price > lower_close:
self.BuyMarket()
def CreateClone(self):
return cai_standard_deviation_strategy()