[發(fā)明專利]一種實(shí)現(xiàn)工業(yè)物聯(lián)網(wǎng)智能設(shè)備數(shù)據(jù)快速接入、匯聚、存儲(chǔ)和發(fā)布的方法

在審

• 申請(qǐng)?zhí)枺?/td>: 202110123141.2
• 申請(qǐng)日: 2021-01-29
• 公開（公告）號(hào): CN112953913A
• 公開（公告）日: 2021-06-11
• 發(fā)明（設(shè)計(jì)）人: 薛峰;張萬(wàn)友;陸文
• 申請(qǐng)（專利權(quán)）人: 江蘇提米智能科技有限公司
• 主分類號(hào): H04L29/06
• 分類號(hào): H04L29/06;H04L29/08
• 代理公司: 南京勤行知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 32397
• 代理人: 尹英

1.一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理系統(tǒng)，其特征在于，包括：

數(shù)據(jù)采集模塊，其用于通過(guò)多線程并發(fā)形式采集工業(yè)設(shè)備的工業(yè)大數(shù)據(jù)，并對(duì)所述工業(yè)大數(shù)據(jù)進(jìn)行協(xié)議轉(zhuǎn)換及封包上傳；

數(shù)據(jù)解析模塊，其用于接收封包上傳的所述工業(yè)大數(shù)據(jù)，對(duì)該工業(yè)大數(shù)據(jù)進(jìn)行數(shù)據(jù)解析及數(shù)值壓縮處理，并將處理后的所述工業(yè)大數(shù)據(jù)寫入緩存池；

數(shù)據(jù)存儲(chǔ)模塊，其用于將放入緩存池的數(shù)據(jù)進(jìn)行數(shù)據(jù)存儲(chǔ)；及

數(shù)據(jù)發(fā)布模塊，其用于將緩存池的數(shù)據(jù)按照規(guī)約協(xié)議進(jìn)行數(shù)據(jù)發(fā)布。

2.根據(jù)權(quán)利要求1所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理系統(tǒng)，其特征在于：還包括數(shù)據(jù)監(jiān)控模塊，所述數(shù)據(jù)監(jiān)控模塊用于獲取數(shù)據(jù)采集模塊采集的所述工業(yè)大數(shù)據(jù)，通過(guò)閾值判斷工業(yè)設(shè)備的狀態(tài)；

所述數(shù)據(jù)監(jiān)控模塊還用于監(jiān)控?cái)?shù)據(jù)采集模塊與工業(yè)設(shè)備之間的采集鏈路的網(wǎng)絡(luò)通訊狀態(tài)，并在異常時(shí)發(fā)出告警信息。

3.根據(jù)權(quán)利要求1所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理系統(tǒng)，其特征在于：所述數(shù)據(jù)采集模塊通過(guò)數(shù)據(jù)采集接口的UDP網(wǎng)絡(luò)傳輸協(xié)議，將所述首次封包上傳的所述工業(yè)大數(shù)據(jù)上傳至所述數(shù)據(jù)匯聚接口；所述數(shù)據(jù)匯聚接口通過(guò)TCP網(wǎng)絡(luò)傳輸協(xié)議將所述二次封包上傳的所述工業(yè)大數(shù)據(jù)上傳至所述數(shù)據(jù)解析模塊。

4.根據(jù)權(quán)利要求3所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理系統(tǒng)，其特征在于：所述數(shù)據(jù)解析模塊還用于在數(shù)據(jù)解析完后，根據(jù)測(cè)點(diǎn)的乘系數(shù)和加系數(shù)進(jìn)行數(shù)據(jù)處理，將解析后的數(shù)據(jù)轉(zhuǎn)換成數(shù)據(jù)字典的形式編入隊(duì)列。

5.根據(jù)權(quán)利要求4所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理系統(tǒng)，其特征在于：所述隊(duì)列為先進(jìn)先出的線程安全隊(duì)列，并對(duì)隊(duì)列的入隊(duì)出隊(duì)進(jìn)行加解鎖控制。

6.根據(jù)權(quán)利要求4所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理系統(tǒng)，其特征在于：數(shù)據(jù)存儲(chǔ)模塊在數(shù)據(jù)存儲(chǔ)過(guò)程中：

先根據(jù)測(cè)點(diǎn)個(gè)數(shù)在數(shù)據(jù)庫(kù)中創(chuàng)建數(shù)據(jù)表，數(shù)據(jù)表中包含時(shí)間字段和數(shù)值字段；

再建立測(cè)點(diǎn)和數(shù)據(jù)字段的對(duì)應(yīng)關(guān)系，在存儲(chǔ)數(shù)據(jù)時(shí)，按照所述對(duì)應(yīng)關(guān)系將時(shí)間字段和數(shù)值字段進(jìn)行批量存儲(chǔ)。

7.一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理方法，其特征在于，包括：

通過(guò)多線程并發(fā)形式采集工業(yè)設(shè)備的工業(yè)大數(shù)據(jù)，并對(duì)所述工業(yè)大數(shù)據(jù)進(jìn)行協(xié)議轉(zhuǎn)換及封包上傳；

接收封包上傳的所述工業(yè)大數(shù)據(jù)，對(duì)該工業(yè)大數(shù)據(jù)進(jìn)行數(shù)據(jù)解析及數(shù)值壓縮處理，并將處理后的所述工業(yè)大數(shù)據(jù)寫入緩存池；

將放入緩存池的數(shù)據(jù)進(jìn)行數(shù)據(jù)存儲(chǔ)；

將緩存池的數(shù)據(jù)按照規(guī)約協(xié)議進(jìn)行數(shù)據(jù)發(fā)布。

8.根據(jù)權(quán)利要求7所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理方法，其特征在于：

獲取數(shù)據(jù)采集模塊采集的所述工業(yè)大數(shù)據(jù)，通過(guò)閾值判斷工業(yè)設(shè)備的狀態(tài)；

監(jiān)控?cái)?shù)據(jù)采集模塊與工業(yè)設(shè)備之間的采集鏈路的網(wǎng)絡(luò)通訊狀態(tài)，并在異常時(shí)發(fā)出告警信息。

9.根據(jù)權(quán)利要求7所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理方法，其特征在于：

通過(guò)數(shù)據(jù)采集接口的UDP網(wǎng)絡(luò)傳輸協(xié)議，將所述首次封包上傳的所述工業(yè)大數(shù)據(jù)上傳至所述數(shù)據(jù)匯聚接口；所述數(shù)據(jù)匯聚接口通過(guò)TCP網(wǎng)絡(luò)傳輸協(xié)議將所述二次封包上傳的所述工業(yè)大數(shù)據(jù)上傳至所述數(shù)據(jù)解析模塊。

10.根據(jù)權(quán)利要求7所述的一種基于工業(yè)物聯(lián)網(wǎng)設(shè)備的數(shù)據(jù)管理方法，其特征在于：

在數(shù)據(jù)解析完后，根據(jù)測(cè)點(diǎn)的乘系數(shù)和加系數(shù)進(jìn)行數(shù)據(jù)處理，將解析后的數(shù)據(jù)轉(zhuǎn)換成數(shù)據(jù)字典的形式編入隊(duì)列；

所述隊(duì)列為先進(jìn)先出的線程安全隊(duì)列，并對(duì)隊(duì)列的入隊(duì)出隊(duì)進(jìn)行加解鎖控制。