股票20点倍数波动K线拆分需求及代码问题咨询

核心处理逻辑 #

针对单次大幅波动的Tick数据，按20点固定间隔拆分完整K线，直接忽略不足20点的剩余波动部分，确保每根生成的K线开盘价与收盘价差值严格为20点。

具体实现步骤 #

1. 波动拆分规则落地 #

遍历Tick数据时，维护当前待生成K线的起始价格current_open：

• 当最新Tick价格与current_open的差值绝对值≥20时，计算可拆分的完整20点K线数量：可拆分数量 = 差值绝对值 // 20
• 根据涨跌方向生成每根拆分K线：
  • 上涨行情：每根K线开盘=前一根收盘价，收盘=开盘+20，最高价=收盘，最低价=开盘
  • 下跌行情：每根K线开盘=前一根收盘价，收盘=开盘-20，最高价=开盘，最低价=收盘
• 更新current_open为最后一根拆分K线的收盘价，剩余不足20点的波动暂存，等待后续Tick继续累积（若后续无足够波动则直接丢弃）

2. 代码修改示例 #

替换原有处理Tick的逻辑，加入拆分逻辑：

import pandas as pd

def split_tick_to_kline(tick_data):
    kline_results = []
    current_base_price = None

    for _, tick in tick_data.iterrows():
        tick_price = tick['price']
        tick_time = tick['timestamp']

        if current_base_price is None:
            current_base_price = tick_price
            continue

        price_gap = tick_price - current_base_price
        abs_gap = abs(price_gap)

        if abs_gap >= 20:
            # 计算可生成的完整20点K线数
            bar_count = abs_gap // 20
            # 判断涨跌方向
            direction = 1 if price_gap > 0 else -1

            for _ in range(bar_count):
                bar_close = current_base_price + direction * 20
                # 生成符合要求的K线数据
                kline = {
                    'timestamp': tick_time,
                    'abertura': current_base_price,
                    'fechamento': bar_close,
                    'maximo': max(current_base_price, bar_close),
                    'minimo': min(current_base_price, bar_close)
                }
                kline_results.append(kline)
                # 更新基准价为当前K线收盘价
                current_base_price = bar_close

    # 最后不足20点的波动直接忽略，不生成K线
    return pd.DataFrame(kline_results)

3. Excel与图表修正 #

• 用上述函数生成合规K线数据后，再写入Excel，此时abertura与fechamento的差值严格为20点
• 生成K线图时，直接使用修正后的字段即可解决图表异常问题

注意事项 #

• 拆分时必须只保留完整的20点K线，剩余零头坚决丢弃，不能凑出不符合要求的K线
• 确保Tick数据按时间顺序排列，否则拆分逻辑会出现错误
• 拆分后的K线时间戳可沿用触发拆分的Tick时间，若需要更精准的区间时间，可根据Tick的时间间隔做调整

内容的提问来源于stack exchange，提问作者Nilton Schumacher F