买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉浪潮云洲工业互联网有限公司申请的专利一种工业制造实时流处理方法、设备及介质获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN121029441B 。

龙图腾网通过国家知识产权局官网在2026-03-17发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202511575823.1，技术领域涉及：G06F9/50；该发明授权一种工业制造实时流处理方法、设备及介质是由许晋瑞;来健强;王永宗;齐光鹏设计研发完成，并于2025-10-31向国家知识产权局提交的专利申请。

本一种工业制造实时流处理方法、设备及介质在说明书摘要公布了：本申请公开了一种工业制造实时流处理方法、设备及介质，涉及数据处理领域，解决数据时间乱序以及消息堆积问题。方法包括：根据业务主题标识字段，将业务数据拆分为对应子队列；根据预设时间窗口，将各子队列划分为预设规格批次。对每个批次每条数据，提取维度键、唯一键、时间标识，封装为第一元组；根据维度键分组生成数据组，依预设规则拼接每组唯一键的组标识，与数据组封装为第二元组。根据组标识对第二元组哈希分区，拆分各分区第二元组为单条数据，依时间顺序计算指标。本申请通过按标识组合拆分消息队列、提取维度键等三维标识分组、拼唯一键哈希分区，保证实时流数据按时间顺序处理，同时高效完成实时指标计算，提升处理效率。

本发明授权一种工业制造实时流处理方法、设备及介质在权利要求书中公布了：1.一种工业制造实时流处理方法，其特征在于，所述方法包括： 根据业务主题标识字段，将业务数据的原始消息队列拆分为不同业务主题的子消息队列； 根据预设的时间窗口，将每个子消息队列划分为预设规格的批次； 对每个批次中的每条数据提取维度键、唯一键和时间标识，并将所述维度键、唯一键、时间标识以及对应数据封装为第一元组；所述维度键包括实时指标计算依赖；所述唯一键包括每条数据的唯一标识符； 根据所述维度键对所有第一元组进行分组，生成数据组；其中同一数据组内的所有第一元组具有相同的维度键； 根据预设的拼接规则，分别将每个数据组中所有第一元组的唯一键进行拼接，生成每个数据组唯一的组标识，并将所述组标识与对应数据组的所有第一元组进行封装，生成每个数据组对应的第二元组； 根据所述组标识，对所有第二元组进行哈希分区，以使具有相同组标识的第二元组被分配至同一分区； 将每个分区的第二元组拆分为单条消息数据，并根据时间顺序对单条消息数据进行指标计算，得到指标计算结果； 根据所述维度键对所有第一元组进行分组，生成数据组，具体包括： 提取所述维度键中实时指标计算依赖的维度属性对应的属性值； 根据预设的顺序将所述属性值进行排列，并使用预设的分隔符进行拼接，生成复合字符串； 对比所有第一元组的复合字符串，以将相同复合字符串的第一元组分为同一数据组； 根据预设的拼接规则，分别将每个数据组中所有第一元组的唯一键进行拼接，生成每个数据组唯一的组标识，具体包括： 对同一数据组内的第一元组，根据时间标识进行排序，并依次提取排序后的每个第一元组中的唯一键； 根据所述第一元组的排序顺序，通过预设连接符，将提取的所有唯一键进行首尾拼接，生成唯一的字符串标识，并将所述字符串标识确定为组标识； 对每个批次中的每条数据提取维度键、唯一键和时间标识，具体包括： 根据实时指标计算的数据依赖关系，确定每条数据中参与计算的维度属性集合；根据所述维度属性集合，从数据字段中提取对应的属性值，并根据预设的映射规则生成维度键；从每条数据包含的字段中提取能够全局唯一标识数据记录的键值，将所述键值确定为唯一键；提取每条数据的数据产生时间信息，将所述数据产生时间信息转换为标准化的时间戳格式，确定为时间标识。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人浪潮云洲工业互联网有限公司，其通讯地址为：250100 山东省济南市高新区浪潮路1036号浪潮科技园S02号楼19层；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。