(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210503335.X (22)申请日 2022.05.10 (71)申请人 国泰君安证券股份有限公司 地址 200041 上海市 静安区南京西路768号 国泰君安大厦20层 (72)发明人 俞枫　曾宏祥　毛梦非　王厦　 冯一欣　吴康　叶璞钰　朱晓云　 (74)专利代理 机构 上海智信专利代理有限公司 31002 专利代理师 王洁　郑暄 (51)Int.Cl. G06F 16/215(2019.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) (54)发明名称 基于动态优先级实现高速数据补维处理的 方法、 装置、 处 理器及其计算机可读存 储介质 (57)摘要 本发明涉及一种基于动态优先级实现高速 数据补维处理的方法， 包括以下步骤： 搭建动态 补维系统； 根据动态补维系统进行补维， 补维操 作模块获取实时处理数据流内的数据， 根据获取 的数据查找补维数据缓存， 若补维数据缓存命中 且没有被污染， 则补维操作模块根据补维相关数 据完成补维操作并将结果放入实时处理数据流； 若缓存没有命中， 则将数据放入待补维队列， 设 置待补维处理模块监控所述的待补维队列； 若缓 存命中且污染标识模块指示数据被污染， 则查找 补维策略， 根据补维策略进行补维处理。 采用了 本发明的基于动态优先级实现高速数据补维处 理的方法、 装置、 处理器及其计算机可读存储介 质， 通过单独的待补维队列实时刷新缓存， 提高 补维效率， 保证补维准确度。 权利要求书2页 说明书6页 附图1页 CN 114840512 A 2022.08.02 CN 114840512 A 1.一种基于动态优先级实现高速数据补维处理的方法， 其特征在于， 所述的方法包括 以下步骤： (1)搭建动态补维系 统， 所述的动态补维系统包括原始数据源、 补维数据缓存、 补维操 作模块和实时处理数据流， 所述的补维数据缓存包括补维相关缓存数据、 污染标识模块和 污染时间； (2)根据动态补维系统进行补维， 补维操作模块获取实时处理数据流内的数据， 根据获 取的数据查找补维数据缓存， 若补维数据缓存命中且没有被污染， 则继续步骤(3)； 若缓存 没有命中， 则继续 步骤(4)； 若缓存 命中且污染标识模块指示数据被污染， 则继续 步骤(5)； (3)补维操作模块 根据补维相关数据完成补维操作并将结果 放入实时处 理数据流； (4)将数据放入待补维队列， 设置待补维处理模块监控所述的待补维队列， 若待补维队 列内有数据， 则待补维处 理模块对数据进行处 理； (5)查找补维策略， 根据补维策略进行补维处 理。 2.根据权利要求1所述的基于动态优先级实现高速数据补维处理 的方法， 其特征在于， 所述的步骤(4)的待补维处 理模块对数据进行处 理的步骤具体包括以下处 理过程： 根据数据查询原始数据源内的相关数据， 完成补维并将结果放入所述实时处理数据 流， 若所述原始数据源内没有相关数据， 则将该数据加入所述补维数据缓存中补维相关缓 存数据内。 3.根据权利要求1所述的基于动态优先级实现高速数据补维处理 的方法， 其特征在于， 所述的步骤(5)中的补维策略包括速度优先和准确度优先， 如果补维策略为速度优 先， 则使 用被污染的数据进行补维； 如果补维策略为 准确度优先， 则继续 步骤(4)。 4.根据权利要求3所述的基于动态优先级实现高速数据补维处理 的方法， 其特征在于， 所述的步骤(5)中的补维策略还包括判断时间t内的数据速度优先的策略， 若污染时间在判 断时间t内， 则使用被污染的数据进行补维， 否则继续 步骤(4)。 5.根据权利要求1所述的基于动态优先级实现高速数据补维处理 的方法， 其特征在于， 所述的步骤(1)的污染标识模块内包含污染标识信息， 根据补维相关缓存数据与原始数据 源是否发生变化 来进行判断， 所述的污染标识信息包括已经污染和没有污染。 6.根据权利要求5所述的基于动态优先级实现高速数据补维处理 的方法， 其特征在于， 所述的动态补维系统还 包括监控模块， 用于监控原 始数据源的变更。 7.根据权利要求6所述的基于动态优先级实现高速数据补维处理 的方法， 其特征在于， 在原始数据源发生变化时， 监控模块将补维数据缓存中对应补维相关缓存 数据的污染标识 模块进行刷新， 如果污染标识模块内的污染标识信息为已经污染， 则不作操作； 如果污染标 识信息为没有污染， 则改变污染标识信息为已经污染， 并记录改变时间形成污染时间。 8.一种用于实现基于动态优先级的高速数据补维处理的装置， 其特征在于， 所述的装 置包括： 处理器， 被配置成执 行计算机可 执行指令； 存储器， 存储一个或多个计算机可执行指令， 所述的计算机可执行指令被所述的处理 器执行时， 实现权利要求 1至7中任一项 所述的基于动态优先级实现高速数据补维处理的方 法的各个步骤。 9.一种用于实现基于动态优先级的高速数据补维处理的处理器， 其特征在于， 所述的权　利　要　求　书 1/2 页 2 CN 114840512 A 2处理器被配置成执行计算机可执行指令， 所述的计算机可执行指令被所述的处理器执行 时， 实现权利要求 1至7中任一项 所述的基于动态优先级实现高速数据补维处理的方法的各 个步骤。 10.一种计算机可读存储介质， 其特征在于， 其上存储有计算机程序， 所述的计算机程 序可被处理器执行以实现权利要求1至7中任一项所述的基于动态优先级实现高速数据补 维处理的方法的各个步骤。权　利　要　求　书 2/2 页 3 CN 114840512 A 3