La estrategia de volatilidad por ruptura busca estallidos breves de volatilidad intrabar. Espera una vela cuyo rango se expanda por encima del de la vela anterior, pero solo dentro de una banda estrecha (dos equivalentes de pip después de la normalización de dígitos). Cuando dicha vela cierra alcista, la estrategia compra; cuando cierra bajista, vende. Stops de protección, un trailing stop opcional y una secuencia automática de inversión tras pérdida gestionan el riesgo e intentan recuperarse de movimientos adversos.
Lógica de trading
Filtro de expansión de rango
Calcular el rango de la vela actual (High - Low) y compararlo con el de la vela anterior.
Exigir que el rango actual sea mayor, pero que no supere el rango anterior por más de dos pips normalizados.
Esto crea una configuración en la que la volatilidad aumenta pero sigue contenida, lo que apunta a una posible ruptura sin ruido excesivo.
Sesgo direccional
Si la vela cierra por encima de su apertura, entrar largo.
Si la vela cierra por debajo de su apertura, entrar corto.
La estrategia puede prohibir opcionalmente más de una entrada por barra para evitar señales repetidas en la misma vela.
Gestión de posiciones
El stop-loss inicial y el take-profit se asignan en puntos (equivalentes de pip) relativos al precio de entrada.
Un trailing stop opcional ajusta el nivel de protección cuando el precio se ha movido una distancia especificada a favor de la operación. Un paso trailing evita ajustes diminutos.
Cuando una posición se cierra con pérdida, la estrategia puede invertir la dirección de inmediato. Cada inversión aumenta la distancia de take-profit para compensar el riesgo adicional. Un límite en el número de inversiones consecutivas evita un comportamiento martingala infinito.
Parámetros
Nombre
Descripción
Predeterminado
Optimizable
TradeVolume
Volumen base de orden para entradas de mercado.
0.1
Sí
StopLossPoints
Distancia del stop-loss en puntos.
20
Sí
TakeProfitPoints
Distancia del take-profit en puntos.
10
Sí
TrailingStopPoints
Distancia del trailing stop en puntos. Establecer en 0 para desactivar.
25
No
TrailingStepPoints
Paso incremental mínimo al mover el trailing stop.
5
No
OnlyOnePositionPerBar
Prohíbe múltiples entradas durante la misma vela.
true
No
UseAutoDigits
Multiplica el tamaño del punto por 10 en símbolos con 3 o 5 decimales para convertir a unidades de pip.
true
No
ReverseAfterStop
Habilita el flujo de inversión tras pérdida.
true
No
MaxReverseOrders
Número máximo de operaciones inversas consecutivas.
2
No
TakeProfitIncrease
Puntos extra de take-profit añadidos por cada orden inversa.
100
No
CandleType
Tipo de vela y marco temporal para los cálculos.
TimeSpan.FromMinutes(1)
No
Gestión de riesgos
Los desplazamientos de stop-loss y take-profit se recalculan usando el paso de precio del instrumento. La detección automática de dígitos convierte las cotizaciones de cinco dígitos en distancias del tamaño de un pip.
La lógica trailing solo se activa después de que el mercado avance la distancia trailing especificada y exige un paso mínimo antes de modificar el stop.
El trading inverso se reinicia después de una salida rentable o después de alcanzar el límite configurado de inversiones consecutivas.
Notas prácticas
Funciona mejor en pares de divisas con spreads ajustados, donde pequeños cambios de volatilidad pueden indicar ráfagas de momentum.
Considere alinear el marco temporal de las velas con la sesión de mercado objetivo; el marco temporal predeterminado de 1 minuto captura rupturas de alta frecuencia.
Como las inversiones se ejecutan inmediatamente después de un cierre perdedor, asegúrese de que haya margen suficiente para operaciones consecutivas.
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 BreakthroughVolatilityStrategy : 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 BreakthroughVolatilityStrategy()
{
_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 breakthrough_volatility_strategy(Strategy):
def __init__(self):
super(breakthrough_volatility_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(breakthrough_volatility_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(breakthrough_volatility_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 breakthrough_volatility_strategy()