(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210555190.8 (22)申请日 2022.05.19 (71)申请人 宁波奥克斯电气股份有限公司 地址 315100 浙江省宁波市 鄞州区姜 山镇 明光北路1 166号 申请人 奥克斯空调股份有限公司 (72)发明人 朱文超　 (74)专利代理 机构 浙江中桓凯通专利代理有限 公司 33376 专利代理师 刘潇 (51)Int.Cl. G06F 16/2455(2019.01) G06F 16/2453(2019.01) G06F 16/215(2019.01) G06F 16/28(2019.01) (54)发明名称 空调器的大数据实时分析方法、 系统、 存储 介质和空调器 (57)摘要 本发明提供了一种空调器的大数据实时分 析方法、 系统、 存储介质和空调器， 所述大数据实 时分析方法基于Spark框架， 且大数据实时分析 方法包括： 获取信息存储库中的信息数据； 将所 述信息数据通过流处理平台集群转换成数据流； 将所述数据流转换为样例类缓存至缓存数据库； 当运行关联程序时， 控制对缓存于所述缓存数据 库中的多个所述样例类进行关联处理。 本发明解 决的技术问题是当需要关联数据流与数据流时， 需要从主库中查询与之关联的数据流， 而大数据 环境下数据流与数据流之间的交互存在很高的 延迟， 导致无法满足高时效性的需求。 权利要求书2页 说明书6页 附图4页 CN 114860774 A 2022.08.05 CN 114860774 A 1.一种空调器的大数据实时分析方法， 所述大数据实时分析方法基于Spark框架； 其特 征在于， 所述大 数据实时分析 方法包括： 获取信息存 储库中的信息数据； 将所述信息数据通过流处 理平台集群转换成数据流； 将所述数据流 转换为样例类缓存至缓存数据库； 当运行关联程序时， 查询所述缓存数据库中的样例类与相应的所述数据流关联处 理。 2.根据权利要求1所述的大数据实时分析方法， 特征在于， 所述查询所述缓存数据库中 的样例类与相应的所述数据流关联处 理： 判断所述样例类是否满足关联 条件； 若否， 则将所述样例类转换为Jso n数据， 并将所述Jso n数据缓存于所述缓存数据库。 3.根据权利要求2所述的大数据实时分析方法， 其特征在于， 所述判断所述样例类是否 满足关联 条件包括： 若所述数据流包括设备 日志数据流或设备业务数据流中的任一者 时， 判断所述缓存数 据库中是否存储有与所述设备日志数据流或所述设备业务数据流中的另一者相对应的 Json数据； 其中， 若判断所述缓存数据库中存储有与 所述设备 日志数据流或所述设备业务数据流 中的另一者相对应的Json数据， 则判断所述数据流满足关联条件， 将所述设备日志数据流 和所述设备业 务数据流组合成设备明细写入关联集 合。 4.根据权利要求2或3所述的大数据实时分析方法， 其特征在于， 所述判断所述数据流 是否满足关联 条件包括： 若所述数据流包括设备日志数据流和设备业 务数据流时， 判断满足所述关联 条件； 将所述设备日志数据流和所述设备业 务数据流组合成设备明细写入关联集 合。 5.根据权利要求1所述的大数据实时分析方法， 其特征在于， 所述数据流还包括用户数 据流； 执行反查询命令时， 根据所述缓存数据库中存储的所述用户数据流关联由设备 日志数 据流和设备业 务数据流组合成的设备明细； 其中， 所述缓存数据库被查询的优先级高于所述信息存 储库。 6.根据权利要求1所述的大数据实时分析方法， 其特征在于， 所述将所述信 息数据通过 流处理平台集群转换成数据流包括： 利用数据库处理环境通过监听所述信息存储库以获取所述信息数据到所述流处理平 台集群。 7.一种空调器的大数据实时分析系统， 所述大数据实时分析系统基于Spark框架； 其特 征在于， 所述大 数据实时分析系统包括： 获取模块(1 10)， 用于获取信息存 储库中的信息数据； 转换模块(120)， 用于将所述信息数据通过流处 理平台集群转换成数据流； 缓存模块(130)， 用于缓存由所述数据流 转换成的样例类； 当运行关联程序时， 查询所述缓存数据库中的样例类与相应的所述数据流关联处 理。 8.一种可读存 储介质， 包括存 储的程序， 其特 征在于， 其中， 所述 程序运行时执 行如上述权利要求1 ‑6任一项所述的大 数据实时分析 方法。权　利　要　求　书 1/2 页 2 CN 114860774 A 29.一种空调器， 其特 征在于， 所述空调器能够执 行如权利要求1 ‑6任一项所述的大 数据实时分析 方法。权　利　要　求　书 2/2 页 3 CN 114860774 A 3