[發(fā)明專利]一種異常數(shù)據(jù)上云方法、裝置、電子設備及存儲介質

在審

• 申請?zhí)枺?/td>: 202011545051.4
• 申請日: 2020-12-23
• 公開（公告）號: CN114745291A
• 公開（公告）日: 2022-07-12
• 發(fā)明（設計）人: 王鵬;高健;梁冰;張希成
• 申請（專利權）人: 北京國雙科技有限公司
• 主分類號: H04L43/02
• 分類號: H04L43/02;H04L67/10
• 代理公司: 北京華夏泰和知識產(chǎn)權代理有限公司 11662
• 代理人: 孟德棟;韓來兵

本發(fā)明涉及一種異常數(shù)據(jù)上云方法、裝置、電子設備及存儲介質，所述方法包括：邊緣側設備接收到云網(wǎng)絡發(fā)送的異常數(shù)據(jù)獲取請求后，先從異常數(shù)據(jù)獲取請求中提取數(shù)據(jù)要求，然后從存儲的與異常事件相關的數(shù)據(jù)記錄中，調取與數(shù)據(jù)格式中數(shù)據(jù)字段對應的目標數(shù)據(jù)內容，再將調取到的目標數(shù)據(jù)內容按照數(shù)據(jù)格式生成異常數(shù)據(jù)，最后將生成的異常數(shù)據(jù)發(fā)送至云網(wǎng)絡，由于邊緣側設備是按照云網(wǎng)絡發(fā)送的異常數(shù)據(jù)獲取請求中的數(shù)據(jù)要求生成的，此時云網(wǎng)絡接收到的異常數(shù)據(jù)的數(shù)據(jù)格式和數(shù)據(jù)字段便是符合云網(wǎng)絡對異常數(shù)據(jù)進行分析的需求的，有效避免了因數(shù)據(jù)格式以及數(shù)據(jù)字段不滿足分析需求造成的無法及時對異常數(shù)據(jù)進行分析的問題。

技術領域

本發(fā)明涉及數(shù)據(jù)傳輸技術領域，尤其涉及一種異常數(shù)據(jù)上云方法、裝置、電子設備及存儲介質。

背景技術

一般，現(xiàn)場數(shù)據(jù)采集裝置或數(shù)據(jù)服務器因停機、故障等原因造成丟失數(shù)據(jù)，以及機組異常啟停、異常運行等事件發(fā)生時，都會產(chǎn)生相應的異常數(shù)據(jù)，為了對異常數(shù)據(jù)進行更好的分析，通常需要對異常數(shù)據(jù)的發(fā)生時刻之前一段時間以及發(fā)生時刻之后一段時間內的所有數(shù)據(jù)進行采集，因此，每次異常時，采集的頻率較高，采集數(shù)據(jù)量大。并且不同設備所采集的異常數(shù)據(jù)的采集方式及采集字段均不相同，進而導致將大量的異常數(shù)據(jù)上傳到云服務后，無法及時對異常數(shù)據(jù)進行分析。

發(fā)明內容

為了解決上述技術問題或者至少部分地解決上述技術問題，本發(fā)明提供了一種異常數(shù)據(jù)上云方法、裝置、電子設備以及存儲介質。

第一方面，本發(fā)明提供了一種異常數(shù)據(jù)上云方法，應用于邊緣設備側，所述方法包括：

接收云網(wǎng)絡發(fā)送的異常數(shù)據(jù)獲取請求；所述異常數(shù)據(jù)獲取請求中攜帶至少一個數(shù)據(jù)要求；

從所述異常數(shù)據(jù)獲取請求中提取目標數(shù)據(jù)要求；所述目標數(shù)據(jù)要求包含有數(shù)據(jù)格式和至少一個數(shù)據(jù)字段；

從存儲的與異常事件相關的數(shù)據(jù)記錄中，調取與所述目標數(shù)據(jù)要求中數(shù)據(jù)字段對應的目標數(shù)據(jù)內容；

將調取到的目標數(shù)據(jù)內容按照所述數(shù)據(jù)格式生成異常數(shù)據(jù)；

發(fā)送所述異常數(shù)據(jù)至云網(wǎng)絡。

在本發(fā)明的可選實施方式中，所述異常數(shù)據(jù)獲取請求中攜帶有設備標識，每個設備標識與數(shù)據(jù)要求之間一一對應；

所述從所述異常數(shù)據(jù)獲取請求中提取所述數(shù)據(jù)要求，包括：

查找與所述邊緣側設備的標識對應的目標設備標識；

提取與所述目標設備標識對應的數(shù)據(jù)要求作為目標數(shù)據(jù)要求。

在本發(fā)明的可選實施方式中，所述數(shù)據(jù)要求中包含有多個數(shù)據(jù)字段；

所述調取與所述目標數(shù)據(jù)要求中數(shù)據(jù)字段對應的目標數(shù)據(jù)內容，包括：

提取所述目標數(shù)據(jù)要求中的所有數(shù)據(jù)字段；

從所述所有數(shù)據(jù)字段中確定所述邊緣側設備所支持的目標數(shù)據(jù)字段；

調取所述目標數(shù)據(jù)字段對應的數(shù)據(jù)內容作為目標數(shù)據(jù)內容。

在本發(fā)明的可選實施方式中，發(fā)送所述異常數(shù)據(jù)至云網(wǎng)絡，包括：

發(fā)送所述異常數(shù)據(jù)至所述異常數(shù)據(jù)獲取請求的發(fā)送方；

或者，

發(fā)送所述異常數(shù)據(jù)至所述異常數(shù)據(jù)獲取請求的發(fā)送方所在云網(wǎng)絡中kafka集群。

在本發(fā)明的可選實施方式中，所述方法還包括：

獲取所述邊緣側設備所支持的所有數(shù)據(jù)字段；

判斷所述邊緣側設備的所支持的所有數(shù)據(jù)字段是否與所述數(shù)據(jù)要求的數(shù)據(jù)字段一致；