La Estrategia EMA LWMA RSI reproduce el asesor experto de MetaTrader "EMA LWMA RSI" en StockSharp. Compara dos medias móviles que usan el mismo precio aplicado y opcionalmente un desplazamiento hacia adelante, mientras un filtro de Índice de Fuerza Relativa confirma el momentum. El algoritmo solo reacciona a velas completamente terminadas del marco temporal configurado y opera una sola posición neta: cierra cualquier exposición opuesta antes de abrir una nueva orden en la dirección señalada. Las distancias de stop-loss y take-profit se configuran en pips y se escalan automáticamente al tamaño de tick del instrumento.
Lógica de trading
Calcular una media móvil exponencial (EMA) y una media móvil ponderada lineal (LWMA) con longitudes individuales pero el mismo precio aplicado. Si MaShift es mayor que cero, ambas medias se desplazan hacia adelante por el número especificado de barras para reflejar el argumento "shift" de MetaTrader.
Procesar un RSI con su propio precio aplicado. La estrategia usa el umbral clásico de 50 para distinguir momentum alcista y bajista.
Cuando llega una vela terminada:
Se genera una señal de compra si el EMA cruza por encima del LWMA (el EMA anterior era mayor que el LWMA anterior, pero el EMA actual está por debajo del LWMA actual) y el valor RSI está por encima de 50.
Se genera una señal de venta si el EMA cruza por debajo del LWMA (el EMA anterior era menor que el LWMA anterior, pero el EMA actual está por encima del LWMA actual) y el valor RSI está por debajo de 50.
Las señales establecen indicadores de pendiente internos. Antes de revertir, la estrategia primero cierra la posición existente con ClosePosition(). Después de confirmar el llenado, inmediatamente envía una orden de mercado en la dirección solicitada. Esto refleja el asesor experto original que esperaba la confirmación de transacción antes de enviar la siguiente orden.
Las órdenes protectoras se inician vía StartProtection. Si un stop-loss o take-profit está desactivado (establecido en cero), esa parte se omite, coincidiendo con el comportamiento MQL.
Notas de implementación
La selección de precio aplicado soporta las opciones de MetaTrader (Cierre, Apertura, Máximo, Mínimo, Mediano, Típico, Ponderado, Promedio). El precio ponderado se calcula como (Máximo + Mínimo + 2 * Cierre) / 4, idéntico a PRICE_WEIGHTED.
El dimensionamiento de pips multiplica automáticamente el PriceStep del instrumento por 10 para símbolos forex de 3/5 dígitos, asegurando que un pip equivalga a 10 puntos en cotizaciones fraccionarias.
Las vinculaciones de indicadores dependen de la suscripción de velas de alto nivel de StockSharp. El manejo de desplazamiento usa indicadores Shift en lugar de indexación manual de buffers.
El código mantiene indicadores booleanos para solicitudes de compra/venta pendientes. Previenen órdenes duplicadas mientras el comando anterior todavía está pendiente y se limpian cuando llegan los llenados o cuando la posición ya coincide con la señal.
Los ayudantes de gráficos dibujan ambas medias móviles en el panel de precio y el RSI en un área separada para inspección visual.
Parámetros
Parámetro
Tipo
Predeterminado
Descripción
CandleType
DataType
1h TimeFrame
Serie de velas procesada por la estrategia.
StopLossPips
int
150
Distancia de stop-loss en pips. 0 desactiva el stop.
TakeProfitPips
int
150
Distancia de take-profit en pips. 0 desactiva el objetivo.
EmaPeriod
int
28
Período de la media móvil exponencial.
LwmaPeriod
int
8
Período de la media móvil ponderada lineal.
MaShift
int
0
Desplazamiento hacia adelante (barras) aplicado a ambas medias móviles.
RsiPeriod
int
14
Período de promediado del RSI.
MaAppliedPrice
AppliedPriceType
Weighted
Precio aplicado enviado a EMA y LWMA.
RsiAppliedPrice
AppliedPriceType
Weighted
Precio aplicado usado por el RSI.
Uso
Adjuntar la estrategia al instrumento deseado y establecer CandleType para que coincida con el marco temporal usado en MetaTrader.
Ajustar las protecciones basadas en pips y la configuración de indicadores si el broker usa valores predeterminados diferentes.
Habilitar el trading una vez que la suscripción esté activa. La estrategia gestionará una posición a la vez y usará ClosePosition() antes de cambiar de dirección.
No se proporciona traducción en Python para esta estrategia todavía.
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 EmaLwmaRsiStrategy : 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 EmaLwmaRsiStrategy()
{
_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 ema_lwma_rsi_strategy(Strategy):
def __init__(self):
super(ema_lwma_rsi_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(ema_lwma_rsi_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(ema_lwma_rsi_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 ema_lwma_rsi_strategy()