(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210516106.1 (22)申请日 2022.05.12 (71)申请人 平安科技 （深圳） 有限公司 地址 518000 广东省深圳市福田区福田街 道福安社区益田路5033号平 安金融中 心23楼 (72)发明人 邓小龙　李松春　张登峰　 (74)专利代理 机构 深圳国新 南方知识产权代理 有限公司 4 4374 专利代理师 周纯 (51)Int.Cl. G06Q 10/06(2012.01) G06Q 10/10(2012.01) G06F 16/242(2019.01) G06F 16/2455(2019.01) (54)发明名称 数据实时处理方法、 装置、 服务器及存储介 质 (57)摘要 本申请的数据实时处理方法、 装置、 服务器 及存储介质， 获取规则流数据； 根据规则流数据 生成对应的查询任务算子； 获取业务流数据， 将 业务流数据发送至相关联的至少一个查询任务 算子； 根据查询任务算子构建对应的实时计算任 务， 执行实时计算任务以根据所述业务数据流获 取对应的中间计算结果； 根据中间计算结果确定 是否触发对应的预设事件； 通过上述方式， 将不 同查询规则分别对应不同查询任务算子， 针对业 务流数据在相关的每个查询任务算子上进行处 理， 每一次的业务流数据的实时计算量小， 中间 计算结果是每一步实时计算的不断积累， 提高了 业务规则的数据查询响应速度， 当业务规则较多 时， 无需短时间内循环遍历所有业务规则， 数据 库的并发查询压力小。 权利要求书2页 说明书10页 附图4页 CN 114912795 A 2022.08.16 CN 114912795 A 1.一种数据实时处 理方法， 其特 征在于， 包括： 获取规则流数据， 所述 规则流数据包括至少一个查询规则； 根据所述 规则流数据生成对应的查询任务 算子； 获取业务流数据， 将所述 业务流数据发送至相关联的至少一个所述 查询任务 算子； 根据所述查询任务算子构建对应的实时计算任务， 执行所述实时计算任务以根据 所述 业务数据流获取对应的中间计算结果； 根据所述中间计算结果确定是否触发对应的预设事 件。 2.根据权利要求1所述的数据实时处理方法， 其特征在于， 执行所述实时计算任务以根 据所述业务数据流获取对应的中间计算结果， 包括： 获取所述查询任务 算子的历史中间计算结果； 根据所述实时计算任务的所述查询规则， 将所述业务流数据以及所述历史中间计算结 果进行叠加计算， 得到所述中间计算结果。 3.根据权利要求2所述的数据实时处理方法， 其特征在于， 所述根据所述规则流数据生 成对应的查询任务 算子之后， 还 包括： 获取与所述 查询任务 算子相关的历史数据； 根据所述查询任务算子构建对应的汇总计算任务， 执行所述汇总计算任务以根据 所述 历史数据获取对应的汇总计算结果， 作为所述历史中间计算结果。 4.根据权利要求1所述的数据实时处理方法， 其特征在于， 所述获取业务流数据， 将所 述业务流数据发送至相关联的至少一个所述 查询任务 算子， 包括： 接收所述 业务流数据， 其中， 所述 业务流数据包括实时业 务订单数据； 根据接收到的所述实时业 务订单数据生成对应的业 务数据集； 将所述业务数据集发送至相关联的至少一个所述 查询任务 算子。 5.根据权利要求1所述的数据实时处理方法， 其特征在于， 所述根据所述查询任务算子 构建对应的实时计算任务， 执行所述 实时计算任务以根据所述业务数据流获取对应的中间 计算结果之后， 还 包括： 根据所述中间计算结果生成对应的中间数据集， 将所述中间数据集发送至分布式消息 系统， 以将所述中间数据集作为所述 业务流数据。 6.根据权利要求1所述的数据实时处理方法， 其特征在于， 所述根据所述规则流数据生 成对应的查询任务 算子， 包括： 对所述规则流数据进行解析， 得到解析后的规则流数据； 根据所述 解析后的规则流数据生成对应的计算 规则信息； 创建所述查询任务算子， 将所述计算规则信 息添加至所述查询任务算子的规则数据集 中。 7.根据权利要求1所述的数据实时处理方法， 其特征在于， 所述根据所述中间计算结果 确定是否触发对应的预设事 件， 包括： 若所述中间计算结果大于或等于预设的目标阈值， 则触发对应的所述预设时间； 若所述中间计算结果小于预设的所述目标阈值， 则将所述中间计算结果作为所述查询 任务算子的历史中间计算结果进行存 储。 8.一种数据实时处 理装置， 其特 征在于， 包括：权　利　要　求　书 1/2 页 2 CN 114912795 A 2第一接收模块， 用于获取规则流数据， 所述 规则流数据包括至少一个查询规则； 创建模块， 用于根据所述 规则流数据生成对应的查询任务 算子； 第二接收模块， 用于获取业务流数据， 将所述业务流数据发送至相关联的至少一个所 述查询任务 算子； 计算模块， 用于根据所述查询任务算子构建对应的实时计算任务， 执行所述实时计算 任务以根据所述 业务数据流获取对应的中间计算结果； 触发模块， 用于根据所述中间计算结果确定是否触发对应的预设事 件。 9.一种服务器， 其特征在于， 包括存储器、 处理器以及存储在所述存储器中并可在所述 处理器上运行 的计算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现如权利 要求1至7中任一项所述数据实时处 理方法的步骤。 10.一种计算机可读存储介质， 所述计算机可读存储介质存储有计算机程序， 其特征在 于， 所述计算机程序被处理器执行时实现如权利要求 1至7中任一项 所述数据实时处理方法 的步骤。权　利　要　求　书 2/2 页 3 CN 114912795 A 3