mirror of
https://github.com/PyP-Quant/quant-trading-strategy-templates.git
synced 2026-08-21 14:48:08 +00:00
feat: implement EURJPY range fade classifier 5m strategy (closes #210)
This commit is contained in:
@@ -41,4 +41,4 @@ EURJPY may show repeatable behavior when range fade classifier conditions align
|
||||
|
||||
This idea is intentionally Markdown-only. A future template can add `strategy.py`, `quant.config.json`, and a focused README once PPE results justify turning the idea into executable code.
|
||||
|
||||
Closes #13
|
||||
Closes #210
|
||||
@@ -0,0 +1,47 @@
|
||||
# EURJPY Range fade classifier 5m
|
||||
|
||||
This strategy implements a range fade classifier approach for EURJPY on 5-minute candles using HistGradientBoostingClassifier.
|
||||
|
||||
## Overview
|
||||
|
||||
- **Pair**: EURJPY
|
||||
- **Timeframe**: 5m
|
||||
- **Model**: HistGradientBoostingClassifier with feature engineering focused on range fading (mean reversion in ranging markets)
|
||||
- **Goal**: Identify ranging markets and trade mean reversion moves off support/resistance levels
|
||||
|
||||
## Features Engineered
|
||||
|
||||
1. **Returns**: 1, 3, 6, 12 period returns
|
||||
2. **ATR-normalized candle range and close location value** (from idea)
|
||||
3. **Range fade classifier**:
|
||||
- Bollinger Band position (0=lower band, 1=upper band)
|
||||
- Bollinger Band width (normalized)
|
||||
- Ranging market detection (low BB width)
|
||||
- Mean reversion signals in ranging markets (fade extremes)
|
||||
4. **Distance from EMAs** (from idea): 20, 50, and 200 period EMAs
|
||||
5. **Prior swing high and swing low distance** (from idea)
|
||||
6. **Volume features**: Z-score and ratio to moving average
|
||||
7. **Rolling volatility percentile** (from idea): Fast/slow volatility ratio, volatility percentile
|
||||
|
||||
## Configuration
|
||||
|
||||
See `quant.config.json` for hyperparameters:
|
||||
- `lookback`: 100 candles for prediction
|
||||
- `horizon`: 5 candles forward for labeling (5m timeframe)
|
||||
- `threshold`: 0.0008 (8 pips) for ATR-normalized breakout
|
||||
- `min_confidence`: 0.52 minimum probability for signal generation
|
||||
|
||||
## Usage
|
||||
|
||||
This template follows the PyP Quant Mode contract:
|
||||
```python
|
||||
def train(data, config):
|
||||
return model, metrics
|
||||
|
||||
def predict(model, market_data, config):
|
||||
return {"signal": "UP|DOWN|HOLD", "confidence": 0.0, "metadata": {}}
|
||||
```
|
||||
|
||||
## Disclaimer
|
||||
|
||||
Educational template only. Not financial advice. Past performance does not guarantee future results.
|
||||
@@ -0,0 +1,28 @@
|
||||
{
|
||||
"pair": "EURJPY",
|
||||
"timeframe": "5m",
|
||||
"model_family": "sklearn HistGradientBoostingClassifier",
|
||||
"runtime_target": "edge",
|
||||
"artifact_format": "weights_bundle",
|
||||
"parameters": {
|
||||
"lookback": 100,
|
||||
"horizon": 5,
|
||||
"threshold": 0.0008,
|
||||
"min_confidence": 0.52
|
||||
},
|
||||
"training_requirements": [
|
||||
"numpy",
|
||||
"pandas",
|
||||
"scikit-learn",
|
||||
"joblib"
|
||||
],
|
||||
"inference_requirements": [
|
||||
"numpy",
|
||||
"pandas",
|
||||
"scikit-learn",
|
||||
"joblib"
|
||||
],
|
||||
"symbol": "EURJPY",
|
||||
"description": "EURJPY range fade classifier strategy using HistGradientBoostingClassifier",
|
||||
"disclaimer": "Educational template only. Not financial advice."
|
||||
}
|
||||
@@ -0,0 +1,163 @@
|
||||
import numpy as np
|
||||
import pandas as pd
|
||||
from sklearn.experimental import enable_hist_gradient_boosting # noqa
|
||||
from sklearn.ensemble import HistGradientBoostingClassifier
|
||||
from sklearn.pipeline import Pipeline
|
||||
from sklearn.preprocessing import StandardScaler
|
||||
|
||||
|
||||
SYMBOL = "EURJPY"
|
||||
MODEL_NAME = "eurjpy-range-fade-classifier-5m"
|
||||
|
||||
|
||||
def _normalise(data):
|
||||
df = data.copy()
|
||||
df.columns = [str(c).lower() for c in df.columns]
|
||||
if "volume" not in df.columns:
|
||||
df["volume"] = 1.0
|
||||
for col in ["open", "high", "low", "close", "volume"]:
|
||||
df[col] = pd.to_numeric(df[col], errors="coerce")
|
||||
return df.dropna(subset=["open", "high", "low", "close"]).reset_index(drop=True)
|
||||
|
||||
|
||||
def _features(df):
|
||||
c = df["close"]
|
||||
h = df["high"]
|
||||
l = df["low"]
|
||||
v = df["volume"]
|
||||
|
||||
# Basic returns
|
||||
out = pd.DataFrame(index=df.index)
|
||||
out["ret1"] = c.pct_change()
|
||||
out["ret3"] = c.pct_change(3)
|
||||
out["ret6"] = c.pct_change(6)
|
||||
out["ret12"] = c.pct_change(12)
|
||||
|
||||
# ATR for normalization
|
||||
tr = np.maximum(h - l, np.maximum(abs(h - c.shift(1)), abs(l - c.shift(1))))
|
||||
atr = pd.Series(tr).rolling(14).mean()
|
||||
out["atr"] = atr
|
||||
|
||||
# ATR-normalized candle range and close location value
|
||||
out["range_pct"] = (h - l) / c
|
||||
out["body_pct"] = (c - df["open"]) / (h - l).replace(0, np.nan)
|
||||
out["close_pos"] = (c - l) / (h - l).replace(0, np.nan)
|
||||
|
||||
# Range fade classifier features
|
||||
# Identify ranging markets (low volatility, price bouncing between support/resistance)
|
||||
# Bollinger Band position
|
||||
sma_20 = c.rolling(20).mean()
|
||||
std_20 = c.rolling(20).std()
|
||||
upper_bb = sma_20 + (std_20 * 2)
|
||||
lower_bb = sma_20 - (std_20 * 2)
|
||||
bb_width = upper_bb - lower_bb
|
||||
out["bb_position"] = (c - lower_bb) / bb_width.replace(0, np.nan) # 0=lower band, 1=upper band
|
||||
out["bb_width"] = bb_width / c # Normalized BB width
|
||||
|
||||
# Range detection: low BB width indicates ranging market
|
||||
out["is_ranging"] = (out["bb_width"] < out["bb_width"].rolling(50).quantile(0.3)).astype(int)
|
||||
|
||||
# Mean reversion signals in ranging markets
|
||||
out["mean_reversion_signal"] = np.where(
|
||||
out["is_ranging"] == 1,
|
||||
np.where(out["bb_position"] > 0.8, -1, # Near upper band -> expect down
|
||||
np.where(out["bb_position"] < 0.2, 1, 0)), # Near lower band -> expect up
|
||||
0 # Not ranging -> no signal
|
||||
)
|
||||
|
||||
# Distance from EMAs (from idea)
|
||||
out["ema20_dist"] = (c - c.ewm(span=20, adjust=False).mean()) / c
|
||||
out["ema50_dist"] = (c - c.ewm(span=50, adjust=False).mean()) / c
|
||||
out["ema200_dist"] = (c - c.ewm(span=200, adjust=False).mean()) / c
|
||||
|
||||
# Prior swing high and swing low distance (from idea)
|
||||
swing_high = h.rolling(20, center=False).max().shift(1)
|
||||
swing_low = l.rolling(20, center=False).min().shift(1)
|
||||
out["dist_to_swing_high"] = (swing_high - c) / c
|
||||
out["dist_to_swing_low"] = (c - swing_low) / c
|
||||
|
||||
# Volume features
|
||||
out["volume_z"] = (v - v.rolling(48).mean()) / (v.rolling(48).std() + 1e-9)
|
||||
out["volume_ratio"] = v / v.rolling(20).mean()
|
||||
|
||||
# Rolling volatility percentile (from idea)
|
||||
returns = c.pct_change()
|
||||
out["volatility_fast"] = returns.rolling(16).std()
|
||||
out["volatility_slow"] = returns.rolling(64).std()
|
||||
out["volatility_ratio"] = out["volatility_fast"] / (out["volatility_slow"] + 1e-9)
|
||||
out["volatility_percentile"] = out["volatility_fast"].rolling(200).apply(
|
||||
lambda x: pd.Series(x).rank(pct=True).iloc[-1] if len(x) > 0 else 0.5, raw=False)
|
||||
|
||||
return out.replace([np.inf, -np.inf], np.nan).dropna()
|
||||
|
||||
|
||||
def _labels(close, index, horizon, threshold):
|
||||
fwd = close.pct_change(horizon).shift(-horizon)
|
||||
y = pd.Series(1, index=close.index)
|
||||
y[fwd > threshold] = 2
|
||||
y[fwd < -threshold] = 0
|
||||
return y.reindex(index).fillna(1).astype(int)
|
||||
|
||||
|
||||
def train(data, config):
|
||||
params = config.get("parameters", {})
|
||||
horizon = int(params.get("horizon", 5)) # 5m horizon for 5m timeframe
|
||||
threshold = float(params.get("threshold", 0.0008))
|
||||
df = _normalise(data)
|
||||
feat = _features(df)
|
||||
y = _labels(df["close"], feat.index, horizon, threshold)
|
||||
|
||||
model = Pipeline([
|
||||
("scaler", StandardScaler()),
|
||||
("clf", HistGradientBoostingClassifier(
|
||||
learning_rate=0.1,
|
||||
max_iter=100,
|
||||
max_depth=6,
|
||||
min_samples_leaf=10,
|
||||
l2_regularization=0.1,
|
||||
random_state=42
|
||||
)),
|
||||
])
|
||||
model.fit(feat.values.astype(np.float32), y.values)
|
||||
preds = model.predict(feat.values.astype(np.float32))
|
||||
|
||||
metrics = {
|
||||
"training_bars": int(len(feat)),
|
||||
"feature_count": int(feat.shape[1]),
|
||||
"buy_signals": int((preds == 2).sum()),
|
||||
"sell_signals": int((preds == 0).sum()),
|
||||
"hold_signals": int((preds == 1).sum()),
|
||||
}
|
||||
return {"model": model, "features": list(feat.columns), "symbol": SYMBOL}, metrics
|
||||
|
||||
|
||||
def predict(model, market_data, config):
|
||||
params = config.get("parameters", {})
|
||||
lookback = int(params.get("lookback", 100))
|
||||
min_conf = float(params.get("min_confidence", 0.52))
|
||||
candles = market_data.get("candles", [])
|
||||
|
||||
if len(candles) < lookback:
|
||||
return {"signal": "HOLD", "confidence": 0.0, "metadata": {"reason": "not_enough_candles", "model": MODEL_NAME}}
|
||||
|
||||
df = _normalise(pd.DataFrame(candles, columns=["open", "high", "low", "close", "volume"]))
|
||||
feat = _features(df).tail(1)
|
||||
|
||||
if feat.empty:
|
||||
return {"signal": "HOLD", "confidence": 0.0, "metadata": {"reason": "no_features", "model": MODEL_NAME}}
|
||||
|
||||
proba = model["model"].predict_proba(feat.values.astype(np.float32))[0]
|
||||
klass = int(np.argmax(proba))
|
||||
conf = float(proba[klass])
|
||||
signal = {0: "DOWN", 1: "HOLD", 2: "UP"}[klass]
|
||||
|
||||
if conf < min_conf:
|
||||
signal = "HOLD"
|
||||
|
||||
return {"signal": signal, "confidence": round(conf, 4), "metadata": {
|
||||
"p_sell": round(float(proba[0]), 4),
|
||||
"p_hold": round(float(proba[1]), 4),
|
||||
"p_buy": round(float(proba[2]), 4),
|
||||
"model": MODEL_NAME,
|
||||
"symbol": SYMBOL
|
||||
}}
|
||||
Reference in New Issue
Block a user