首页/ 中节能晶和智慧城市科技（浙江）有限公司/ 专利详情

一种基于流式处理的物联网平台消息处理方法和系统

基本信息

申请号 CN202111397905.3 申请日 -
公开（公告）号 CN113821361A 公开（公告）日 2021-12-21
申请公布号 CN113821361A 申请公布日 2021-12-21
分类号 G06F9/54（2006.01）I;G06F16/2455（2019.01）I;G16Y10/75（2020.01）I;G16Y20/40（2020.01）I;G16Y40/10（2020.01）I 分类 计算；推算；计数;
发明人 王鹏;张伟杰;姜凌青;费晨杰 申请（专利权）人 中节能晶和智慧城市科技（浙江）有限公司
代理机构 杭州宇信联合知识产权代理有限公司 代理人 王健
地址 310000 浙江省杭州市萧山区宁围街道利一路188号天人大厦3002-23
法律状态 -

摘要

摘要 本发明提供了一种基于流式处理的物联网平台消息处理方法，包括：物联网平台数据接入服务接收设备上报的数据，并将设备上报的原始数据推送到保存消息的消息中间件；设置配置有第一类处理规则的前置流式处理结点，对保存在消息中间件的原始数据拆分成以指定特征信息为划分依据的消息分支，然后将各消息分支再次保存至消息中间件；设置配置有第二类处理规则的后置流式处理结点，对消息中间件中的每个消息分支进行处理，并将处理完的结果保存至数据库或者继续流转到下一个消息中间件；重复此过程直至处理完的数据满足预设业务需求。本发明的方法，在提高物联网平台处理消息的高效性和实时性的同时能够支持用户根据业务自定义配置流式处理规则。