GitHub で見る
経済カレンダー戦略のサンプル検出
概要
サンプル検出経済カレンダー戦略は、元の MetaTrader エキスパート アドバイザー SampleDetectEconomicCalendar.mq5 の動作を再現します。この戦略は、手動で提供された経済カレンダー イベントのリストを監視し、設定された通貨に大きな影響を与えるイベントが近づいている場合に、現在の買値/売値を中心に対称的な逆指値ペアを配置します。プロテクティブストップ、オプションのテイクプロフィットレベル、トレーリングエグジットは、ソースコードの資金管理ロジックを複製します。
MQL バージョンとは異なり、StockSharp ポートは MetaTrader カレンダー サービスにアクセスできません。代わりに、イベントはユーザーによって CalendarDefinition パラメータを通じて提供されます。
仕組み
- この戦略はレベル 1 データをサブスクライブして買値/売値を追跡します。
CalendarDefinition で定義されたカレンダー行は起動時に解析されます。
BaseCurrency に一致する重要度の高いイベントごとに、戦略は次のようになります。
- リリース前に
LeadMinutes まで待機します。
- 注文量 (固定またはリスクベース) を計算します。
- 現在の価格から
BuyDistancePoints と SellDistancePoints で買い/売りのストップ注文を出します。
- リリース後、保留中の注文は、
PostMinutes が経過するか、合計タイムアウトが ExpiryMinutes に達するとキャンセルされます。
- 一方がトリガーされると、反対側の注文はキャンセルされます。オープンポジションは、ストップロス、オプションのテイクプロフィット、およびポイントで表されるトレーリングストップ距離で管理されます。
パラメーター
| パラメータ |
説明 |
TradeNews |
スケジュールされたニュースイベントの前後に未決注文を発注できるようにします。 |
OrderVolume |
資金管理が無効な場合に使用される固定注文量。 |
StopLossPoints |
計器ポイントでのストップロス距離。無効にするには 0 に設定します。 |
TakeProfitPoints |
テイクプロフィット距離(ポイント単位)。無効にするには 0 に設定します。 |
TrailingStopPoints |
トレーリングストップの距離 (ポイント単位)。末尾を無効にするには 0 に設定します。 |
ExpiryMinutes |
リリース後の未決注文の最大存続期間。 |
UseMoneyManagement |
有効にすると、残高リスクからボリュームが計算されます。 |
RiskPercent |
取引ごとにリスクがかかるポートフォリオ資本の割合(資金管理がアクティブな場合にのみ使用されます)。 |
BuyDistancePoints |
買いストップエントリーのアスクの上のオフセット。 |
SellDistancePoints |
売りストップエントリーの入札値を下回るオフセット。 |
LeadMinutes |
未決注文が送信されるリリースの数分前。 |
PostMinutes |
リリース後、無人注文がキャンセルされるまでの数分。 |
BaseCurrency |
カレンダーエントリに表示する必要がある通貨コード (デフォルトは USD)。 |
CalendarDefinition |
カレンダーイベントを含む複数行の文字列。 |
カレンダー定義形式
次の形式で 1 行に 1 つのイベントを入力します。
「」
yyyy-MM-dd HH:mm;CUR;高;イベントのタイトル
「」
yyyy-MM-dd HH:mm — UTC のタイムスタンプ。秒数はオプションです。複数の日付形式 (yyyy/MM/dd、dd.MM.yyyy) もサポートされています。
CUR — 通貨コード (例: USD)。 BaseCurrency に一致するイベントのみが取引されます。
High - 重要キーワード (High、Medium、Low、または Nfp)。 High のみが取引をトリガーします。
Event title — ログ用の自由テキスト。
例:
「」
2024-06-12 18:00;USD;高値;FOMC声明
2024-07-05 12:30;USD;Nfp;非農業部門雇用者数
「」
リスク管理
UseMoneyManagement が オフの場合、注文は OrderVolume パラメータを使用して行われます。
UseMoneyManagement が オン の場合、戦略は構成された StopLossPoints を使用してポートフォリオ値の RiskPercent をリスクにさらします。 Exchange のボリューム制限 (最小/最大ステップ) が尊重されます。
- トレーリング ロジックはオリジナルの EA を反映しています。ストップロスとテイクプロフィットのエグジットが強制され、価格が
TrailingStopPoints までに有利に推移すると、トレーリング ストップが取引を保護します。
MQL エキスパートアドバイザーとの違い
- 経済カレンダー イベントは、
CalendarDefinition で手動で指定する必要があります。
- 戦略インスタンスごとに 1 つの金融商品/通貨ペアのみが処理されます。
- StockSharp のストップ注文は MetaTrader スタイルの
ORDER_TIME_SPECIFIED フラグを公開しないため、未決注文の有効期限は PostMinutes/ExpiryMinutes タイマーで内部的に処理されます。
使用上の注意
- 戦略を開始する前に、
CalendarDefinition 行を構成します。
TradeNews を有効にし、必要なリスク パラメータを設定します。
- ニュースウィンドウの前に買値/売値の更新が届くように、レベル 1 データが利用可能であることを確認します。
- ログを確認して、各イベントの前後で予想どおりに注文とキャンセルが行われていることを確認します。
namespace StockSharp.Samples.Strategies;
using System;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
/// <summary>
/// Sample Detect Economic Calendar strategy: Parabolic SAR trend with EMA filter.
/// Buys when close above both SAR and EMA, sells when close below both.
/// </summary>
public class SampleDetectEconomicCalendarStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _emaPeriod;
private decimal _prevClose;
private decimal _prevSar;
private decimal _prevEma;
private bool _hasPrev;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int EmaPeriod { get => _emaPeriod.Value; set => _emaPeriod.Value = value; }
public SampleDetectEconomicCalendarStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(60).TimeFrame())
.SetDisplay("Candle Type", "Candle timeframe", "General");
_emaPeriod = Param(nameof(EmaPeriod), 50)
.SetGreaterThanZero()
.SetDisplay("EMA Period", "EMA filter period", "Indicators");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_prevClose = 0;
_prevSar = 0;
_prevEma = 0;
_hasPrev = false;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_prevClose = 0;
_prevSar = 0;
_prevEma = 0;
_hasPrev = false;
var sar = new ParabolicSar { Acceleration = 0.01m, AccelerationMax = 0.1m };
var ema = new ExponentialMovingAverage { Length = EmaPeriod };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(sar, ema, ProcessCandle).Start();
}
private void ProcessCandle(ICandleMessage candle, decimal sarValue, decimal emaValue)
{
if (candle.State != CandleStates.Finished) return;
if (_hasPrev)
{
var aboveSar = candle.ClosePrice > sarValue;
var belowSar = candle.ClosePrice < sarValue;
var aboveEma = candle.ClosePrice > emaValue;
var belowEma = candle.ClosePrice < emaValue;
if (aboveSar && aboveEma && !(_prevClose > _prevSar && _prevClose > _prevEma) && Position <= 0)
BuyMarket();
else if (belowSar && belowEma && !(_prevClose < _prevSar && _prevClose < _prevEma) && Position >= 0)
SellMarket();
}
_prevClose = candle.ClosePrice;
_prevSar = sarValue;
_prevEma = emaValue;
_hasPrev = true;
}
}
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 ParabolicSar, ExponentialMovingAverage
from StockSharp.Algo.Strategies import Strategy
class sample_detect_economic_calendar_strategy(Strategy):
def __init__(self):
super(sample_detect_economic_calendar_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(60)))
self._ema_period = self.Param("EmaPeriod", 50)
self._prev_close = 0.0
self._prev_sar = 0.0
self._prev_ema = 0.0
self._has_prev = False
@property
def CandleType(self):
return self._candle_type.Value
@CandleType.setter
def CandleType(self, value):
self._candle_type.Value = value
@property
def EmaPeriod(self):
return self._ema_period.Value
@EmaPeriod.setter
def EmaPeriod(self, value):
self._ema_period.Value = value
def OnReseted(self):
super(sample_detect_economic_calendar_strategy, self).OnReseted()
self._prev_close = 0.0
self._prev_sar = 0.0
self._prev_ema = 0.0
self._has_prev = False
def OnStarted2(self, time):
super(sample_detect_economic_calendar_strategy, self).OnStarted2(time)
self._prev_close = 0.0
self._prev_sar = 0.0
self._prev_ema = 0.0
self._has_prev = False
sar = ParabolicSar()
sar.Acceleration = 0.01
sar.AccelerationMax = 0.1
ema = ExponentialMovingAverage()
ema.Length = self.EmaPeriod
subscription = self.SubscribeCandles(self.CandleType)
subscription.Bind(sar, ema, self._process_candle).Start()
def _process_candle(self, candle, sar_value, ema_value):
if candle.State != CandleStates.Finished:
return
close = float(candle.ClosePrice)
sar_val = float(sar_value)
ema_val = float(ema_value)
if self._has_prev:
above_sar = close > sar_val
below_sar = close < sar_val
above_ema = close > ema_val
below_ema = close < ema_val
was_above_both = self._prev_close > self._prev_sar and self._prev_close > self._prev_ema
was_below_both = self._prev_close < self._prev_sar and self._prev_close < self._prev_ema
if above_sar and above_ema and not was_above_both and self.Position <= 0:
self.BuyMarket()
elif below_sar and below_ema and not was_below_both and self.Position >= 0:
self.SellMarket()
self._prev_close = close
self._prev_sar = sar_val
self._prev_ema = ema_val
self._has_prev = True
def CreateClone(self):
return sample_detect_economic_calendar_strategy()