Esta estrategia combina una media móvil con una media móvil ponderada por volumen (VWMA). Cuando el precio opera por encima de la VWMA, sugiere que los compradores son dominantes. Un rompimiento ocurre cuando el precio cruza la VWMA desde el lado opuesto.
Las pruebas indican un retorno anual promedio de aproximadamente 40%. Funciona mejor en el mercado de criptomonedas.
Las operaciones se alinean con la dirección de la VWMA y utilizan la media móvil simple como filtro de tendencia de nivel superior. Las salidas ocurren cuando el precio revierte respecto a la media móvil.
El objetivo es capturar rompimientos respaldados por volumen.
Detalles
Criterios de entrada: Precio por encima o por debajo de la VWMA con confirmación de la MA.
Largo/Corto: Ambas direcciones.
Criterios de salida: El precio cruza la MA en dirección opuesta o stop.
Stops: Sí.
Valores predeterminados:
MAPeriod = 20
VWAPPeriod = 20
CandleType = TimeSpan.FromMinutes(5)
Filtros:
Categoría: Ruptura
Dirección: Ambos
Indicadores: VWMA, MA
Stops: Sí
Complejidad: Intermedio
Marco temporal: Intradía
Estacionalidad: No
Redes neuronales: No
Divergencia: No
Nivel de riesgo: Medio
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>
/// Volume Weighted Price Breakout Strategy.
/// Long entry: Price rises above VWMA.
/// Short entry: Price falls below VWMA.
/// Exit: Price crosses MA in the opposite direction.
/// </summary>
public class VolumeWeightedPriceBreakoutStrategy : Strategy
{
private readonly StrategyParam<int> _maPeriod;
private readonly StrategyParam<int> _vwapPeriod;
private readonly StrategyParam<DataType> _candleType;
private readonly StrategyParam<int> _cooldownBars;
private int _cooldown;
/// <summary>
/// MA Period.
/// </summary>
public int MAPeriod
{
get => _maPeriod.Value;
set => _maPeriod.Value = value;
}
/// <summary>
/// VWAP Period.
/// </summary>
public int VWAPPeriod
{
get => _vwapPeriod.Value;
set => _vwapPeriod.Value = value;
}
/// <summary>
/// Candle type for strategy calculation.
/// </summary>
public DataType CandleType
{
get => _candleType.Value;
set => _candleType.Value = value;
}
/// <summary>
/// Cooldown bars between trades.
/// </summary>
public int CooldownBars
{
get => _cooldownBars.Value;
set => _cooldownBars.Value = value;
}
/// <summary>
/// Initialize <see cref="VolumeWeightedPriceBreakoutStrategy"/>.
/// </summary>
public VolumeWeightedPriceBreakoutStrategy()
{
_maPeriod = Param(nameof(MAPeriod), 20)
.SetGreaterThanZero()
.SetDisplay("MA Period", "Period for Moving Average", "Indicators")
.SetOptimize(10, 50, 10);
_vwapPeriod = Param(nameof(VWAPPeriod), 20)
.SetGreaterThanZero()
.SetDisplay("VWAP Period", "Period for VWMA", "Indicators")
.SetOptimize(10, 30, 5);
_candleType = Param(nameof(CandleType), TimeSpan.FromMinutes(1).TimeFrame())
.SetDisplay("Candle Type", "Type of candles to use", "General");
_cooldownBars = Param(nameof(CooldownBars), 500)
.SetRange(1, 1000)
.SetDisplay("Cooldown Bars", "Bars to wait between trades", "General");
}
/// <inheritdoc />
public override IEnumerable<(Security sec, DataType dt)> GetWorkingSecurities()
{
return [(Security, CandleType)];
}
/// <inheritdoc />
protected override void OnReseted()
{
base.OnReseted();
_cooldown = default;
}
/// <inheritdoc />
protected override void OnStarted2(DateTime time)
{
base.OnStarted2(time);
_cooldown = 0;
var ma = new SimpleMovingAverage { Length = MAPeriod };
var vwma = new VolumeWeightedMovingAverage { Length = VWAPPeriod };
var subscription = SubscribeCandles(CandleType);
subscription
.Bind(ma, vwma, ProcessCandle)
.Start();
var area = CreateChartArea();
if (area != null)
{
DrawCandles(area, subscription);
DrawIndicator(area, ma);
DrawIndicator(area, vwma);
DrawOwnTrades(area);
}
}
private void ProcessCandle(ICandleMessage candle, decimal maValue, decimal vwmaValue)
{
if (candle.State != CandleStates.Finished)
return;
if (!IsFormedAndOnlineAndAllowTrading())
return;
if (_cooldown > 0)
{
_cooldown--;
return;
}
if (Position == 0)
{
if (candle.ClosePrice > vwmaValue)
{
BuyMarket();
_cooldown = CooldownBars;
}
else if (candle.ClosePrice < vwmaValue)
{
SellMarket();
_cooldown = CooldownBars;
}
}
else if (Position > 0 && candle.ClosePrice < maValue)
{
SellMarket();
_cooldown = CooldownBars;
}
else if (Position < 0 && candle.ClosePrice > maValue)
{
BuyMarket();
_cooldown = CooldownBars;
}
}
}
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 SimpleMovingAverage, VolumeWeightedMovingAverage
from StockSharp.Algo.Strategies import Strategy
class volume_weighted_price_breakout_strategy(Strategy):
"""
Volume Weighted Price Breakout Strategy.
Long entry: Price rises above VWMA.
Short entry: Price falls below VWMA.
Exit: Price crosses MA in the opposite direction.
"""
def __init__(self):
super(volume_weighted_price_breakout_strategy, self).__init__()
self._ma_period = self.Param("MAPeriod", 20).SetDisplay("MA Period", "Period for Moving Average", "Indicators")
self._vwap_period = self.Param("VWAPPeriod", 20).SetDisplay("VWAP Period", "Period for VWMA", "Indicators")
self._candle_type = self.Param("CandleType", DataType.TimeFrame(TimeSpan.FromMinutes(1))).SetDisplay("Candle Type", "Type of candles to use", "General")
self._cooldown_bars = self.Param("CooldownBars", 500).SetDisplay("Cooldown Bars", "Bars to wait between trades", "General")
self._cooldown = 0
@property
def candle_type(self):
return self._candle_type.Value
def OnReseted(self):
super(volume_weighted_price_breakout_strategy, self).OnReseted()
self._cooldown = 0
def OnStarted2(self, time):
super(volume_weighted_price_breakout_strategy, self).OnStarted2(time)
self._cooldown = 0
ma = SimpleMovingAverage()
ma.Length = self._ma_period.Value
vwma = VolumeWeightedMovingAverage()
vwma.Length = self._vwap_period.Value
subscription = self.SubscribeCandles(self.candle_type)
subscription.Bind(ma, vwma, self._process_candle).Start()
area = self.CreateChartArea()
if area is not None:
self.DrawCandles(area, subscription)
self.DrawIndicator(area, ma)
self.DrawIndicator(area, vwma)
self.DrawOwnTrades(area)
def _process_candle(self, candle, ma_val, vwma_val):
if candle.State != CandleStates.Finished:
return
if self._cooldown > 0:
self._cooldown -= 1
return
close = float(candle.ClosePrice)
mv = float(ma_val)
vv = float(vwma_val)
cd = self._cooldown_bars.Value
if self.Position == 0:
if close > vv:
self.BuyMarket()
self._cooldown = cd
elif close < vv:
self.SellMarket()
self._cooldown = cd
elif self.Position > 0 and close < mv:
self.SellMarket()
self._cooldown = cd
elif self.Position < 0 and close > mv:
self.BuyMarket()
self._cooldown = cd
def CreateClone(self):
return volume_weighted_price_breakout_strategy()