(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211177127.1 (22)申请日 2022.09.26 (71)申请人 网易 （杭州） 网络有限公司 地址 310056 浙江省杭州市滨江区长河街 道网商路59 9号4幢7层 (72)发明人 徐帅　刘勇成　胡志鹏　袁思思　 程龙　 (74)专利代理 机构 北京风雅颂专利代理有限公 司 11403 专利代理师 王刚 (51)Int.Cl. G06F 16/23(2019.01) G06F 16/2455(2019.01) (54)发明名称 数据更新方法、 装置、 电子设备及存 储介质 (57)摘要 本申请提供的一种数据更新方法、 及相关设 备包括： 接收数据流； 监测当前时刻与处理函数 进程的最近历史初始化时刻之间的时间间隔； 处 理函数进程的最近历史初始化时刻为距当前时 刻最近一次成功对处理函数进程进行初始化的 时刻； 配置信息中包含处理函数进程对应的初始 化逻辑； 在监测到当前时刻与处理函数的最近历 史初始化时刻之间的时间间隔不小于预设时间 间隔阈值时从数据库的配置信息中获取处理函 数进程对应的当前初始化逻辑； 利用当前初始化 逻辑更新最近历史初始化逻辑， 并通过当前初始 化逻辑对处理函数进程进行初始化； 通过以当前 初始化逻辑初始化后的数据处理进程对数据流 进行处理， 以此提供了一种可以随时更新数据且 更新后不需要重启的方案 。 权利要求书2页 说明书12页 附图2页 CN 115544036 A 2022.12.30 CN 115544036 A 1.一种数据处理方法， 其特征在于， 应用于与数据库通信连接的数据处理引擎， 所述数 据处理引擎包 含至少一个数据处 理函数， 包括： 接收数据流； 监测当前时刻与处理函数进程的最近历史初始化时刻之间的时间间隔； 其中， 所述处 理函数进程至少用于根据从数据库的配置信息中获取的处理函数进程对应的初始化逻辑 对所述处理函数进程进行初始化； 所述处理函数进程的最近历史初始化时刻为距当前时刻 最近一次成功对所述处理函数进程进 行初始化的时刻； 所述配置信息中包含所述处理函数 进程对应的初始化逻辑； 在监测到当前时刻与所述处理函数的最近历史初始化时刻之间的时间间隔不小于预 设时间间隔阈值时， 从所述数据库的配置信息中获取所述处理函数进程对应的当前初始 化 逻辑； 利用所述当前初始化逻辑更新所述最近历史初始化逻辑， 并通过所述当前初始化逻辑 对所述处 理函数进程进行初始化； 通过以当前初始化逻辑初始化后的所述数据处 理进程对所述数据流进行处 理。 2.根据权利要求1所述的方法， 其特征在于， 所述配置信 息还包括处理函数进程对应的 处理函数标识， 所述从所述数据库的配置信息中获取所述处理函数进程对应的当前初始 化 逻辑， 包括： 根据所述处理函数进程对应的处理函数标识， 从所述数据库的配置信 息中获取所述处 理函数进程对应的当前初始化逻辑。 3.根据权利要求1或2所述的方法， 其特征在于， 所述配置信息还包括处理函数进程的 初始化参数， 通过 所述当前初始化逻辑对所述处 理函数进程进行初始化， 包括： 根据所述当前初始化逻辑对所述处理函数进程的初始化参数进行赋值， 以对所述处理 函数进程进行初始化； 通过以当前初始化逻辑初始化后的所述数据处 理进程对所述数据流进行处 理， 包括： 通过以当前初始化逻辑初始化后的所述数据处理进程中初始化参数的赋值对所述数 据流进行处 理。 4.根据权利要求3所述的方法， 其特 征在于， 所述接收数据流之前， 还 包括： 根据预设初始化逻辑对所述处 理函数进程进行 首次初始化； 响应于确定所述首次初始化成功， 接收所述数据流； 响应于确定所述首次初始化失败， 所述处 理引擎退 出登录。 5.根据权利要求1所述的方法， 其特征在于， 所述监测当前时刻与处理函数进程的最近 历史初始化时刻之间的时间 间隔， 包括： 响应于接收到所述数据流， 将接收到所述数据流的时刻作为所述当前时刻； 根据最近历史初始化 时刻， 确定接收所述数据流的当前时刻与 所述最近历史初始化 时 刻的时间 间隔。 6.根据权利要求1所述的方法， 其特 征在于， 所述方法， 还 包括： 在监测到当前时刻与所述处理函数的最近历史初始化时刻之间的时间间隔小于预设 时间间隔阈值时， 通过 所述最近历史初始化逻辑对所述处 理函数进程进行初始化； 通过以所述最近历史初始化逻辑初始化后的所述数据处理进程对所述数据流进行处权　利　要　求　书 1/2 页 2 CN 115544036 A 2理。 7.根据权利要求1所述的方法， 其特征在于， 通过如下方法更新所述最近历史初始化逻 辑和最近历史初始化时刻， 包括： 将所述当前初始化逻辑更新 为所述处 理函数进程的所述 最近历史初始化逻辑； 将所述当前初始化逻辑的更新所述处理函数进程的时刻， 作为所述最近历史初始化 时 刻。 8.根据权利要求1所述的方法， 其特 征在于， 所述方法还 包括： 响应于确定初始化失败， 恢复最近历史初始化逻辑， 并通过恢复的最近历史初始化逻 辑对所述处 理函数进程进行初始化； 通过以恢复的最近历史初始化逻辑初始化后的所述数据处理进程对所述数据流进行 处理。 9.一种数据 更新装置， 其特征在于， 应用于与数据库通信连接的数据处理引擎， 所述数 据处理引擎包 含至少一个数据处 理函数， 包括： 接收模块， 被 配置为接收数据流； 第一监测模块， 被配置为监测当前时刻与处理函数进程的最近历史初始化 时刻之间的 时间间隔； 其中， 所述处理函数进程至少用于根据从数据库的配置信息中获取 的处理函数 进程对应的初始 化逻辑对所述处理函数进程进行初始化； 所述处理函数进程的最近历史初 始化时刻为距当前时刻最近一次成功对所述处理函数进程进 行初始化的时刻； 所述配置信 息中包含所述处 理函数进程对应的初始化逻辑； 第二监测模块， 被配置为在监测到当前时刻与 所述处理函数的最近历史初始化时刻 之 间的时间间隔不小于预设时间间隔阈值时， 从所述数据库的配置信息中获取所述处理函数 进程对应的当前初始化逻辑； 初始化模块， 被配置为利用所述当前初始化逻辑更新所述最近历史初始化逻辑， 并通 过所述当前初始化逻辑对所述处 理函数进程进行初始化； 处理模块， 被配置为通过以当前初始化逻辑初始化后的所述数据处理进程对所述数据 流进行处 理。 10.一种电子设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计算 机程序， 其特征在于， 所述处理器执行所述程序时实现如权利要求1至8任意一项所述的方 法。 11.一种计算机可读存储介质， 其特征在于， 所述计算机可读存储介质存储计算机指 令， 所述计算机指令用于使所述计算机执 行权利要求1至8任一所述方法。权　利　要　求　书 2/2 页 3 CN 115544036 A 3