摘要
本申请公开了一种分布式多路行情的处理方法及系统,涉及数据处理领域,包括:接收多路行情数据;选择时延最小的一路行情数据作为最优行情数据;通过添加最优行情数据的基础信息;根据基础信息,通过查询证券数据库,获取与证券代码相对应的补充信息;根据补充信息和包含基础信息的最优行情数据,生成证券静态数据;根据包含基础信息的最优行情数据,生成对应的K线数据和衍生数据;通过行情推送服务利用流式订阅,从消息队列服务中订阅包含基础信息的最优行情数据、K线数据和衍生数据;针对现有技术中多路行情数据处理时延大,本申请通过多个接入点接收多路行情数据,选择时延最小的一路作为最优行情数据等,降低了行情数据的处理时延。
技术关键词
滑动窗口
指标
消息队列服务
分布式时序数据库
序列
基础
数据库查询接口
扩展算法
列式存储数据
内存计算技术
队列数据结构
数据处理时延
分布式跟踪
主题
GO语言
指数
游程编码
系统为您推荐了相关专利信息
智能识别算法
学习能力评估
样本
评估指标体系
曲线