视觉增强利器！在FMZ上用砖图与平均K线读懂市场趋势

发明者量化-小小梦

1363

Followers

Discussions

Created 2025-06-06 09:27:29 Updated 2025-06-06 17:34:58

958

在量化交易中，传统的K线图是最常用的数据表现形式之一，但它也存在一定局限性，例如对波动不敏感或过度噪声影响。为了更清晰地观察价格趋势，交易者常常使用一些改进型图表，如：

砖图（Renko）：基于价格变动而非时间绘制，有效过滤市场噪声。
平均K线（Heikin Ashi）：通过平滑价格数据，更直观地展示趋势方向。

本文将在 FMZ 量化交易平台上，介绍如何基于普通K线计算出砖图和平均K线数据，并展示绘图效果，帮助策略开发者更直观地分析市场走势。

砖图（Renko）

砖图以“砖块”为单位，只在价格波动超过固定幅度（如 $100）时才画出一个新砖。

优势：以价格变动为基础，过滤掉市场中的小幅波动，突出主要趋势。
适用场景：适用于识别中长期趋势，减少交易中的噪音干扰。

交易信号解读

趋势确认：连续上涨砖块表示趋势强劲，可持仓；出现反向砖块是趋势反转信号。
突破交易：当出现新砖块，尤其是打破前高/前低时，可考虑入场。
假突破过滤：由于砖图忽略小波动，有助于过滤掉震荡期的小假突破。

核心计算逻辑：

设定“砖大小” brickSize
以初始价格为基础，不断比较最新价格是否偏离上一个砖价格超过 brickSize
如果上涨超出，则画出一个上涨砖块；下跌同理

计算砖图（Renko）以及画图实现代码：


            javascript
            
            
/*backtest
start: 2025-05-01 00:00:00
end: 2025-06-06 00:00:00
period: 1h
basePeriod: 1m
exchanges: [{"eid":"Binance","currency":"ETH_USDT","balance":1000,"stocks":0.5}]
*/

let globalbricks = []
let lastBarTime = 0

function getBricks(r, brickSize, sourceAttribute, lastPrice) {
    for (let i = 1; i < r.length; i++) {
        let bar = r[i]
        let price = bar[sourceAttribute]
        let time = bar.Time

        if (time < lastBarTime) {
            continue 
        }

        // 遍历原始K线数据
        while (Math.abs(price - lastPrice) >= brickSize) {
            if (globalbricks.length > 0 && time == globalbricks[globalbricks.length - 1].Time) {
                time = globalbricks[globalbricks.length - 1].Time + 1000
            }
            // 构造砖块
            let brick = {
                Time: time,
                Open: lastPrice,
                Close: 0,
                High: 0,
                Low: 0
            }

            if (price > lastPrice) {
                // 上涨砖块
                lastPrice += brickSize
                brick.Close = lastPrice
                brick.High = lastPrice
                brick.Low = brick.Open
            } else {
                // 下跌砖块
                lastPrice -= brickSize
                brick.Close = lastPrice
                brick.High = brick.Open
                brick.Low = lastPrice
            }

            // 放入数组
            globalbricks.push(brick)

            // time 累加1秒，防止一根BAR分成多块brick时断开
            time += 1000
        }

        lastBarTime = bar.Time
    }

    return globalbricks
}

function getRenko(r, brickSize, sourceAttribute) {
    // 原始K线数据如果不符合计算要求，直接返回
    if (!r || r.length <= 0) {
        return null
    }

    if (globalbricks.length == 0) {
        return getBricks(r, brickSize, sourceAttribute, r[0][sourceAttribute])
    } else {
        return getBricks(r, brickSize, sourceAttribute, globalbricks[globalbricks.length - 1].Close)
    }
}

function main() {
    let c = KLineChart({
        overlay: true
    })

    while (true) {
        let r = _C(exchange.GetRecords)
        let bricks = getRenko(r, 100, "Close")
        bricks.forEach(function (brick, index) {
            c.begin(brick)
            c.close()
        })

        Sleep(1000)
    }
}

回测测试

平均K线（Heikin Ashi）

Heikin Ashi 是对传统K线的平滑处理

优势：通过平滑价格数据，提供更清晰的趋势方向，减少虚假信号。
适用场景：适用于趋势跟踪策略，帮助交易者在趋势中持仓更久。

计算方法如下：


            
            
            
HA_Close = (Open + High + Low + Close) / 4
HA_Open = (前一根 HA_Open + 前一根 HA_Close) / 2
HA_High = max(High, HA_Open, HA_Close)
HA_Low = min(Low, HA_Open, HA_Close)
Heikin Ashi 本质上是一种移动平均滤波的 K 线，具有趋势持续性更强的特点。

趋势判断与信号识别

实体较大，几乎无上下影线的阳线强烈上涨趋势
实体较大，几乎无上下影线的阴线强烈下跌趋势
上下影线变长，实体缩小趋势减弱，警惕反转
实体很短，影线较长市场震荡，暂不操作

实现代码以及画图：


            javascript
            
            
/*backtest
start: 2025-05-01 00:00:00
end: 2025-06-06 00:00:00
period: 1h
basePeriod: 1h
exchanges: [{"eid":"Binance","currency":"ETH_USDT","balance":1000,"stocks":0.5}]
*/

function toHeikinAshi(records) {
    if (!records || records.length == 0) {
        return null 
    }

    let haRecords = []

    for (let i = 0; i < records.length; i++) {
        let r = records[i]
        let ha = {}

        ha.Time = r.Time
        ha.Close = (r.Open + r.High + r.Low + r.Close) / 4

        if (i === 0) {
            // 第一根 Heikin Ashi 的开盘价用普通K线的开盘价和收盘价的均值
            ha.Open = (r.Open + r.Close) / 2
        } else {
            // 后续每根的开盘价 = 上一根Heikin Ashi开盘价和收盘价均值
            ha.Open = (haRecords[i - 1].Open + haRecords[i - 1].Close) / 2
        }

        ha.High = Math.max(r.High, ha.Open, ha.Close)
        ha.Low = Math.min(r.Low, ha.Open, ha.Close)

        haRecords.push(ha)
    }

    return haRecords
}

function main() {
    let c = KLineChart({
        overlay: true
    })

    while (true) {
        let r = _C(exchange.GetRecords)
        let heikinAshiRecords = toHeikinAshi(r)
        heikinAshiRecords.forEach(function (bar, index) {
            c.begin(bar)
            c.close()
        })
        Sleep(1000)
    }
}

回测测试