戦略 Risk Monitor Strategy
概要
リスク モニター戦略は、MetaTrader 4 エキスパート アドバイザー risk.mq4 の移植版です。 The original script never opened trades; instead it
口座残高とユーザー定義のリスク割合に基づいて、トレーダーが安全に展開できるロットの数を決定します。これ
StockSharp バージョンも同じ精神を維持しています。継続的な口座診断の実行、推奨される取引サイズの計算、監視を行います。
変動利益と実現利益を計算し、その結果を戦略コメントに直接公開して迅速な意思決定を実現します。
従来の戦略とは異なり、リスクモニター戦略は自動的に注文を送信しません。 Its role is supervisory: it gives the
トレーダーは、現在のエクスポージャのスナップショット、選択したリスクバジェットに応じた利用可能なキャパシティ、クローズドの収益性を確認できます。
positions.コメント行はポジション、損益、取引が変更されるたびに更新されるため、常に最新の情報が反映されます。
portfolio state.
Calculations
この戦略では、コメントに表示される数値を 3 つのデータ グループから導き出します。
- 基本ロットサイズ –
AccountBalance / 1000 として計算され、セキュリティボリュームステップに合わせられます。 This mirrors the original
残高 1000 単位ごとに 1 つの標準ロットに対応する MT4 ロジック。
- リスク ロット サイズ – 基本ロットに
Risk % / 100 を乗算し、結果をボリューム ステップに合わせて、その数を表します
設定されたリスクバジェットを尊重しながらロットを開くことができます。
- オープンロットと差 – 絶対ネットポジションとリスクロットサイズを比較します。 If the trader is below the threshold,
違いは、制限に達するまでに利用可能なロットがどれだけ残っているかを示します。 A tiny negative difference that is smaller than
混乱を招くノイズを避けるために、音量ステップはゼロに丸められます。
利益を得るために、戦略は変動価値と実現価値を区別します。
- 変動損益 – 戦略
PnL プロパティから読み取り、価格単位と現在のパーセンテージの両方で表されます
portfolio value.
- 実現利益 – 自身の取引から蓄積されたもの。このコンポーネントは、すべてのクロージングフィルをポジティブ部分とネガティブ部分に分割します。
報告されたコミッションを適用し、現在までの合計を保持します。最終的な数値は、資本に対する割合にも変換されます。
match the MT4 readout.
パラメーター
- リスク % – 新しいポジションにコミットできる口座残高の部分。 Default:
10. The parameter is exposed for
最適化により、さまざまなリスク バジェットを迅速にバックテストできます。
この戦略は、次の 3 行でコメントを更新します。
Base lots、Risk lots、Open lots、Lots to adjust – ポジションサイジング指標のクイックビュー。
Risk、Floating PnL – リスク設定、通貨単位の変動利益、残高のパーセントでの変動利益。
Realized profit – 累計成約利益とその割合。
すべての値は MT4 スクリプトと同様に四捨五入され、証券ロットステップを尊重し、金額には小数点以下 2 桁が使用されます。
数字。出力はコメント内にあるため、開かなくてもチャートまたは戦略グリッドにすぐに表示されます。
additional panels.
使用上の注意
- バランスとポジションを監視したい商品にストラテジーをアタッチします。 It works with net positions (no MT4-style
hedging) just like StockSharp itself.
- この戦略は手動取引を許容します。統計の同期を保つためにあらゆる取引確認に反応します。
- コメントは戦略が停止またはリセットされると自動的にクリアされ、古い値がセッション間で持続するのを防ぎます。
- No Python implementation is provided; API パッケージには C# バージョンのみが含まれています。
using System;
using System.Linq;
using System.Collections.Generic;
using Ecng.Common;
using Ecng.Collections;
using Ecng.Serialization;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
/// <summary>
/// Risk-aware EMA crossover strategy inspired by the original MT4 Risk Monitor script.
/// Uses a risk percentage of account balance to size positions, combined with EMA crossover signals.
/// Tracks realized gains/losses and adjusts lot sizing accordingly.
/// </summary>
public class RiskMonitorStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<decimal> _riskPercent;
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<decimal> _takeProfitPoints;
private readonly StrategyParam<decimal> _stopLossPoints;
private ExponentialMovingAverage _fastEma;
private ExponentialMovingAverage _slowEma;
private decimal? _prevFast;
private decimal? _prevSlow;
/// <summary>
/// Candle type used for signal detection.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Percentage of the account balance allocated to new positions.
/// </summary>
public decimal RiskPercent
{
get => _riskPercent.Value;
set => _riskPercent.Value = value;
}
/// <summary>
/// Fast EMA period.
/// </summary>
public int FastPeriod
{
get => _fastPeriod.Value;
set => _fastPeriod.Value = value;
}
/// <summary>
/// Slow EMA period.
/// </summary>
public int SlowPeriod
{
get => _slowPeriod.Value;
set => _slowPeriod.Value = value;
}
/// <summary>
/// Take profit distance in absolute points.
/// </summary>
public decimal TakeProfitPoints
{
get => _takeProfitPoints.Value;
set => _takeProfitPoints.Value = value;
}
/// <summary>
/// Stop loss distance in absolute points.
/// </summary>
public decimal StopLossPoints
{
get => _stopLossPoints.Value;
set => _stopLossPoints.Value = value;
}
/// <summary>
/// Initializes a new instance of <see cref="RiskMonitorStrategy"/>.
/// </summary>
public RiskMonitorStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Candle series used for calculations", "General");
_riskPercent = Param(nameof(RiskPercent), 10m)
.SetGreaterThanZero()
.SetDisplay("Risk %", "Portion of balance used to size positions", "Risk Management")
.SetOptimize(5m, 30m, 5m);
_fastPeriod = Param(nameof(FastPeriod), 10)
.SetGreaterThanZero()
.SetDisplay("Fast EMA", "Fast EMA period", "Indicators")
.SetOptimize(5, 30, 5);
_slowPeriod = Param(nameof(SlowPeriod), 30)
.SetGreaterThanZero()
.SetDisplay("Slow EMA", "Slow EMA period", "Indicators")
.SetOptimize(20, 80, 10);
_takeProfitPoints = Param(nameof(TakeProfitPoints), 500m)
.SetNotNegative()
.SetDisplay("Take Profit", "Absolute take profit distance", "Risk");
_stopLossPoints = Param(nameof(StopLossPoints), 500m)
.SetNotNegative()
.SetDisplay("Stop Loss", "Absolute stop loss distance", "Risk");
Volume = 1;
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_fastEma = null;
_slowEma = null;
_prevFast = null;
_prevSlow = null;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
_fastEma = new ExponentialMovingAverage { Length = FastPeriod };
_slowEma = new ExponentialMovingAverage { Length = SlowPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(_fastEma, _slowEma, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, _fastEma);
DrawIndicator(area, _slowEma);
DrawOwnTrades(area);
}
if (TakeProfitPoints > 0 || StopLossPoints > 0)
{
var tp = TakeProfitPoints > 0 ? new Unit(TakeProfitPoints, UnitTypes.Absolute) : null;
var sl = StopLossPoints > 0 ? new Unit(StopLossPoints, UnitTypes.Absolute) : null;
StartProtection(tp, sl);
}
base.OnStarted2(time);
}
private void ProcessCandle(ICandleMessage candle, decimal fastValue, decimal slowValue)
{
if (candle.State != CandleStates.Finished)
return;
var pf = _prevFast;
var ps = _prevSlow;
_prevFast = fastValue;
_prevSlow = slowValue;
if (pf == null || ps == null)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
// Detect crossover
var prevDiff = pf.Value - ps.Value;
var currDiff = fastValue - slowValue;
if (prevDiff <= 0 && currDiff > 0)
{
// Bullish crossover
if (Position < 0)
BuyMarket(Math.Abs(Position));
if (Position == 0)
BuyMarket(Volume);
}
else if (prevDiff >= 0 && currDiff < 0)
{
// Bearish crossover
if (Position > 0)
SellMarket(Position);
if (Position == 0)
SellMarket(Volume);
}
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
from System import TimeSpan, Math
from StockSharp.Messages import DataType, CandleStates, UnitTypes, Unit
from StockSharp.Algo.Indicators import ExponentialMovingAverage
from StockSharp.Algo.Strategies import Strategy
class risk_monitor_strategy(Strategy):
def __init__(self):
super(risk_monitor_strategy, self).__init__()
self._fast_period = self.Param("FastPeriod", 10).SetGreaterThanZero().SetDisplay("Fast EMA", "Fast EMA period", "Indicators")
self._slow_period = self.Param("SlowPeriod", 30).SetGreaterThanZero().SetDisplay("Slow EMA", "Slow EMA period", "Indicators")
self._tp_points = self.Param("TakeProfitPoints", 500.0).SetNotNegative().SetDisplay("Take Profit", "TP distance", "Risk")
self._sl_points = self.Param("StopLossPoints", 500.0).SetNotNegative().SetDisplay("Stop Loss", "SL distance", "Risk")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))).SetDisplay("Candle Type", "Candle timeframe", "General")
@property
def CandleType(self): return self._candle_type.Value
@CandleType.setter
def CandleType(self, value): self._candle_type.Value = value
def OnReseted(self):
super(risk_monitor_strategy, self).OnReseted()
self._prev_fast = None
self._prev_slow = None
self._entry_price = 0
def OnStarted2(self, time):
super(risk_monitor_strategy, self).OnStarted2(time)
self._prev_fast = None
self._prev_slow = None
self._entry_price = 0
fast_ema = ExponentialMovingAverage()
fast_ema.Length = self._fast_period.Value
slow_ema = ExponentialMovingAverage()
slow_ema.Length = self._slow_period.Value
sub = self.SubscribeCandles(self.CandleType)
sub.Bind(fast_ema, slow_ema, self.OnProcess).Start()
tp_val = float(self._tp_points.Value)
sl_val = float(self._sl_points.Value)
tp = Unit(tp_val, UnitTypes.Absolute) if tp_val > 0 else None
sl = Unit(sl_val, UnitTypes.Absolute) if sl_val > 0 else None
self.StartProtection(tp, sl)
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, sub)
self.DrawIndicator(area, fast_ema)
self.DrawIndicator(area, slow_ema)
self.DrawOwnTrades(area)
def OnProcess(self, candle, fast_val, slow_val):
if candle.State != CandleStates.Finished:
return
pf = self._prev_fast
ps = self._prev_slow
self._prev_fast = fast_val
self._prev_slow = slow_val
if pf is None or ps is None:
return
if not self.IsFormedAndOnlineAndAllowTrading():
return
prev_diff = pf - ps
curr_diff = fast_val - slow_val
if prev_diff <= 0 and curr_diff > 0:
if self.Position < 0:
self.BuyMarket(abs(self.Position))
if self.Position == 0:
self.BuyMarket(self.Volume)
elif prev_diff >= 0 and curr_diff < 0:
if self.Position > 0:
self.SellMarket(self.Position)
if self.Position == 0:
self.SellMarket(self.Volume)
def CreateClone(self):
return risk_monitor_strategy()