Williams %R 平均回帰戦略
Williams %Rは0から-100の間で振動し、価格が最近のレンジの極端な水準付近で終値をつけているときを示します。この戦略は、インジケーターが自身の平均から大きく乖離したときにそれらの極端な水準に逆張りします。
テストでは年平均リターンは約154%を示しています。株式市場で最もよいパフォーマンスを発揮します。
Williams %Rが平均からDeviationMultiplier倍の標準偏差を差し引いた値を下回ったときにロングトレードが発動します。平均にそのマルチプライヤーを加えた値を上回ったときにショートトレードを取ります。Williams %Rが平均レベルに向かって戻ったときに決済します。
このアプローチは、エントリーのタイミングをはかるためにモメンタム枯渇を頼りにするトレーダーに適しています。価格が新たな極値に向かって動き続ける場合、保護的なストップロスがリスクを限定します。
詳細
- エントリー条件:
- ロング: %R < Avg - DeviationMultiplier * StdDev
- ショート: %R > Avg + DeviationMultiplier * StdDev
- ロング/ショート: 両方。
- エグジット条件:
- ロング: %R > Avg のときに決済
- ショート: %R < Avg のときに決済
- ストップ: あり、パーセンテージストップロス。
- デフォルト値:
WilliamsRPeriod= 14AveragePeriod= 20DeviationMultiplier= 2StopLossPercent= 2CandleType= TimeSpan.FromMinutes(5) AvgとStdDevは現在値を含む直近AveragePeriod個の%Rの平均と標準偏差です。 ストップはエントリー価格の固定StopLossPercentで、ローソク足の間も監視されます。0で無効になります。 保有ポジションと逆方向のエントリーシグナルはドテンになります。
- フィルター:
- カテゴリ: 平均回帰
- 方向: 両方
- インジケーター: Williams %R
- ストップ: はい
- 複雑さ: 中級
- 時間軸: イントラデイ
- 季節性: いいえ
- ニューラルネットワーク: いいえ
- ダイバージェンス: いいえ
- リスクレベル: 中
using System;
using System.Collections.Generic;
using System.Linq;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Williams R Mean Reversion strategy.
/// The bands lie DeviationMultiplier standard deviations around the average of the last AveragePeriod %R values, the current one included.
/// %R below the lower band goes long and %R above the upper band goes short,
/// reversing an opposite position. A long closes once %R is back above its average and a short once it is back below it, and a percent stop limits the loss.
/// </summary>
public class WilliamsRMeanReversionStrategy : Strategy
{
private readonly StrategyParam<int> _williamsRPeriod;
private readonly StrategyParam<int> _averagePeriod;
private readonly StrategyParam<decimal> _deviationMultiplier;
private readonly StrategyParam<decimal> _stopLossPercent;
private readonly StrategyParam<DataType> _candleType;
private readonly Queue<decimal> _values = [];
/// <summary>
/// Period of Williams %R.
/// </summary>
public int WilliamsRPeriod
{
get => _williamsRPeriod.Value;
set => _williamsRPeriod.Value = value;
}
/// <summary>
/// Values of %R the average and the standard deviation span.
/// </summary>
public int AveragePeriod
{
get => _averagePeriod.Value;
set => _averagePeriod.Value = value;
}
/// <summary>
/// Standard deviations between the average and a band.
/// </summary>
public decimal DeviationMultiplier
{
get => _deviationMultiplier.Value;
set => _deviationMultiplier.Value = value;
}
/// <summary>
/// Stop loss percentage from entry price.
/// </summary>
public decimal StopLossPercent
{
get => _stopLossPercent.Value;
set => _stopLossPercent.Value = value;
}
/// <summary>
/// Candle type.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Constructor.
/// </summary>
public WilliamsRMeanReversionStrategy()
{
_williamsRPeriod = Param(nameof(WilliamsRPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("Williams %R Period", "Period of Williams %R", "Indicators");
_averagePeriod = Param(nameof(AveragePeriod), 20)
.SetGreaterThanZero()
.SetDisplay("Average Period", "Values of %R the average and the standard deviation span", "Indicators");
_deviationMultiplier = Param(nameof(DeviationMultiplier), 2m)
.SetGreaterThanZero()
.SetDisplay("Multiplier", "Standard deviations between the average and a band", "Indicators");
_stopLossPercent = Param(nameof(StopLossPercent), 2m)
.SetNotNegative()
.SetDisplay("Stop Loss %", "Stop loss percentage from entry price", "Risk");
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_values.Clear();
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_values.Clear();
var williams = new WilliamsR { Length = WilliamsRPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.BindEx(williams, ProcessCandle)
.Start();
StartProtection(new Unit(), new Unit(StopLossPercent, UnitTypes.Percent), useMarketOrders: true, isLocalStop: true);
// The stop has to see prices between candles, not only at their close.
foreach (var field in new[] { Level1Fields.BestBidPrice, Level1Fields.BestAskPrice })
{
var quotes = new Subscription(DataType.Level1, Security);
quotes.MarketData.BuildField = field;
SubscribeLevel1(quotes).Bind(ObserveProtectionQuote).Start();
}
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawOwnTrades(area);
var oscillators = CreateChartArea();
if (oscillators != null)
{
DrawIndicator(oscillators, williams);
}
}
}
private void ObserveProtectionQuote(Level1ChangeMessage quote)
{
// The high-level handler activates native protection before this callback, also between signal bars.
}
private void ProcessCandle(ICandleMessage candle, IIndicatorValue williamsValue)
{
if (candle.State != CandleStates.Finished)
return;
if (!williamsValue.IsFormed)
return;
var value = williamsValue.GetValue<decimal>();
_values.Enqueue(value);
if (_values.Count > AveragePeriod)
_values.Dequeue();
if (_values.Count < AveragePeriod)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
var mean = _values.Average();
var deviation = (decimal)Math.Sqrt((double)_values.Average(v => (v - mean) * (v - mean)));
var upper = mean + DeviationMultiplier * deviation;
var lower = mean - DeviationMultiplier * deviation;
if (value < lower && Position <= 0)
BuyMarket(Volume + Math.Abs(Position));
else if (value > upper && Position >= 0)
SellMarket(Volume + Math.Abs(Position));
else if (Position > 0 && value > mean)
SellMarket(Position);
else if (Position < 0 && value < mean)
BuyMarket(-Position);
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
clr.AddReference("StockSharp.BusinessEntities")
from System import TimeSpan, Decimal, Math
from StockSharp.Messages import DataType, CandleStates, Unit, UnitTypes, Level1Fields
from StockSharp.BusinessEntities import Subscription
from StockSharp.Algo.Indicators import WilliamsR
from StockSharp.Algo.Strategies import Strategy
class williams_r_mean_reversion_strategy(Strategy):
"""
Williams R Mean Reversion strategy.
The bands lie DeviationMultiplier standard deviations around the average of the last AveragePeriod %R values, the current one included.
%R below the lower band goes long and %R above the upper band goes short,
reversing an opposite position. A long closes once %R is back above its average and a short once it is back below it, and a percent stop limits the loss.
"""
def __init__(self):
super(williams_r_mean_reversion_strategy, self).__init__()
self._williams_r_period = self.Param("WilliamsRPeriod", 14).SetGreaterThanZero().SetDisplay("Williams %R Period", "Period of Williams %R", "Indicators")
self._average_period = self.Param("AveragePeriod", 20).SetGreaterThanZero().SetDisplay("Average Period", "Values of %R the average and the standard deviation span", "Indicators")
self._deviation_multiplier = self.Param("DeviationMultiplier", 2.0).SetGreaterThanZero().SetDisplay("Multiplier", "Standard deviations between the average and a band", "Indicators")
self._stop_loss_percent = self.Param("StopLossPercent", 2.0).SetNotNegative().SetDisplay("Stop Loss %", "Stop loss percentage from entry price", "Risk")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))).SetDisplay("Candle Type", "Type of candles to use", "General")
self._reset_state()
@property
def candle_type(self):
return self._candle_type.Value
def _reset_state(self):
self._values = []
def OnReseted(self):
super(williams_r_mean_reversion_strategy, self).OnReseted()
self._reset_state()
def OnStarted2(self, time):
super(williams_r_mean_reversion_strategy, self).OnStarted2(time)
self._reset_state()
williams = WilliamsR()
williams.Length = self._williams_r_period.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.BindEx(williams, self._process_candle).Start()
self.StartProtection(Unit(), Unit(Decimal(self._stop_loss_percent.Value), UnitTypes.Percent), useMarketOrders=True, isLocalStop=True)
# The stop has to see prices between candles, not only at their close.
for field in (Level1Fields.BestBidPrice, Level1Fields.BestAskPrice):
quotes = Subscription(DataType.Level1, self.Security)
quotes.MarketData.BuildField = field
self.SubscribeLevel1(quotes).Bind(self._observe_protection_quote).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawOwnTrades(area)
oscillators = self.CreateChartArea()
if oscillators is not None:
self.DrawIndicator(oscillators, williams)
def _observe_protection_quote(self, quote):
# The high-level handler activates native protection before the callback, including between bars.
pass
def _process_candle(self, candle, williams_value):
if candle.State != CandleStates.Finished:
return
if not williams_value.IsFormed:
return
value = williams_value.GetValue[Decimal](None)
period = self._average_period.Value
self._values.append(value)
if len(self._values) > period:
self._values.pop(0)
if len(self._values) < period:
return
if not self.IsFormedAndOnlineAndAllowTrading():
return
total = Decimal(0)
for item in self._values:
total += item
mean = total / Decimal(period)
squares = Decimal(0)
for item in self._values:
squares += (item - mean) * (item - mean)
deviation = Decimal(Math.Sqrt(Decimal.ToDouble(squares / Decimal(period))))
multiplier = Decimal(self._deviation_multiplier.Value)
upper = mean + multiplier * deviation
lower = mean - multiplier * deviation
if value < lower and self.Position <= 0:
self.BuyMarket(self.Volume + abs(self.Position))
elif value > upper and self.Position >= 0:
self.SellMarket(self.Volume + abs(self.Position))
elif self.Position > 0 and value > mean:
self.SellMarket(self.Position)
elif self.Position < 0 and value < mean:
self.BuyMarket(-self.Position)
def CreateClone(self):
return williams_r_mean_reversion_strategy()