GitHub で見る
AH HM MFI 戦略
概要
AH HM MFI 戦略は、マネー フロー インデックス (MFI) によって確認されるハンマーとハンギングマンのローソク足パターンを取引します。短期的な下降トレンドに強気のハンマーが現れ、MFI が売られすぎのしきい値を下回っている場合、この戦略はロングポジションをオープンします。 MFIが買われ過ぎの閾値を上回っている間に弱気のハンギングマンが上昇トレンドを形成すると、ショートポジションがオープンします。保護的出口は、MFI が事前に定義された上限または下限の境界を超えるとトリガーされます。
中核ロジック
- 構成された時間枠のローソク足をサブスクライブし、2 つのインジケーターを計算します。
- マネー フロー インデックス (設定可能な期間) (デフォルト: 47)。
- 元の MQL 戦略からのトレンド フィルターを近似する終値の 単純移動平均 (デフォルトの長さ: 5)。
- ハンマー と 吊り下げられた男 パターンを検出します。
- キャンドル本体は範囲の上部 3 分の 1 に位置します。
- 実体に対して長い下の影。
- 前のローソク足と比較したトレンドの方向のギャップ。
- 前のローソク足と移動平均の中点を使用してトレンドを確認します。
- MFI しきい値を使用してエントリを確認します。
- ハンマーが検出され、MFI が設定された売られ過ぎレベル (デフォルト: 40) 以下の場合は、ロングを入力します。
- ぶら下がっている男性が検出され、MFI が設定された買われすぎレベル (デフォルト: 60) 以上である場合は、ショートを入力します。
- MFI 交差点を使用して出口を管理します。
- MFI が下限または上限の出口レベル (デフォルト: 30 および 70) を超えて上向きにクロスしたときに、ショート ポジションを閉じます。
- MFIが上方出口レベルを上方に通過するか、下方出口レベルを下方に下方に通過すると、ロングポジションを閉じます。
- 内蔵のリスク保護モジュールを起動して緊急停止を処理します。
パラメーター
| 名前 |
説明 |
デフォルト |
CandleType |
パターン検出に使用されるローソク足のデータ型とタイムフレーム。 |
30分の時間枠 |
MfiPeriod |
MFI 計算のルックバック期間。 |
47 |
MaPeriod |
トレンド確認のために終値に適用される SMA の長さ。 |
5 |
HammerEntryThreshold |
ハンマー信号を入力する前に許可される最大 MFI 値。 |
40 |
HangingEntryThreshold |
ぶら下がりマン信号に入る前に必要な最小 MFI 値。 |
60 |
MfiUpperExitLevel |
MFI の上限境界。それを超えるとオープンポジションがクローズされます。 |
70 |
MfiLowerExitLevel |
MFI 境界の下限。それを下回るとロングポジションがクローズされ、上をクロスするとショートポジションがクローズされます。 |
30 |
注意事項
- この戦略は、不完全な情報に基づいて行動することを避けるために、完成したキャンドルのみを評価します。
- ハンマーと吊るされた男の検出は保守的です。長い下影とろうそくの高値付近にある本体の両方が必要です。
- 移動平均は、元のエキスパートアドバイザーの MetaTrader 5
CloseAvg フィルターを置き換え、エントリがより広範な傾向に一致することを保証します。
namespace StockSharp.Samples.Strategies;
using System;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.Messages;
/// <summary>
/// Hammer/Hanging Man + MFI strategy.
/// Buys on hammer with low MFI (oversold), sells on hanging man with high MFI (overbought).
/// </summary>
public class AhHmMfiStrategy : Strategy
{
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _mfiPeriod;
private readonly StrategyParam<decimal> _mfiLow;
private readonly StrategyParam<decimal> _mfiHigh;
private readonly StrategyParam<int> _signalCooldownCandles;
private int _candlesSinceTrade;
public DataType CandleType { get => _candleType.Value; set => _candleType.Value = value; }
public int MfiPeriod { get => _mfiPeriod.Value; set => _mfiPeriod.Value = value; }
public decimal MfiLow { get => _mfiLow.Value; set => _mfiLow.Value = value; }
public decimal MfiHigh { get => _mfiHigh.Value; set => _mfiHigh.Value = value; }
public int SignalCooldownCandles { get => _signalCooldownCandles.Value; set => _signalCooldownCandles.Value = value; }
public AhHmMfiStrategy()
{
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(60).TimeFrame())
.SetDisplay("Candle Type", "Candle timeframe", "General");
_mfiPeriod = Param(nameof(MfiPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("MFI Period", "MFI period", "Indicators");
_mfiLow = Param(nameof(MfiLow), 35m)
.SetDisplay("MFI Low", "MFI oversold threshold for buy", "Signals");
_mfiHigh = Param(nameof(MfiHigh), 65m)
.SetDisplay("MFI High", "MFI overbought threshold for sell", "Signals");
_signalCooldownCandles = Param(nameof(SignalCooldownCandles), 8)
.SetGreaterThanZero()
.SetDisplay("Signal Cooldown", "Bars to wait between trades", "Trading");
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_candlesSinceTrade = SignalCooldownCandles;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_candlesSinceTrade = SignalCooldownCandles;
var rsi = new RelativeStrengthIndex { Length = MfiPeriod };
var subscription = SubscribeCandles(CandleType);
subscription.Bind(rsi, ProcessCandle).Start();
}
private void ProcessCandle(ICandleMessage candle, decimal mfiValue)
{
if (candle.State != CandleStates.Finished) return;
if (_candlesSinceTrade < SignalCooldownCandles)
_candlesSinceTrade++;
var body = Math.Abs(candle.ClosePrice - candle.OpenPrice);
var range = candle.HighPrice - candle.LowPrice;
if (range <= 0 || body <= 0) return;
var upperShadow = candle.HighPrice - Math.Max(candle.OpenPrice, candle.ClosePrice);
var lowerShadow = Math.Min(candle.OpenPrice, candle.ClosePrice) - candle.LowPrice;
var isHammer = lowerShadow > body * 2.5m && upperShadow < body * 0.5m;
var isHangingMan = upperShadow > body * 2.5m && lowerShadow < body * 0.5m;
if (isHammer && mfiValue < MfiLow && Position <= 0 && _candlesSinceTrade >= SignalCooldownCandles)
{
BuyMarket();
_candlesSinceTrade = 0;
}
else if (isHangingMan && mfiValue > MfiHigh && Position >= 0 && _candlesSinceTrade >= SignalCooldownCandles)
{
SellMarket();
_candlesSinceTrade = 0;
}
}
}
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 RelativeStrengthIndex
from StockSharp.Algo.Strategies import Strategy
class ah_hm_mfi_strategy(Strategy):
def __init__(self):
super(ah_hm_mfi_strategy, self).__init__()
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(60)))
self._mfi_period = self.Param("MfiPeriod", 14)
self._mfi_low = self.Param("MfiLow", 35.0)
self._mfi_high = self.Param("MfiHigh", 65.0)
self._signal_cooldown_candles = self.Param("SignalCooldownCandles", 8)
self._candles_since_trade = 8
@property
def CandleType(self):
return self._candle_type.Value
@CandleType.setter
def CandleType(self, value):
self._candle_type.Value = value
@property
def MfiPeriod(self):
return self._mfi_period.Value
@MfiPeriod.setter
def MfiPeriod(self, value):
self._mfi_period.Value = value
@property
def MfiLow(self):
return self._mfi_low.Value
@MfiLow.setter
def MfiLow(self, value):
self._mfi_low.Value = value
@property
def MfiHigh(self):
return self._mfi_high.Value
@MfiHigh.setter
def MfiHigh(self, value):
self._mfi_high.Value = value
@property
def SignalCooldownCandles(self):
return self._signal_cooldown_candles.Value
@SignalCooldownCandles.setter
def SignalCooldownCandles(self, value):
self._signal_cooldown_candles.Value = value
def OnReseted(self):
super(ah_hm_mfi_strategy, self).OnReseted()
self._candles_since_trade = self.SignalCooldownCandles
def OnStarted2(self, time):
super(ah_hm_mfi_strategy, self).OnStarted2(time)
self._candles_since_trade = self.SignalCooldownCandles
rsi = RelativeStrengthIndex()
rsi.Length = self.MfiPeriod
subscription = self.SubscribeCandles(self.CandleType)
subscription.Bind(rsi, self._process_candle).Start()
def _process_candle(self, candle, mfi_value):
if candle.State != CandleStates.Finished:
return
if self._candles_since_trade < self.SignalCooldownCandles:
self._candles_since_trade += 1
mfi_val = float(mfi_value)
body = abs(float(candle.ClosePrice) - float(candle.OpenPrice))
rng = float(candle.HighPrice) - float(candle.LowPrice)
if rng <= 0 or body <= 0:
return
upper_shadow = float(candle.HighPrice) - max(float(candle.OpenPrice), float(candle.ClosePrice))
lower_shadow = min(float(candle.OpenPrice), float(candle.ClosePrice)) - float(candle.LowPrice)
is_hammer = lower_shadow > body * 2.5 and upper_shadow < body * 0.5
is_hanging_man = upper_shadow > body * 2.5 and lower_shadow < body * 0.5
if is_hammer and mfi_val < self.MfiLow and self.Position <= 0 and self._candles_since_trade >= self.SignalCooldownCandles:
self.BuyMarket()
self._candles_since_trade = 0
elif is_hanging_man and mfi_val > self.MfiHigh and self.Position >= 0 and self._candles_since_trade >= self.SignalCooldownCandles:
self.SellMarket()
self._candles_since_trade = 0
def CreateClone(self):
return ah_hm_mfi_strategy()