[發明專利]狀態數據處理方法、裝置及計算機設備

有效

• 申請號: 202010437921.X
• 申請日: 2020-05-21
• 公開（公告）號: CN111611207B
• 公開（公告）日: 2023-06-23
• 發明（設計）人: 朱堂華;康添
• 申請（專利權）人: 四川虹美智能科技有限公司
• 主分類號: G06F16/14
• 分類號: G06F16/14;G06F16/17;G06F16/182;G06F16/242;G06F11/14
• 代理公司: 濟南信達專利事務所有限公司 37100
• 代理人: 李世喆

本發明提供了一種狀態數據處理方法、裝置及計算機設備，在接收到目標智能設備上報的狀態數據后，按照設定格式生成對應的業務日志，將業務日志放置至Flume組件對應的日志目錄中，實現對狀態數據的整合，由Flume組件按照設定采集規則，將日志目錄中的所有業務日志取出發送至Hadoop，由Hadoop中的pig處理框架對業務日志進行分析，以快速針對不同業務需求生成不同的統計數據，通過生成用于表述相應統計數據的sql語句，將sql語句存儲到數據庫中，從而完成對大量狀態數據的統計分析和存儲，在需要進行數據統計展示時，可以直接將數據庫中的sql語句表述的統計數據進行響應，從而可以提高服務器的響應速度。

技術領域

本發明涉及數據處理技術領域，特別涉及一種狀態數據處理方法、裝置及計算機設備。

背景技術

隨著智能家居的發展，智能設備的使用也越來越普遍。智能設備與服務器之間需要經常進行數據交互，例如，智能設備將狀態數據上報給服務器，為了便于后續進行數據統計，服務器需要將智能設備上報的狀態數據進行持久化處理。傳統處理方式是服務器在每接收到智能設備上報的狀態數據后，則直接將這些狀態數據存儲到數據庫中，在進行數據統計時，從數據庫中存儲的狀態數據中進行計算，以對統計結果進行響應。然而數據庫中存儲的數據量較大，計算統計過程耗費時間較長，從而影響服務器的響應速度。因此，需要提供一種快速高效的數據處理方案，以解決現有技術存在的問題。

發明內容

本發明實施例提供了一種狀態數據處理方法、裝置及計算機設備，以對狀態數據快速高效的進行處理，提高服務器性能。

第一方面，本發明實施例提供了一種狀態數據處理方法，包括

接收目標智能設備上報的狀態數據，并對所述狀態數據進行解析；

根據解析后的所述狀態數據，按照預設格式，生成對應的業務日志；

將生成的所述業務日志放置至Flume組件對應的日志目錄中；

利用所述Flume組件，按照設定采集規則，將所述日志目錄中的所有業務日志取出，發送至分布式系統基礎架構Hadoop；

所述Hadoop中的pig處理框架對接收到的業務日志進行分析，以針對不同業務需求生成不同的統計數據，并生成用于表述相應統計數據的sql語句；

采用linux命令將生成的sql語句存儲到數據庫中。

優選地，進一步包括：預先存儲有若干解析協議，每一個解析協議對應不同的智能設備；

所述對所述狀態數據進行解析，包括：確定所述目標智能設備對應的目標解析協議，從預先存儲的若干解析協議中選擇出所述目標解析協議，利用所述目標解析協議對所述狀態數據進行解析。

優選地，在所述采用linux命令將生成的sql語句存儲到數據庫中之前，進一步包括：將生成的sql語句整合到目標文件夾中；

所述采用linux命令將生成的sql語句存儲到數據庫中，包括：采用Linux命令執行所述目標文件夾中包含的sql語句，以將所述目標文件夾中包含的sql語句存儲到數據庫中。

優選地，在所述生成對應的業務日志之后，進一步包括：將生成的所述業務日志進行本地備份；

優選地，所述設定采集規則包括：每隔設定時間段采集一次，或，每當所述日志目錄中放置的業務日志量達到設定數量則采集一次。

第二方面，本發明實施例提供了一種狀態數據處理裝置，包括：

數據處理模塊，用于接收目標智能設備上報的狀態數據，并對所述狀態數據進行解析，根據解析后的所述狀態數據，按照預設格式，生成對應的業務日志，將生成的所述業務日志放置至Flume組件對應的日志目錄中；