GitHub で見る
急速童子戦略
概要
Rapid Doji 戦略は、元の「Rapid Doji EA」エキスパート アドバイザーのロジックを複製します。設定可能な時間枠 (デフォルトでは毎日) の完了したローソク足をスキャンし、すべての doji ローソク足の上下にストップ エントリー注文を配置します。プロテクティブ ストップは平均トゥルー レンジ (ATR) 乗数を使用して配置されますが、補助トレーリング ストップは、ポジションが利益を生んだ後、リスク ディスタンスを生のポイントで固定します。
取引ロジック
- データ サブスクリプション – この戦略は、選択した時間枠の終了したローソク足をリッスンし、構成可能な期間で ATR インジケーターを維持します。
- Doji 検出 – ローソクは、本体の絶対サイズがローソクの全範囲の最大 3% である場合に Doji として扱われます。完成したキャンドルのみが評価されます。
- 注文の発注 – 有効な童子が見つかった場合:
- 買いストップ注文は同地高値で出されます。
- 売りストップ注文は同地安値で出されます。
- 各エントリは、反対極値のマイナス/プラス ATR × 乗数に等しい保護ストップ価格を記憶します。
- リスク管理 – ポジションがオープンされると、残りの未決注文がキャンセルされ、記憶されたストップが保護ストップとして登録され、トレーリングロジックが制御を引き継ぎます。
- トレーリングストップ – 新しいキャンドルごとに、ポジションがすでに利益を上げている場合に限り、最新の終値から一定の距離(商品価格ステップを通じて換算されたポイント)を維持するようにストップレベルが移動します。
この戦略では利益確定ターゲットは決して使用されません。終了は保護停止または手動介入によって行われます。
パラメーター
| パラメータ |
説明 |
CandleType |
パターン検出に使用されるローソク足のデータ型 (デフォルトでは毎日の時間枠)。 |
AtrPeriod |
ATR インジケーターのルックバックの長さ。 |
AtrMultiplier |
ストップロス計算のために ATR 値に適用される乗数。 |
TrailingDistancePoints |
ストップを追跡するときに使用される生のポイントでの固定距離。 |
すべてのパラメータは、StockSharp 環境内の最適化をサポートします。
実装メモ
- このコードは、手動による履歴処理を回避するために、高レベルのローソク足サブスクリプション API (
SubscribeCandles) とインジケーター バインディング (Bind) を組み合わせたものに依存しています。
- 注文は、為替ティック サイズを考慮して
Security.ShrinkPrice を通じて正規化されます。
- 保護停止は、元の MetaTrader エキスパート アドバイザーの動作を模倣するために明示的に管理されます。
- プロジェクトでは、タスク要件に従って Python 実装を意図的に省略しています。
namespace StockSharp.Samples.Strategies;
using System;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
/// <summary>
/// Rapid Doji strategy: detects doji candles and trades the breakout direction.
/// Buys on next candle if it closes above doji high, sells if below doji low.
/// Uses ATR for volatility confirmation.
/// </summary>
public class RapidDojiStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _atrPeriod;
private readonly StrategyParam<decimal> _dojiThreshold;
private readonly StrategyParam<int> _signalCooldownCandles;
private decimal _prevHigh;
private decimal _prevLow;
private bool _prevWasDoji;
private int _candlesSinceTrade;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int AtrPeriod { get => _atrPeriod.Value; set => _atrPeriod.Value = value; }
public decimal DojiThreshold { get => _dojiThreshold.Value; set => _dojiThreshold.Value = value; }
public int SignalCooldownCandles { get => _signalCooldownCandles.Value; set => _signalCooldownCandles.Value = value; }
public RapidDojiStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(15).TimeFrame())
.SetDisplay("Candle Type", "Candle timeframe", "General");
_atrPeriod = Param(nameof(AtrPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("ATR Period", "ATR period for volatility filter", "Indicators");
_dojiThreshold = Param(nameof(DojiThreshold), 0.15m)
.SetDisplay("Doji Threshold", "Max body/range ratio for doji detection", "Pattern");
_signalCooldownCandles = Param(nameof(SignalCooldownCandles), 6)
.SetGreaterThanZero()
.SetDisplay("Signal Cooldown", "Bars to wait between breakouts", "Trading");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevHigh = 0m;
_prevLow = 0m;
_prevWasDoji = false;
_candlesSinceTrade = SignalCooldownCandles;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_prevWasDoji = false;
_candlesSinceTrade = SignalCooldownCandles;
var atr = new AverageTrueRange { Length = AtrPeriod };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(atr, ProcessCandle).Start();
}
private void ProcessCandle(ICandleMessage candle, decimal atr)
{
if (candle.State != CandleStates.Finished) return;
if (_candlesSinceTrade < SignalCooldownCandles)
_candlesSinceTrade++;
if (_prevWasDoji && atr > 0 && _candlesSinceTrade >= SignalCooldownCandles)
{
var close = candle.ClosePrice;
if (close > _prevHigh + atr * 0.2m && Position <= 0)
{
BuyMarket();
_candlesSinceTrade = 0;
}
else if (close < _prevLow - atr * 0.2m && Position >= 0)
{
SellMarket();
_candlesSinceTrade = 0;
}
}
var range = candle.HighPrice - candle.LowPrice;
var body = Math.Abs(candle.ClosePrice - candle.OpenPrice);
_prevWasDoji = range > 0 && body <= DojiThreshold * range;
_prevHigh = candle.HighPrice;
_prevLow = candle.LowPrice;
}
}
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 AverageTrueRange
from StockSharp.Algo.Strategies import Strategy
class rapid_doji_strategy(Strategy):
def __init__(self):
super(rapid_doji_strategy, self).__init__()
self._atr_period = self.Param("AtrPeriod", 14) \
.SetDisplay("ATR Period", "ATR period for volatility filter", "Indicators")
self._doji_threshold = self.Param("DojiThreshold", 0.15) \
.SetDisplay("Doji Threshold", "Max body/range ratio for doji detection", "Pattern")
self._signal_cooldown = self.Param("SignalCooldownCandles", 6) \
.SetDisplay("Signal Cooldown", "Bars to wait between breakouts", "Trading")
self._atr = None
self._prev_high = 0.0
self._prev_low = 0.0
self._prev_was_doji = False
self._candles_since_trade = 0
@property
def atr_period(self):
return self._atr_period.Value
@property
def doji_threshold(self):
return self._doji_threshold.Value
@property
def signal_cooldown(self):
return self._signal_cooldown.Value
def OnReseted(self):
super(rapid_doji_strategy, self).OnReseted()
self._atr = None
self._prev_high = 0.0
self._prev_low = 0.0
self._prev_was_doji = False
self._candles_since_trade = self.signal_cooldown
def OnStarted2(self, time):
super(rapid_doji_strategy, self).OnStarted2(time)
self._atr = AverageTrueRange()
self._atr.Length = self.atr_period
self._prev_was_doji = False
self._candles_since_trade = self.signal_cooldown
subscription = self.SubscribeCandles(DataType.TimeFrame(TimeSpan.FromMinutes(15)))
subscription.Bind(self._atr, self._process_candle)
subscription.Start()
def _process_candle(self, candle, atr_value):
if candle.State != CandleStates.Finished:
return
if not self._atr.IsFormed:
return
atr_val = float(atr_value)
if self._candles_since_trade < self.signal_cooldown:
self._candles_since_trade += 1
if self._prev_was_doji and atr_val > 0 and self._candles_since_trade >= self.signal_cooldown:
close = float(candle.ClosePrice)
if close > self._prev_high + atr_val * 0.2 and self.Position <= 0:
self.BuyMarket()
self._candles_since_trade = 0
elif close < self._prev_low - atr_val * 0.2 and self.Position >= 0:
self.SellMarket()
self._candles_since_trade = 0
high = float(candle.HighPrice)
low = float(candle.LowPrice)
range_size = high - low
body = abs(float(candle.ClosePrice) - float(candle.OpenPrice))
self._prev_was_doji = range_size > 0 and body <= self.doji_threshold * range_size
self._prev_high = high
self._prev_low = low
def CreateClone(self):
return rapid_doji_strategy()