[發明專利]基于MQTT的物聯網大數據采集處理系統

在審

• 申請號: 202010144171.7
• 申請日: 2020-03-04
• 公開（公告）號: CN111245661A
• 公開（公告）日: 2020-06-05
• 發明（設計）人: 不公告發明人
• 申請（專利權）人: 山西博華科技有限公司
• 主分類號: H04L12/24
• 分類號: H04L12/24;H04L29/08;G16Y40/10;G16Y40/20
• 代理公司: 暫無信息
• 代理人: 暫無信息

本發明公開基于MQTT的物聯網大數據采集處理系統，涉及工業物聯網大數據應用領域中一種基于MQTT協議數據傳輸采集處理的系統，其通過MQTT協議采集傳感器數據，并通過大數據處理分析技術提供一種能保障產品質量的物聯網大數據采集處理系統，能在產品出現故障前，通過大數據分析，來判斷傳感器故障，做到事前預防及傳感器產品研發升級。傳感器基于MQTT協議通過網絡將數據發布至后臺MQTT代理服務器，后臺大數據處理軟件通過向MQTT代理服務器訂閱傳感器數據，將接收到的數據通過校驗、分析、處理等一系列環節后進行存儲以及發布至消息中間件或進行顯示供用戶查看。

技術領域

本發明涉及工業物聯網大數據應用領域中一種基于MQTT協議數據傳輸采集處理的系統。

背景技術

現有傳感器數據傳輸基于MQTT的消息發布/訂閱傳輸協議，該協議是輕量、簡單、開放和易于實現，廣泛應用于工業物聯網數據傳輸。

現有傳感器在產品質量出現問題后采用事后控制的原則進行檢修、維護或更換，對工業生產帶來很大的不利，如果能在產品出現故障前，通過大數據分析手段判斷傳感器故障，將對施工維護人員提供大大的便利，并利于傳感器研發升級。

發明內容

本發明的目的在于通過MQTT協議采集傳感器數據，并通過大數據處理分析技術提供一種能保障產品質量的物聯網大數據采集處理系統，其能在產品出現故障前，通過大數據分析，來判斷傳感器故障，做到事前預防及傳感器產品研發升級。

本發明采用以下技術方案實現：傳感器基于MQTT協議通過網絡將數據發布至后臺MQTT代理服務器，后臺大數據處理軟件通過向MQTT代理服務器訂閱傳感器數據，將接收到的數據通過校驗、分析、處理等一系列環節后進行存儲以及發布至消息中間件或進行顯示供用戶查看。

基于MQTT的物聯網大數據采集處理系統通過訂閱到的傳感器數據，比較傳感器類別、傳感器唯一標識以及業務數據監測項來判斷當前傳感器數據是否合法。

基于MQTT的物聯網大數據采集處理系統將合法的傳感器實時業務數據與該傳感器出廠時標定的數據量程進行比較，通過判斷當前傳感器數據傳輸是否存在超量程異常情況。

基于MQTT的物聯網大數據采集處理系統將通過大數據處理技術，對傳感器近期歷史數據比較、聚類、分類等分析歸納，可得到該傳感器數據傳輸趨勢以及可對該傳感器健康狀態進行預測。

如果存在超量程異常以及所述大數據處理系統判斷數據趨勢存在異常或預測傳感器將發生故障，則發出警告來提示這個傳感器出現異常。

基于MQTT的物聯網大數據采集處理系統，可以及時判斷傳感器數據是否存在異常或傳感器是否故障，對不正常的傳感器及時維修或更換，并對該傳感器研發升級提供一定數據基礎，可降低傳感器異常故障帶來的停工、停產風險，對傳感器的數據及健康狀態做到實時監控。

附圖說明

圖1為基于MQTT的物聯網大數據采集處理系統業務數據合法性判斷及超量程異常判斷流程圖。

具體實施方式

為了使本發明的目的、技術方案及優點更加清楚明白，以下結合附圖，對本發明進行進一步詳細說明。應當理解，此處所描述的具體實施例僅用以解釋本發明，并不用于限定本發明。

原始數據接收：使用MQTT訂閱主題的方式接收原始數據，傳輸協議報文結構如下：

主題：busiData/設備類型/設備編號。

荷載：

{

time: timeValue,

data: [