流式数据处理方法、规则插件、流式数据处理模块及系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114265866A(43)申请公布日2022.04.01(21)申请号202111405082.4(22)申请日2021.11.24(71)申请人青岛海尔科技有限公司地址266101山东省青岛市崂山区海尔路1号海尔工业园申请人海尔智家股份有限公司(72)发明人董一博(74)专利代理机构北京路浩知识产权代理有限公司11002代理人聂俊伟(51)Int.Cl.G06F16/2455(2019.01)G06F16/242(2019.01)G06F9/445(2018.01)权利要求书2页说明书14页附图4页(54)发明名称流式数据处理方法、规则插件、流式数据处理模块及系统(57)摘要本发明提供一种流式数据处理方法、规则插件、流式数据处理模块及系统，该方法包括：响应于流式数据处理模块的触发，获取待处理流式数据对应的原始业务规则；基于待处理流式数据的数据源类型，对原始业务规则进行解析，获取与待处理流式数据的数据源类型匹配的目标业务规则，以使得流式数据处理模块基于目标业务规则，对待处理流式数据进行处理。本发明提供的流式数据处理方法、规则插件、流式数据处理模块及系统，能基于与流式数据处理模块无缝集成的规则插件，在进行流式数据处理时实现不同语言的业务规则的动态加载，能实现远程调用或跨平台调用业务规则，能更灵活、更高效和更简单的实现业务规则的动态加载，能提高海量流式数据的处理效率。CN114265866ACN114265866A权利要求书1/2页1.一种流式数据处理方法，其特征在于，包括：响应于流式数据处理模块的触发，获取待处理流式数据对应的原始业务规则；基于待处理流式数据的数据源类型，对所述原始业务规则进行解析，获取与所述待处理流式数据的数据源类型匹配的目标业务规则，以使得所述流式数据处理模块基于所述目标业务规则，对所述待处理流式数据进行处理。2.根据权利要求1所述的流式数据处理方法，其特征在于，所述获取待处理流式数据对应的原始业务规则，包括：基于所述待处理流式数据的特征信息，从业务规则模块调取所述待处理流式数据对应的原始业务规则；其中，所述业务规则模块，用于存储业务规则；所述业务规则，包括所述原始业务规则；所述业务规则的语言为目标语言。3.根据权利要求2所述的流式数据处理方法，其特征在于，所述基于待处理流式数据的数据源类型，对所述原始业务规则进行解析，获取与所述待处理流式数据的数据源类型匹配的目标业务规则，包括：基于目标协议对所述原始业务规则进行解析，获取与所述待处理流式数据的数据源类型匹配的目标业务规则；其中，所述目标协议，与所述目标语言和所述待处理流式数据的数据源类型相对应。4.根据权利要求2所述的流式数据处理方法，其特征在于，所述业务规则模块，还可以用于对所述业务规则进行更新。5.根据权利要求4所述的流式数据处理方法，其特征在于，所述基于待处理流式数据的数据源类型，对所述原始业务规则进行解析，获取与所述待处理流式数据的数据源类型匹配的目标业务规则之后，所述方法还包括：在所述业务规则模块对所述业务规则进行更新的情况下，获取更新后的原始业务规则，并基于所述待处理流式数据的数据源类型，对所述更新后的原始业务规则进行解析，获取与所述待处理流式数据的数据源类型匹配的更新后的目标业务规则，以使得所述流式数据处理模块基于所述更新后的目标业务规则，对所述待处理流式数据进行处理。6.根据权利要求2至5任一所述的流式数据处理方法，其特征在于，所述响应于流式数据处理模块的触发，获取待处理流式数据对应的原始业务规则之前，所述方法还包括：基于所述目标语言进行初始化。7.一种流式数据处理方法，其特征在于，包括：获取待处理流式数据；触发规则插件获取所述待处理流式数据对应的原始业务规则，并基于所述待处理流式数据的数据源类型，对所述原始业务规则进行解析，获取与所述待处理流式数据的数据源类型匹配的目标业务规则；接收所述规则插件发送的所述目标业务规则，并基于所述目标业务规则，对所述待处理流式数据进行处理。8.根据权利要求7所述的流式数据处理方法，其特征在于，所述基于所述目标业务规则，对所述待处理流式数据进行处理，包括：基于所述目标业务规则，对所述待处理流式数据进行数据源演变，获取所述待处理流2CN114265866A权利要求书2/2页式数据的数据处理结果；相应地，所述基于所述目标业务规则，对所述待处理流式数据进行处理之后，所述方法还包括：将所述数据处理结果存储至所述数据处理结果的数据源类型对应的数据存储模块。9.一种规则插件，其特征在于，包括：规则获取模块，用于响应于流式数据处理模块的触发，获取待处理流式数据对应的原始业务规则；规则解析模块，用于基于待处理流式数据的数据源类型，对所述原始业务规