Главная
/
Примеры стратегий
Открыть на GitHub
Стратегия Price Action Fractal
Стратегия является портом экспертного советника MetaTrader "PRICE_ACTION" на платформу StockSharp. Она сочетает фракталы Вильямса, линейно-взвешенные скользящие средние, индикатор Momentum и MACD, чтобы торговать подтверждённые ценовым действием пробои на выбранном таймфрейме.
Идея
Анализируются только завершённые свечи – каждое решение принимается по цене закрытия выбранного периода.
В пятисвечном окне ищутся новые бычьи и медвежьи фракталы. Нижний фрактал показывает потенциальную поддержку, верхний – сопротивление.
Направление фильтруется двумя LWMA: для покупок быстрая средняя должна быть выше медленной, для продаж – ниже.
Проверяется сила импульса по абсолютному отклонению индикатора Momentum от базового уровня 100 на старшем периоде.
Дополнительный фильтр – MACD (по умолчанию 12/26/9). Для лонга основная линия должна быть выше сигнальной, для шорта – ниже.
Когда все фильтры совпадают, стратегия входит по направлению пробоя и сопровождает позицию фиксированным стопом, трейлинг-стопом и опциональным переносом в безубыток.
Правила входа
Покупка
На текущей свече сформирован новый нижний фрактал (паттерн из 5 свечей).
Быстрая LWMA > медленной LWMA.
abs(Momentum - 100) ≥ MomentumThreshold.
Линия MACD > сигнальной линии.
Объём рассчитывается из параметра Volume и ограничивается MaxPositionUnits.
Продажа
На текущей свече сформирован новый верхний фрактал.
Быстрая LWMA < медленной LWMA.
abs(Momentum - 100) ≥ MomentumThreshold.
Линия MACD < сигнальной линии.
Правила выхода
Фиксированный стоп-лосс (StopLossPoints) и тейк-профит (TakeProfitPoints) в шагах цены.
При включении трейлинг-стопа (TrailingStopPoints) позиция защищается по максимуму/минимуму после прохождения заданного расстояния.
Перенос в безубыток: после достижения BreakEvenTriggerPoints стоп переносится на EntryPrice ± BreakEvenOffsetPoints.
Закрытия выполняются рыночными заявками, свечные High/Low используются для проверки условий.
Управление позицией
Стратегия ведёт единую агрегированную позицию по инструменту.
Volume задаёт базовый объём сделки. При развороте сначала закрывается встречная позиция, затем открывается новая.
MaxPositionUnits ограничивает абсолютный размер позиции.
Параметры
CandleType – таймфрейм, на котором строятся индикаторы и принимаются решения (аналог переменной T).
FastMaPeriod / SlowMaPeriod – периоды LWMA (FastMA, SlowMA).
MomentumPeriod – длина расчёта Momentum (в оригинале 14).
MomentumThreshold – минимальное отклонение от 100 (Mom_Buy / Mom_Sell).
MacdFastPeriod, MacdSlowPeriod, MacdSignalPeriod – параметры MACD.
StopLossPoints, TakeProfitPoints – дистанции стопа и тейка (Stop_Loss, Take_Profit).
TrailingStopPoints – шаг трейлинг-стопа (TrailingStop).
BreakEvenTriggerPoints, BreakEvenOffsetPoints – условия переноса в безубыток (WHENTOMOVETOBE, PIPSTOMOVESL).
FractalLifetime – сколько свечей фрактал остаётся актуальным (CandlesToRetrace).
MaxPositionUnits – лимит по абсолютному объёму (аналог Max_Trades в лотах).
EnableTrailing, EnableBreakEven, UseStopLoss, UseTakeProfit – переключатели соответствующих механизмов выхода.
Отличия от оригинального советника
Не реализованы денежный тейк-профит, эквити-стоп и почтовые/Push уведомления.
Алгоритмы оптимизации лота упрощены: используется нормализация объёма StockSharp.
Вместо модификации отложенных ордеров применяются рыночные заявки – это соответствует архитектуре RiskManager в StockSharp.
Файлы
CS/PriceActionFractalStrategy.cs – реализация стратегии на C#.
Python-версия пока отсутствует.
using System;
using System.Collections.Generic;
using Ecng.Common;
using StockSharp.Algo.Indicators;
using StockSharp.Algo.Strategies;
using StockSharp.BusinessEntities;
using StockSharp.Messages;
namespace StockSharp.Samples.Strategies;
public class PriceActionFractalStrategy : Strategy
{
private readonly StrategyParam<int> _fastPeriod;
private readonly StrategyParam<int> _slowPeriod;
private readonly StrategyParam<int> _stopLossPoints;
private readonly StrategyParam<int> _takeProfitPoints;
private ExponentialMovingAverage _fast;
private ExponentialMovingAverage _slow;
private decimal _prevFast;
private decimal _prevSlow;
private decimal _entryPrice;
private int _cooldown;
public int FastPeriod { get => _fastPeriod.Value; set => _fastPeriod.Value = value; }
public int SlowPeriod { get => _slowPeriod.Value; set => _slowPeriod.Value = value; }
public int StopLossPoints { get => _stopLossPoints.Value; set => _stopLossPoints.Value = value; }
public int TakeProfitPoints { get => _takeProfitPoints.Value; set => _takeProfitPoints.Value = value; }
public PriceActionFractalStrategy()
{
_fastPeriod = Param(nameof(FastPeriod), 14).SetGreaterThanZero().SetDisplay("Fast Period", "Fast EMA period", "Indicator");
_slowPeriod = Param(nameof(SlowPeriod), 50).SetGreaterThanZero().SetDisplay("Slow Period", "Slow EMA period", "Indicator");
_stopLossPoints = Param(nameof(StopLossPoints), 200).SetNotNegative().SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk");
_takeProfitPoints = Param(nameof(TakeProfitPoints), 400).SetNotNegative().SetDisplay("Take Profit", "Take-profit in price steps", "Risk");
}
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
yield return (Security, TimeSpan.FromMinutes(5).TimeFrame());
}
protected override void OnReseted()
{
base.OnReseted();
_fast = null; _slow = null;
_prevFast = 0; _prevSlow = 0; _entryPrice = 0; _cooldown = 0;
}
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_fast = new ExponentialMovingAverage { Length = FastPeriod };
_slow = new ExponentialMovingAverage { Length = SlowPeriod };
var subscription = SubscribeCandles(TimeSpan.FromMinutes(5).TimeFrame());
subscription.Bind(_fast, _slow, ProcessCandle);
subscription.Start();
}
private void ProcessCandle(ICandleMessage candle, decimal fastValue, decimal slowValue)
{
if (candle.State != CandleStates.Finished) return;
if (!_fast.IsFormed || !_slow.IsFormed) { _prevFast = fastValue; _prevSlow = slowValue; return; }
if (_cooldown > 0) { _cooldown--; _prevFast = fastValue; _prevSlow = slowValue; return; }
var close = candle.ClosePrice;
var step = Security?.PriceStep ?? 1m;
if (Position > 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close <= _entryPrice - StopLossPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close >= _entryPrice + TakeProfitPoints * step) { SellMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
else if (Position < 0 && _entryPrice > 0)
{
if (StopLossPoints > 0 && close >= _entryPrice + StopLossPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
if (TakeProfitPoints > 0 && close <= _entryPrice - TakeProfitPoints * step) { BuyMarket(); _entryPrice = 0; _cooldown = 100; _prevFast = fastValue; _prevSlow = slowValue; return; }
}
if (_prevFast <= _prevSlow && fastValue > slowValue && Position <= 0)
{ if (Position < 0) BuyMarket(); BuyMarket(); _entryPrice = close; _cooldown = 100; }
else if (_prevFast >= _prevSlow && fastValue < slowValue && Position >= 0)
{ if (Position > 0) SellMarket(); SellMarket(); _entryPrice = close; _cooldown = 100; }
_prevFast = fastValue; _prevSlow = slowValue;
}
}
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 ExponentialMovingAverage
from StockSharp.Algo.Strategies import Strategy
class price_action_fractal_strategy(Strategy):
def __init__(self):
super(price_action_fractal_strategy, self).__init__()
self._fast_period = self.Param("FastPeriod", 14) \
.SetDisplay("Fast Period", "Fast MA period", "Indicator")
self._slow_period = self.Param("SlowPeriod", 50) \
.SetDisplay("Slow Period", "Slow MA period", "Indicator")
self._stop_loss_points = self.Param("StopLossPoints", 200) \
.SetDisplay("Stop Loss", "Stop-loss in price steps", "Risk")
self._take_profit_points = self.Param("TakeProfitPoints", 400) \
.SetDisplay("Take Profit", "Take-profit in price steps", "Risk")
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
@property
def fast_period(self):
return self._fast_period.Value
@property
def slow_period(self):
return self._slow_period.Value
@property
def stop_loss_points(self):
return self._stop_loss_points.Value
@property
def take_profit_points(self):
return self._take_profit_points.Value
def OnReseted(self):
super(price_action_fractal_strategy, self).OnReseted()
self._fast = None
self._slow = None
self._prev_fast = 0.0
self._prev_slow = 0.0
self._entry_price = 0.0
self._cooldown = 0
def OnStarted2(self, time):
super(price_action_fractal_strategy, self).OnStarted2(time)
self._fast = ExponentialMovingAverage()
self._fast.Length = self.fast_period
self._slow = ExponentialMovingAverage()
self._slow.Length = self.slow_period
subscription = self.SubscribeCandles(DataType.TimeFrame(TimeSpan.FromMinutes(5)))
subscription.Bind(self._fast, self._slow, self._process_candle)
subscription.Start()
def _process_candle(self, candle, fast_value, slow_value):
if candle.State != CandleStates.Finished:
return
fast_val = float(fast_value)
slow_val = float(slow_value)
if not self._fast.IsFormed or not self._slow.IsFormed:
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._cooldown > 0:
self._cooldown -= 1
self._prev_fast = fast_val
self._prev_slow = slow_val
return
close = float(candle.ClosePrice)
step = float(self.Security.PriceStep) if self.Security is not None and self.Security.PriceStep is not None else 1.0
if self.Position > 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close <= self._entry_price - self.stop_loss_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close >= self._entry_price + self.take_profit_points * step:
self.SellMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
elif self.Position < 0 and self._entry_price > 0:
if self.stop_loss_points > 0 and close >= self._entry_price + self.stop_loss_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self.take_profit_points > 0 and close <= self._entry_price - self.take_profit_points * step:
self.BuyMarket()
self._entry_price = 0.0
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
return
if self._prev_fast <= self._prev_slow and fast_val > slow_val and self.Position <= 0:
if self.Position < 0:
self.BuyMarket()
self.BuyMarket()
self._entry_price = close
self._cooldown = 100
elif self._prev_fast >= self._prev_slow and fast_val < slow_val and self.Position >= 0:
if self.Position > 0:
self.SellMarket()
self.SellMarket()
self._entry_price = close
self._cooldown = 100
self._prev_fast = fast_val
self._prev_slow = slow_val
def CreateClone(self):
return price_action_fractal_strategy()