(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210791076.5 (22)申请日 2022.07.05 (71)申请人 湖南快乐阳光互动娱乐传媒有限公 司 地址 410003 湖南省长 沙市开福区湖南国 际会展中心北四楼 (72)发明人 张子穆　彭一　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 张影 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/242(2019.01) G06F 16/2453(2019.01) G06F 17/15(2006.01)G06F 17/18(2006.01) (54)发明名称 一种数据处 理方法及装置 (57)摘要 本申请提供了一种数据处理方法及装置， 该 方法包括： 在第一设定时长的时窗内， 在获取到 一条数据时， 确定数据中是否存在与预先设定的 事件的主体键相匹配的字段； 若存在， 将数据发 送给主体键对应的指标计算器； 指标计算器基于 数据和指标计算器在数据到达 之前， 计算得到的 历史指标值， 计算得到当前指标值； 每隔第二设 定时长计算一次时窗内的当前指标值的中间结 果， 并存储中间结果， 第二设定时长小于所述第 一设定时长 。 权利要求书2页 说明书10页 附图4页 CN 115129756 A 2022.09.30 CN 115129756 A 1.一种数据处 理方法， 其特 征在于， 包括： 在第一设定时长的时窗内， 在获取到一条数据时， 确定所述数据中是否存在与预先设 定的事件的主体键相匹配的字段； 若存在， 将所述数据发送给 所述主体键对应的指标计算器； 所述指标计算器基于历史指标值， 确定当前指标值， 所述历史指标值为基于所述数据 和所述指标计算器在所述数据到 达之前计算得到的； 每隔第二设定时长计算一 次所述时窗内所述当前指标值的中间结果， 并存储所述中间 结果， 所述第二设定时长小于所述第一设定时长 。 2.根据权利要求1所述的方法， 其特 征在于， 所述存 储所述中间结果， 包括： 存储在当前时刻 之前的第 三设定时长内计算得到的所述中间结果， 所述第 三设定时长 基于所述第一设定时长确定得到， 所述第三设定时长大于所述第一设定时长 。 3.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 响应指标值查询 请求， 判断所述指标值查询 请求中查询时间段与所述第 一设定时长是 否一致； 若一致， 将所述时窗内的所述中间结果返回给用户； 若不一致， 则基于所述时窗内的所述中间结果， 确定在所述 查询时间段内的中间结果； 对在所述查询时间段内的中间结果进行聚合处理， 得到聚合结果， 并返回所述聚合结 果给用户。 4.根据权利要求3所述的方法， 其特征在于， 所述对在所述查询时间段内的中间结果进 行聚合处 理， 得到聚合结果， 包括： 若所述中间结果为计数指标类型的中间结果， 则对在所述查询时间段内的中间结果进 行累加， 得到累加结果。 5.根据权利要求3所述的方法， 其特征在于， 所述对在所述查询时间段内的中间结果进 行聚合处 理， 得到聚合结果， 包括： 若所述中间结果为最小值指标类型、 最大值指标类型、 均值指标类型或方差指标类型 的中间结果， 则从在所述查询时间段内的中间结果中选取一个未 处理中间结果作为历史中 间结果； 从在所述查询时间段内的中间结果中选择一个不同于所述历史中间结果的未处理中 间结果， 基于所述历史中间结果和 不同于所述历史中间结果的未处理中间结果， 计算得到 待使用中间结果； 将所述待使用中间结果作为所述历史中间结果， 返回执行所述从在所述查询时间段内 的中间结果中选择一个不同于所述历史中间结果的未处 理中间结果的步骤。 6.一种数据处 理装置， 其特 征在于， 包括： 第一确定模块， 用于在第 一设定时长的时窗内， 在获取到一条数据时， 确定所述数据中 是否存在与预 先设定的事 件的主体键相匹配的字段； 第一发送模块， 用于若所述数据中存在与预先设定的事件的主体键匹配的字段， 则将 所述数据发送给 所述主体键对应的指标计算模块； 所述指标计算模块， 用于基于所述数据和所述指标计算器在所述数据到达之前， 计算 得到的历史指标值， 计算得到当前指标值；权　利　要　求　书 1/2 页 2 CN 115129756 A 2中间结果计算模块， 用于每隔第 二设定时长计算一 次所述时窗内所述当前指标值的中 间结果， 所述第二设定时长小于所述第一设定时长； 存储模块， 用于存 储所述中间结果。 7.根据权利要求6所述的装置， 其特 征在于， 所述存 储模块， 具体用于： 存储在当前时刻 之前的第 三设定时长内计算得到的所述中间结果， 所述第 三设定时长 基于所述第一设定时长确定得到， 所述第三设定时长大于所述第一设定时长 。 8.根据权利要求6所述的装置， 其特 征在于， 所述装置还 包括： 判断模块， 用于响应指标值查询请求， 判断所述指标值查询请求中查询时间段与所述 第一设定时长是否一 致； 第一返回模块， 用于若一 致， 则将所述时窗内的所述中间结果返回给用户； 第二确定模块， 用于若不一致， 则 基于所述 时窗内的所述中间结果， 确定在所述查询时 间段内的中间结果； 聚合模块， 用于对在所述 查询时间段内的中间结果进行聚合处 理， 得到聚合结果； 第二返回模块， 用于返回所述聚合结果给用户。 9.根据权利要求8所述的装置， 其特 征在于， 所述聚合模块， 具体用于： 若所述中间结果为计数指标类型的中间结果， 则对在所述查询时间段内的中间结果进 行累加， 得到累加结果。 10.根据权利要求8所述的装置， 其特 征在于， 所述聚合模块， 具体用于： 若所述中间结果为最小值指标类型、 最大值指标类型、 均值指标类型或方差指标类型 的中间结果， 则从在所述查询时间段内的中间结果中选取一个未 处理中间结果作为历史中 间结果； 从在所述查询时间段内的中间结果中选择一个不同于所述历史中间结果的未处理中 间结果， 基于所述历史中间结果和 不同于所述历史中间结果的未处理中间结果， 计算得到 待使用中间结果； 将所述待使用中间结果作为所述历史中间结果， 返回执行所述从在所述查询时间段内 的中间结果中选择一个不同于所述历史中间结果的未处 理中间结果的步骤。权　利　要　求　书 2/2 页 3 CN 115129756 A 3