VIP20
本课程属于：100-逐笔行情数据工程与接口开发 金融科技风控与量化工程 · 共 20 门相关课程，组合学习更完整。
查看所属VIP全部课程 →
← 返回所属目录 咨询 / 购买

逐笔行情分钟聚合计算实战

共计 30 章节
可可资料掘金营 · 点击在线试看
01
逐笔行情数据解析与分钟聚合目标
目标=理解逐笔成交与逐笔委托的数据结… · 字段含义 · 明确分钟聚合的计算目标与输出指标
逐笔行情数据解析分钟聚合目标
02
分钟聚合核心指标定义
掌握OHLC · 成交量 · 成交额
分钟聚合核心指标…OHLC
03
逐笔数据清洗与异常处理
识别重复记录 · 时间戳乱序 · 价格为零
逐笔数据清洗异常处理
04
时间窗口划分与对齐
实现基于自然分钟 · 滚动分钟 · 交易所时间戳的窗口划分
时间窗口划分对齐
05
逐笔成交聚合为分钟OHLC
编写聚合逻辑 · 从逐笔成交价生成每分钟开盘价 · 最高价
OHLC逐笔成交聚合为分…
06
分钟成交量与成交额聚合
按分钟累计成交数量与成交金额 · 处理撤单 · 更正记录对累计值的影响
分钟成交量成交额聚合
07
买卖方向分类与分钟净流入
基于逐笔成交的买卖方向标识或主动买卖… · 计算分钟主动买入量 · 主动卖出量与净流入
买卖方向分类分钟净流入
08
逐笔委托聚合与分钟委托统计
将逐笔委托按分钟聚合 · 计算委托笔数 · 委托量
逐笔委托聚合分钟委托统计
09
分钟聚合中的价格精度与数值稳定性
处理浮点精度 · 价格最小变动单位 · 大数累计误差
分钟聚合价格精度
10
逐笔数据乱序与延迟到达处理
设计基于事件时间与水位线的聚合机制 · 处理乱序逐笔记录并保证分钟结果最终正…
逐笔数据乱序延迟到达处理
11
分钟聚合的内存管理与数据结构选型
针对高频逐笔数据选择高效数据结构（如… · 哈希表 · 跳表）
分钟聚合的内存管…数据结构选型
12
单机分钟聚合引擎实现
从零搭建一个单线程逐笔到分钟的聚合引… · 完成数据读取 · 窗口聚合
单机分钟聚合引擎…从零搭建一个单线…
13
聚合引擎的模块化与接口设计
划分数据源 · 解析器 · 聚合器
聚合引擎的模块化接口设计
14
分钟聚合的单元测试与边界用例
针对空窗口 · 单笔成交 · 窗口边界
分钟聚合的单元测…边界用例
15
基于Pandas的逐笔分钟聚合快速实现
使用Pandas的resample与… · 对比手写引擎结果
Pandas基于
16
流式处理框架下的分钟聚合
使用Flink或Spark Stru… · 处理事件时间与窗口触发
流式处理框架下的…Flink
17
分钟聚合结果持久化与查询优化
将聚合结果写入数据库或列式存储 · 设计索引与分区 · 支持按分钟快速查询
分钟聚合结果持久…查询优化
18
分钟聚合性能剖析与优化
使用性能分析工具定位聚合热点 · 通过批处理 · 向量化
分钟聚合性能剖析优化
19
多品种逐笔并行聚合
设计按品种分区的并行聚合方案 · 处理共享状态与结果合并 · 保证线程安全与顺序性
多品种逐笔并行聚…设计按品种分区的…
20
分钟聚合中的状态管理与容错恢复
实现聚合状态的检查点与恢复机制 · 确保故障后分钟结果不重不漏
分钟聚合状态管理
21
逐笔行情回放与分钟聚合验证
搭建历史逐笔回放环境 · 将聚合结果与交易所官方分钟K线对比 · 定位差异原因
逐笔行情回放分钟聚合验证
22
分钟聚合结果的可视化与监控
绘制分钟K线图与指标曲线 · 设置聚合延迟 · 数据质量等监控告警
分钟聚合结果的可…监控
23
基于分钟聚合的简单策略信号计算
利用分钟OHLC与净流入构建均线突破 · 量价背离等信号 · 验证聚合数据可用性
基于分钟聚合的简…OHLC
24
分钟聚合中的复权与公司行为处理
处理除权除息 · 拆股等公司行为对分钟价格与成交量的影… · 实现复权聚合
分钟聚合复权
25
跨日与隔夜分钟聚合处理
处理交易日切换 · 隔夜持仓 · 开盘集合竞价对分钟聚合连续性的影响
跨日隔夜分钟聚合处理
26
分钟聚合数据质量评估体系
定义完整性 · 准确性 · 一致性
分钟聚合数据质量…定义完整性
27
大规模逐笔数据的分区聚合与合并
按时间与品种分区聚合 · 再合并分钟结果 · 处理分区边界与重复计算
大规模逐笔数据的…合并
28
分钟聚合引擎的配置化与参数调优
将窗口大小 · 聚合指标 · 清洗规则等配置化
分钟聚合引擎的配…参数调优
29
端到端实战
构建逐笔到分钟聚合的完整数据管道 · 清洗 · 聚合
端到端实战构建逐笔到分钟聚…
30
课程总结与扩展方向
回顾核心技术与实战要点 · 探讨分钟聚合在实时风控 · 算法交易等场景的扩展应用
课程总结扩展方向