(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210912546.9 (22)申请日 2022.07.30 (71)申请人 重庆长安汽车股份有限公司 地址 400023 重庆市江北区建新 东路260号 (72)发明人 朱成建　 (74)专利代理 机构 上海光华专利事务所(普通 合伙) 31219 专利代理师 唐勇 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/2458(2019.01) G06F 16/215(2019.01) G06F 16/23(2019.01) G06F 16/25(2019.01) (54)发明名称 一种时序数据整合方法、 装置、 设备及 介质 (57)摘要 本发明公开了一种时序数据整合方法， 包 括： 监听CEP规则库， 并在监测到当前CEP规则发 生更新时， 拦截当前的非确定性状态机NFA对象 的访问请求； 生成新的非确定性状态机NFA对象， 并利用所述新的非确定性状态机NFA对象替换当 前的非确定性状态机NFA； 对更新后的CEP规则库 进行解析， 得到对CEP规则库的信号集合； 从监测 的一个或多个数据流中筛选出与信号集合对应 的数据； 从与信号集合对应的数据中筛选出规则 描述事件； 从时序库中查找与描述信息关联的上 下文信息； 将描述信息与上下文信息进行整合。 本发明可以做到在不重启实时Flink(实时计算) 程序情况下， 动态加载新的匹配规则， 从而在对 数据进行处理时， 具有低延 迟、 高吞吐、 高效率的 实时响应处 理能力。 权利要求书2页 说明书8页 附图3页 CN 115145964 A 2022.10.04 CN 115145964 A 1.一种时序数据整合方法， 其特 征在于， 所述方法包括： 监听CEP规则库， 并在监测到当前CEP规则发生更新时， 拦截当前的非确定性状态机NFA 对象的访问请求， 所述C EP规则库中包括多条C EP规则； 根据更新后的CEP规则， 生成新的非确定性状态机NFA对象， 并利用所述新的非确定性 状态机NFA对象替换当前的非确定性状态机NFA； 对更新后的CEP规则库进行解析， 得到对所述CEP规则库的信号集合， 其中， 每一条CEP 规则对应一个信号； 从监测的一个或多个数据流中筛 选出与所述信号 集合对应的数据； 利用规则匹配条件， 从所述与所述信号 集合对应的数据中筛 选出规则描述事 件； 根据所述规则描述事件的描述信 息， 从时序库中查找与 所述描述信 息关联的上下文信 息； 将所述描述信息与所述上 下文信息进行整合， 并写入下游应用。 2.根据权利要求1所述的时序数据整合方法， 其特征在于， 所述CEP规则包括事件判定 基本规则和事 件的信息要素中 需要整合的数据项。 3.根据权利要求1所述的时序数据整合方法， 其特 征在于， 所述 监听CEP规则库， 包括： 由程序主动通知； 或监听CEP规则库的日志， 通过Dbus工具从日志中捕获变更数据， 从而实现对CEP规则 的监听。 4.根据权利要求1所述的时序 数据整合方法， 其特征在于， 在拦截当前的非确定性状态 机NFA对象的访问请求前， 所述方法还 包括： 保存当前 数据流的状态， 并生成新的保存点savepo int。 5.根据权利要求1所述的时序 数据整合方法， 其特征在于， 在利用所述新的非确定性状 态机NFA对象替换当前的非确定性状态机NFA前， 所述方法还 包括： 清空当前非确定性状态机NFA对象相关的中间状态存储数据， 并初始化新的非确定性 状态机NFA。 6.根据权利要求1所述的时序 数据整合方法， 其特征在于， 所述描述信 息包括规则描述 事件发生的主体以及时间， 所述上下文信息包括与所述主体相关联的信息， 所述下游应用 包括Kafka消息中间件、 数据库、 存 储介质中的至少一种。 7.一种时序数据整合装置， 其特 征在于， 所述装置包括： 监听模块， 用于监听CEP规则库， 并在监测到当前CEP规则发生更新时， 拦截当前的非确 定性状态机NFA对象的访问请求， 所述C EP规则库中包括多条C EP规则； 更新模块， 用于根据更新后的CEP规则， 生成新的非确定性状态机NFA对象， 并利用所述 新的非确定性状态机NFA对象替换当前的非确定性状态机NFA； 解析模块， 用于对更新后的CEP规则库进行解析， 得到对所述CEP规则库的信号集合， 其 中， 每一条C EP规则对应一个信号； 第一筛选模块， 用于从监测的一个或多个数据流中筛选出与所述信号集合对应的数 据； 第二筛选模块， 利用规则匹配条件， 从所述与所述信号集合对应的数据中筛选出规则 描述事件；权　利　要　求　书 1/2 页 2 CN 115145964 A 2查找模块， 用于根据所述规则描述事件的描述信息， 从时序库中查找与所述描述信息 关联的上 下文信息； 整合模块， 用于将所述描述信息与所述上 下文信息进行整合， 并写入下游应用。 8.一种电子设备， 其特 征在于， 所述电子设备包括： 一个或多个处 理器； 存储装置， 用于存储一个或多个程序， 当所述一个或多个程序被所述一个或多个处理 器执行时， 使得所述电子 设备实现如权利要求 1至6中任一项 所述的时序数据整合方法的步 骤。 9.一种计算机可读存储介质， 其特征在于， 其上存储有计算机程序， 当所述计算机程序 被计算机的处理器执行时， 使计算机执行权利要求1至6中任一项 所述的时序数据整合方法 的步骤。权　利　要　求　书 2/2 页 3 CN 115145964 A 3