毕昇云技术有限公司

本申请公开了一种基于云边协同的物联网数据实时处理方法及系统。该方法包括：通过数据接入网关将物联网设备原始数据转换为标准化数据并写入云端流式数据通道；云端按时间窗口生成数据处理任务并划分为具有执行依赖关系的多个处理阶段，在规则版本改变时保持已开始执行任务使用的规则版本；根据缓存队列长度调节数据写入速率，根据任务优先级和等待时长确定任务处理顺序，并根据任务规则版本号和节点负载值确定目标计算节点；全部处理阶段完成后，合并阶段处理结果并更新物联网设备的云端状态。该方案有助于使数据写入调节、规则版本管理、处理阶段调度和结果更新相互衔接，提高物联网实时数据处理过程的连续性。

本申请公开了一种基于微服务架构的多源数据融合处理方法及系统，涉及多源数据融合处理技术领域。该方法包括：采集多个数据源的源数据并记录数据源标识及采集时间，依据数据源标识写入对应的数据传输通道，获取背压水位、一致性检测结果和数据源连接情况，生成通道状态记录；将源数据标准化并生成目标融合组标识，依据融合映射关系和通道状态记录生成融合处理记录，将其标记为直接融合状态或延迟融合状态；聚合直接融合状态的融合处理记录并按时间优先写入规则更新目标融合数据对象，在延迟融合状态的融合处理记录对应的通道状态满足融合准入条件时执行目标字段写入。本申请可降低数据传输状态变化对融合过程的影响，提高多源数据融合的可靠性。