(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211029162.9 (22)申请日 2022.08.25 (71)申请人 北京有竹居网络技 术有限公司 地址 101299 北京市平谷区林荫北街13号 信息大厦802室 (72)发明人 胡薰尹　王剑　 (74)专利代理 机构 北京三聚阳光知识产权代理 有限公司 1 1250 专利代理师 熊飞雪 (51)Int.Cl. G06F 11/14(2006.01) G06F 16/2455(2019.01) (54)发明名称 大数据分析方法、 装置、 边缘节点及云端服 务器 (57)摘要 本公开实施例涉及一种大数据分析方法、 装 置、 边缘节点及云端服务器， 该方法包括： 获取客 户端传输的第一数据； 根据与第一数据对应的数 据分析规则， 将第一数据备份至与边缘节点的第 一预设存储位置， 对第一数据进行分析， 获取分 析结果； 当分析结果包括第二数据时， 将第二数 据存储至边缘节点的第二预设存储位置； 和/或， 当分析结果包括第三数据时， 将第三数据上传至 与边缘节 点建立通信连接的云端服务器。 通过该 方式， 可以降低数据传输压力， 减少带宽资源的 占用。 还可以节省云端服务器的存储空间的资 源， 提升云端 服务器的数据处理、 查询， 以及分析 等能力， 提升对第三数据的查询分析速度。 权利要求书3页 说明书15页 附图6页 CN 115391098 A 2022.11.25 CN 115391098 A 1.一种大 数据分析 方法， 其特 征在于， 所述方法由边 缘节点执 行， 所述方法包括： 获取客户端传输的第一数据； 根据预获取的与所述第 一数据对应的数据分析规则， 将所述第 一数据备份至与所述边 缘节点对应的第一预设存 储位置， 以及， 对所述第一数据进行分析， 获取分析 结果； 当所述分析结果中包括第 二数据时， 将所述第 二数据存储至所述边缘节点的第 二预设 存储位置； 和/或， 当所述分析结果中包括第 三数据时， 将所述第 三数据上传至与 所述边缘节点建立通信 连接的云端服务器， 以便所述云端服务器对所述第三数据进行处理后， 将处理后的结果进 行存储。 2.根据权利要求1所述的方法， 其特征在于， 所述预获取的与 所述第一数据对应的数据 分析规则， 为所述云端服 务器根据对象需求， 事先 下发至所述 边缘节点的数据分析规则。 3.根据权利要求1所述的方法， 其特征在于， 所述数据分析规则包括存储规则和至少一 条数据处理规则； 所述根据预获取 的与所述第一数据对应的数据分析规则， 将所述第一数 据备份至与所述边缘节点对应的第一预设存储位置， 以及， 对 所述第一数据进 行分析， 获取 分析结果， 具体包括： 根据所述存储规则， 将所述第一数据备份至与所述边缘节点对应的第一预设存储位 置； 根据至少一条所述数据处理规则中的每一条数据处理规则， 分别对所述第 一数据进行 处理， 获取与每一条数据 处理规则 分别对应的处理结果， 所有的所述处理结果构成所述分 析结果。 4.根据权利要求3所述的方法， 其特征在于， 所述第三数据包括至少一种处理结果， 当 所述分析结果中包括第三数据时， 将所述第三数据上传至与所述边缘节点建立通信连接的 云端服务器， 具体包括： 将至少一种处理结果中的每一种处理结果， 分别存储至与所述处理结果对应的消息队 列； 通过所述消息队列， 将所述处理结果上传至与 所述边缘节点建立通信连接的云端服务 器， 以便所述云端服务器根据所述消息队列， 确定后续对所述处理结果执行的操作， 其中， 所述消息队列为所述 边缘节点与所述云端服 务器之间建立的消息传输通道。 5.根据权利要求1 ‑4任一项所述的方法， 其特征在于， 所述边缘节点包括第 一类边缘节 点和/或第二类边 缘节点； 当所述边缘节点为所述第 一类边缘节点 时， 所述第 一类边缘节点与 所述云端服务器之 间通过专线建立 通信连接； 或者， 当所述边缘节点为所述第 二类边缘节点 时， 所述第 二类边缘节点通过第 一公网与 所述 云端服务器 建立通信连接， 和/或， 通过所述第一类边缘节 点与所述云端服务器之间建立通 信连接， 其中， 所述第二类边缘节点与所述第一类边缘节点之间通过第二公网建立通信连 接。 6.一种大 数据分析 方法， 其特 征在于， 所述方法由云端服 务器执行， 所述方法包括：权　利　要　求　书 1/3 页 2 CN 115391098 A 2获取边缘节点发送的预设数据； 根据预获取的数据分析规则， 对所述预设数据进行分析， 获取分析 结果； 将所述分析 结果存储于所述云端服 务器的预设存 储位置。 7.根据权利要求6所述的方法， 其特征在于， 当所述预设数据为通过至少一个消息队列 中每一个消息队列分别传输的数据构成时， 所述根据预获取 的数据分析规则， 对所述预设 数据进行分析， 获取分析 结果， 具体包括： 根据至少一个消息队列中的第 一消息队列对应的标识信 息， 从预获取的至少一条数据 处理规则中， 选取与所述标识信息对应的预设数据处理规则， 其中， 至少一条数据处理规 则， 构成所述数据分析规则； 根据所述预设数据处理规则， 对通过所述第一消息队列传输的数据进行分析， 获取所 述分析结果， 其中， 至少一个所述消息队列中的每一个所述消息队列均为所述边缘节点与 所述云端服务器之 间建立的消息传输通道， 所述第一消息队列为至少一个消息队列中的任 一个消息队列。 8.根据权利要求6或7 所述的方法， 其特 征在于， 所述方法还 包括： 根据不同客户端的数据采样频率， 为不同客户端配置不同的数据采样率， 以便不同客 户端根据各自的数据采样率， 采集数据并上传至与自身建立 通信连接的边 缘节点。 9.根据权利要求6或7 所述的方法， 其特 征在于， 所述方法还 包括： 获取数据查询请求， 所述数据查询请求中包括用以指示待查询数据的标识信息； 根据所述标识信息， 从预构建的数据网关中获取与所述待查询数据对应的路径信息； 基于所述路径信 息， 到存储有所述待查询数据的数据存储位置获取所述待查询数据并 反馈， 其中， 所述数据网关中存储有任一数据的存储路径信息； 与所述数据查询请求对应的 数据存储位置包括与所述边缘节点对应的预设存储位置， 和/或包括与所述云端服务器对 应的预设存 储位置。 10.一种大 数据分析装置， 其特 征在于， 所述装置包括： 第一获取模块， 用于获取客户端传输的第一数据； 第一处理模块， 用于根据预获取的与所述第一数据对应的数据分析规则， 将所述第一 数据备份至与边缘节点对应的第一预设存储位置， 以及， 对所述第一数据进行分析， 获取分 析结果； 当所述分析结果中包括第 二数据时， 将所述第 二数据存储至所述边缘节点的第 二预设 存储位置； 和/或， 发送模块， 用于当所述分析结果中包括第三数据时， 将所述第三数据上传至与所述边 缘节点建立通信连接的云端服务器， 以便所述云端服务器对所述第三数据进行处理后， 将 处理后的结果进行存 储。 11.一种大 数据分析装置， 其特 征在于， 所述装置包括： 第二获取模块， 用于获取边 缘节点发送的预设数据； 第二处理模块， 用于根据 预获取的数据分析规则， 对所述预设数据进行分析， 获取分析 结果； 将所述分析 结果存储于云端服 务器的预设存 储位置。 12.一种边缘节点， 其特征在于， 包括处理器、 通信接口、 存储器和通信总 线， 其中， 处理权　利　要　求　书 2/3 页 3 CN 115391098 A 3