Estratégia de Rompimento de Inclinação ATR
A estratégia de Rompimento de Inclinação ATR observa a taxa de variação do ATR. Uma inclinação incomumente acentuada sugere que uma nova tendência está se formando.
Os testes indicam um retorno anual médio de aproximadamente 148%. Funciona melhor no mercado de câmbio.
As entradas ocorrem quando a inclinação excede seu nível típico em um múltiplo do desvio padrão, realizando operações na direção da aceleração com um stop protetor.
Atrai traders ativos que buscam exposição antecipada à tendência. As posições são encerradas quando a inclinação retorna às leituras normais. AtrPeriod padrão = 14.
Detalhes
- Critérios de entrada: O indicador supera a média pelo multiplicador de desvio.
- Comprado/Vendido: Ambas as direções.
- Critérios de saída: O indicador reverte para a média.
- Stops: Sim.
- Valores padrão:
AtrPeriod= 14SlopePeriod= 20BreakoutMultiplier= 2.0mStopLossAtrMultiplier= 2.0mCandleType= TimeSpan.FromMinutes(5)
- Filtros:
- Categoria: Rompimento
- Direção: Ambos
- Indicadores: ATR
- Stops: Sim
- Complexidade: Intermediário
- Período: Curto prazo
- Sazonalidade: Não
- Redes neurais: Não
- Divergência: Não
- Nível de risco: Médio
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;
/// <summary>
/// Strategy based on ATR slope breakout with EMA direction filter.
/// Opens positions when ATR slope deviates from its recent average and price confirms the direction relative to EMA.
/// </summary>
public class AtrSlopeBreakoutStrategy : Strategy
{
private readonly StrategyParam<int> _atrPeriod;
private readonly StrategyParam<int> _emaPeriod;
private readonly StrategyParam<int> _slopePeriod;
private readonly StrategyParam<decimal> _breakoutMultiplier;
private readonly StrategyParam<decimal> _stopLossPercent;
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _cooldownBars;
private AverageTrueRange _atr;
private ExponentialMovingAverage _ema;
private decimal _prevAtrValue;
private decimal _currentSlope;
private decimal _avgSlope;
private decimal _stdDevSlope;
private decimal[] _slopes;
private int _currentIndex;
private int _filledCount;
private int _cooldown;
private bool _isInitialized;
/// <summary>
/// ATR period.
/// </summary>
public int AtrPeriod
{
get => _atrPeriod.Value;
set => _atrPeriod.Value = value;
}
/// <summary>
/// EMA period.
/// </summary>
public int EmaPeriod
{
get => _emaPeriod.Value;
set => _emaPeriod.Value = value;
}
/// <summary>
/// Lookback period for slope statistics calculation.
/// </summary>
public int SlopePeriod
{
get => _slopePeriod.Value;
set => _slopePeriod.Value = value;
}
/// <summary>
/// Standard deviation multiplier for breakout detection.
/// </summary>
public decimal BreakoutMultiplier
{
get => _breakoutMultiplier.Value;
set => _breakoutMultiplier.Value = value;
}
/// <summary>
/// Stop loss percentage.
/// </summary>
public decimal StopLossPercent
{
get => _stopLossPercent.Value;
set => _stopLossPercent.Value = value;
}
/// <summary>
/// Candle type.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Cooldown bars between orders.
/// </summary>
public int CooldownBars
{
get => _cooldownBars.Value;
set => _cooldownBars.Value = value;
}
/// <summary>
/// Initializes a new instance of <see cref="AtrSlopeBreakoutStrategy"/>.
/// </summary>
public AtrSlopeBreakoutStrategy()
{
_atrPeriod = Param(nameof(AtrPeriod), 14)
.SetGreaterThanZero()
.SetDisplay("ATR Period", "Period for ATR calculation", "Indicator Parameters");
_emaPeriod = Param(nameof(EmaPeriod), 20)
.SetGreaterThanZero()
.SetDisplay("EMA Period", "Period for EMA direction filter", "Indicator Parameters");
_slopePeriod = Param(nameof(SlopePeriod), 20)
.SetGreaterThanZero()
.SetDisplay("Slope Period", "Period for slope statistics calculation", "Strategy Parameters");
_breakoutMultiplier = Param(nameof(BreakoutMultiplier), 2m)
.SetGreaterThanZero()
.SetDisplay("Breakout Multiplier", "Standard deviation multiplier for breakout detection", "Strategy Parameters");
_stopLossPercent = Param(nameof(StopLossPercent), 2m)
.SetGreaterThanZero()
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk Management");
_cooldownBars = Param(nameof(CooldownBars), 1200)
.SetRange(1, 5000)
.SetDisplay("Cooldown Bars", "Bars to wait between orders", "Risk Management");
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(5).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_atr = null;
_ema = null;
_prevAtrValue = default;
_currentSlope = default;
_avgSlope = default;
_stdDevSlope = default;
_currentIndex = default;
_filledCount = default;
_cooldown = default;
_isInitialized = default;
_slopes = new decimal[SlopePeriod];
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_atr = new AverageTrueRange { Length = AtrPeriod };
_ema = new ExponentialMovingAverage { Length = EmaPeriod };
_slopes = new decimal[SlopePeriod];
_cooldown = 0;
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(_atr, _ema, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, _ema);
DrawIndicator(area, _atr);
DrawOwnTrades(area);
}
StartProtection(new(), new Unit(StopLossPercent, UnitTypes.Percent));
}
private void ProcessCandle(ICandleMessage candle, decimal atrValue, decimal emaValue)
{
if (candle.State != CandleStates.Finished)
return;
if (!_atr.IsFormed || !_ema.IsFormed)
return;
if (!_isInitialized)
{
_prevAtrValue = atrValue;
_isInitialized = true;
return;
}
_currentSlope = atrValue - _prevAtrValue;
_prevAtrValue = atrValue;
_slopes[_currentIndex] = _currentSlope;
_currentIndex = (_currentIndex + 1) % SlopePeriod;
if (_filledCount < SlopePeriod)
_filledCount++;
if (_filledCount < SlopePeriod)
return;
CalculateStatistics();
if (!IsFormedAndOnlineAndAllowTrading())
return;
if (_stdDevSlope <= 0)
return;
if (_cooldown > 0)
{
_cooldown--;
return;
}
var upperThreshold = _avgSlope + BreakoutMultiplier * _stdDevSlope;
var closePrice = candle.ClosePrice;
var priceAboveEma = closePrice > emaValue;
var priceBelowEma = closePrice < emaValue;
if (Position == 0)
{
if (_currentSlope > upperThreshold && priceAboveEma)
{
BuyMarket();
_cooldown = CooldownBars;
}
else if (_currentSlope > upperThreshold && priceBelowEma)
{
SellMarket();
_cooldown = CooldownBars;
}
}
else if (Position > 0)
{
if (_currentSlope <= _avgSlope || priceBelowEma)
{
SellMarket(Math.Abs(Position));
_cooldown = CooldownBars;
}
}
else if (Position < 0)
{
if (_currentSlope <= _avgSlope || priceAboveEma)
{
BuyMarket(Math.Abs(Position));
_cooldown = CooldownBars;
}
}
}
private void CalculateStatistics()
{
_avgSlope = 0;
var sumSquaredDiffs = 0m;
for (var i = 0; i < SlopePeriod; i++)
_avgSlope += _slopes[i];
_avgSlope /= SlopePeriod;
for (var i = 0; i < SlopePeriod; i++)
{
var diff = _slopes[i] - _avgSlope;
sumSquaredDiffs += diff * diff;
}
_stdDevSlope = (decimal)Math.Sqrt((double)(sumSquaredDiffs / SlopePeriod));
}
}
import clr
clr.AddReference("StockSharp.Messages")
clr.AddReference("StockSharp.Algo")
clr.AddReference("StockSharp.Algo.Indicators")
clr.AddReference("StockSharp.Algo.Strategies")
import math
from System import TimeSpan, Math
from StockSharp.Messages import DataType, Unit, UnitTypes, CandleStates
from StockSharp.Algo.Indicators import AverageTrueRange, ExponentialMovingAverage
from StockSharp.Algo.Strategies import Strategy
class atr_slope_breakout_strategy(Strategy):
"""
Strategy based on ATR slope breakout with EMA direction filter.
Opens positions when ATR slope deviates from its recent average and price confirms direction relative to EMA.
"""
def __init__(self):
super(atr_slope_breakout_strategy, self).__init__()
self._atr_period = self.Param("AtrPeriod", 14) \
.SetGreaterThanZero() \
.SetDisplay("ATR Period", "Period for ATR calculation", "Indicator Parameters")
self._ema_period = self.Param("EmaPeriod", 20) \
.SetGreaterThanZero() \
.SetDisplay("EMA Period", "Period for EMA direction filter", "Indicator Parameters")
self._slope_period = self.Param("SlopePeriod", 20) \
.SetGreaterThanZero() \
.SetDisplay("Slope Period", "Period for slope statistics calculation", "Strategy Parameters")
self._breakout_multiplier = self.Param("BreakoutMultiplier", 2.0) \
.SetGreaterThanZero() \
.SetDisplay("Breakout Multiplier", "Standard deviation multiplier for breakout detection", "Strategy Parameters")
self._stop_loss_percent = self.Param("StopLossPercent", 2.0) \
.SetGreaterThanZero() \
.SetDisplay("Stop Loss %", "Stop loss percentage", "Risk Management")
self._cooldown_bars = self.Param("CooldownBars", 1200) \
.SetDisplay("Cooldown Bars", "Bars to wait between orders", "Risk Management")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(5))) \
.SetDisplay("Candle Type", "Type of candles to use", "General")
self._atr = None
self._ema = None
self._prev_atr = 0.0
self._current_slope = 0.0
self._avg_slope = 0.0
self._std_dev_slope = 0.0
self._slopes = None
self._current_index = 0
self._filled_count = 0
self._cooldown = 0
self._is_initialized = False
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(atr_slope_breakout_strategy, self).OnReseted()
self._atr = None
self._ema = None
self._prev_atr = 0.0
self._current_slope = 0.0
self._avg_slope = 0.0
self._std_dev_slope = 0.0
sp = int(self._slope_period.Value)
self._slopes = [0.0] * sp
self._current_index = 0
self._filled_count = 0
self._cooldown = 0
self._is_initialized = False
def OnStarted2(self, time):
super(atr_slope_breakout_strategy, self).OnStarted2(time)
sp = int(self._slope_period.Value)
self._slopes = [0.0] * sp
self._cooldown = 0
self._filled_count = 0
self._current_index = 0
self._atr = AverageTrueRange()
self._atr.Length = int(self._atr_period.Value)
self._ema = ExponentialMovingAverage()
self._ema.Length = int(self._ema_period.Value)
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(self._atr, self._ema, self._process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, self._ema)
self.DrawIndicator(area, self._atr)
self.DrawOwnTrades(area)
self.StartProtection(Unit(), Unit(self._stop_loss_percent.Value, UnitTypes.Percent))
def _process_candle(self, candle, atr_value, ema_value):
if candle.State != CandleStates.Finished:
return
if not self._atr.IsFormed or not self._ema.IsFormed:
return
atr_val = float(atr_value)
ema_val = float(ema_value)
if not self._is_initialized:
self._prev_atr = atr_val
self._is_initialized = True
return
self._current_slope = atr_val - self._prev_atr
self._prev_atr = atr_val
sp = int(self._slope_period.Value)
self._slopes[self._current_index] = self._current_slope
self._current_index = (self._current_index + 1) % sp
if self._filled_count < sp:
self._filled_count += 1
if self._filled_count < sp:
return
self._calculate_statistics()
if not self.IsFormedAndOnlineAndAllowTrading():
return
if self._std_dev_slope <= 0:
return
if self._cooldown > 0:
self._cooldown -= 1
return
bm = float(self._breakout_multiplier.Value)
upper_threshold = self._avg_slope + bm * self._std_dev_slope
close_price = float(candle.ClosePrice)
price_above_ema = close_price > ema_val
price_below_ema = close_price < ema_val
if self.Position == 0:
if self._current_slope > upper_threshold and price_above_ema:
self.BuyMarket()
self._cooldown = int(self._cooldown_bars.Value)
elif self._current_slope > upper_threshold and price_below_ema:
self.SellMarket()
self._cooldown = int(self._cooldown_bars.Value)
elif self.Position > 0:
if self._current_slope <= self._avg_slope or price_below_ema:
self.SellMarket(Math.Abs(self.Position))
self._cooldown = int(self._cooldown_bars.Value)
elif self.Position < 0:
if self._current_slope <= self._avg_slope or price_above_ema:
self.BuyMarket(Math.Abs(self.Position))
self._cooldown = int(self._cooldown_bars.Value)
def _calculate_statistics(self):
sp = int(self._slope_period.Value)
self._avg_slope = 0.0
sum_sq = 0.0
for i in range(sp):
self._avg_slope += self._slopes[i]
self._avg_slope /= float(sp)
for i in range(sp):
diff = self._slopes[i] - self._avg_slope
sum_sq += diff * diff
self._std_dev_slope = math.sqrt(sum_sq / float(sp))
def CreateClone(self):
return atr_slope_breakout_strategy()