[發(fā)明專(zhuān)利]數(shù)據(jù)采集處理方法、裝置、系統(tǒng)和邊緣網(wǎng)關(guān)設(shè)備

有效

• 申請(qǐng)?zhí)枺?/td>: 202010795166.2
• 申請(qǐng)日: 2020-08-10
• 公開(kāi)（公告）號(hào): CN111917636B
• 公開(kāi)（公告）日: 2022-07-22
• 發(fā)明（設(shè)計(jì)）人: 謝虎;張偉;邱榮福;謝型浪
• 申請(qǐng)（專(zhuān)利權(quán)）人: 南方電網(wǎng)數(shù)字電網(wǎng)研究院有限公司
• 主分類(lèi)號(hào): H04L12/66
• 分類(lèi)號(hào): H04L12/66;G06F9/455;H04L41/00
• 代理公司: 華進(jìn)聯(lián)合專(zhuān)利商標(biāo)代理有限公司 44224
• 代理人: 盧曉霞

1.一種數(shù)據(jù)采集處理方法，其特征在于，應(yīng)用于邊緣網(wǎng)關(guān)設(shè)備，所述方法包括：

通過(guò)設(shè)備容器獲取接入至所述邊緣網(wǎng)關(guān)設(shè)備的邊緣設(shè)備的來(lái)源信息并發(fā)送至管理容器；

通過(guò)所述管理容器根據(jù)所述來(lái)源信息判斷所述邊緣設(shè)備是否屬于數(shù)據(jù)來(lái)源已注冊(cè)的邊緣設(shè)備，得到判斷結(jié)果，根據(jù)所述判斷結(jié)果確定與所述來(lái)源信息對(duì)應(yīng)的數(shù)據(jù)容器，若所述判斷結(jié)果為所述邊緣設(shè)備不屬于所述數(shù)據(jù)來(lái)源已注冊(cè)的邊緣設(shè)備，則創(chuàng)建與所述來(lái)源信息對(duì)應(yīng)的數(shù)據(jù)容器，并觸發(fā)所述數(shù)據(jù)容器指示所述數(shù)據(jù)容器注冊(cè)所述邊緣設(shè)備的數(shù)據(jù)來(lái)源；

根據(jù)所述數(shù)據(jù)容器向算法容器申請(qǐng)數(shù)據(jù)管道，建立所述數(shù)據(jù)容器和所述算法容器的數(shù)據(jù)采集通道，所述算法容器加載相應(yīng)的功能模塊，同時(shí)向所述管理容器發(fā)送來(lái)源信息，完成新增來(lái)源的注冊(cè)；

利用所述數(shù)據(jù)容器采集所述邊緣設(shè)備的數(shù)據(jù)后通過(guò)所述數(shù)據(jù)采集通道傳輸至所述算法容器進(jìn)行處理。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述通過(guò)所述設(shè)備容器獲取接入至所述邊緣網(wǎng)關(guān)設(shè)備的所述邊緣設(shè)備的來(lái)源信息并發(fā)送至所述管理容器，包括：

所述邊緣網(wǎng)關(guān)設(shè)備通過(guò)所述設(shè)備容器對(duì)接入的邊緣設(shè)備模型進(jìn)行校驗(yàn)；

若所述邊緣設(shè)備模型檢驗(yàn)成功，所述邊緣網(wǎng)關(guān)設(shè)備通過(guò)所述設(shè)備容器獲取該所述邊緣設(shè)備的所述來(lái)源信息，所述設(shè)備容器將所述邊緣設(shè)備的所述來(lái)源信息發(fā)送給所述管理容器，進(jìn)行查詢，若所述邊緣設(shè)備模型檢驗(yàn)失敗，則服務(wù)結(jié)束。

3.根據(jù)權(quán)利要求2所述的方法，其特征在于，若所述邊緣設(shè)備模型檢驗(yàn)成功，所述邊緣網(wǎng)關(guān)設(shè)備通過(guò)所述設(shè)備容器獲取該所述邊緣設(shè)備的所述來(lái)源信息，所述設(shè)備容器將所述邊緣設(shè)備的所述來(lái)源信息發(fā)送給所述管理容器，進(jìn)行查詢，包括：

通過(guò)所述管理容器對(duì)各類(lèi)所述邊緣數(shù)據(jù)來(lái)源進(jìn)行注冊(cè)、查詢、注銷(xiāo)和認(rèn)證；

根據(jù)所述邊緣數(shù)據(jù)來(lái)源進(jìn)行注冊(cè)、查詢、注銷(xiāo)和認(rèn)證向所述設(shè)備容器、所述數(shù)據(jù)容器、所述算法容器和通信服務(wù)各類(lèi)模塊發(fā)起任務(wù)的權(quán)限。

4.根據(jù)權(quán)利要求1所述的方法，其特征在于，所述根據(jù)所述數(shù)據(jù)容器向算法容器申請(qǐng)數(shù)據(jù)管道，建立所述數(shù)據(jù)容器和所述算法容器的數(shù)據(jù)采集通道，包括：

觸發(fā)所述數(shù)據(jù)容器向所述算法容器申請(qǐng)數(shù)據(jù)管道，以使所述算法容器構(gòu)建與所述數(shù)據(jù)容器的數(shù)據(jù)采集通道并依據(jù)所述邊緣設(shè)備的設(shè)備模型加載相應(yīng)的功能模塊。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述算法容器構(gòu)建與所述數(shù)據(jù)容器的數(shù)據(jù)采集通道并依據(jù)所述邊緣設(shè)備的設(shè)備模型加載相應(yīng)的功能模塊之后，所述方法還包括：

暫停所述算法容器的功能模塊和所述數(shù)據(jù)容器的數(shù)據(jù)采集功能；

通過(guò)所述數(shù)據(jù)容器觸發(fā)所述算法容器依據(jù)所述邊緣設(shè)備的設(shè)備模型更新所述數(shù)據(jù)采集通道的數(shù)據(jù)采集節(jié)點(diǎn)信息，以及通過(guò)所述數(shù)據(jù)容器觸發(fā)所述管理容器依據(jù)所述邊緣設(shè)備的設(shè)備模型更新所述來(lái)源信息；

啟動(dòng)所述算法容器的功能模塊和所述數(shù)據(jù)容器的數(shù)據(jù)采集功能。

6.根據(jù)權(quán)利要求4所述的方法，其特征在于，所述算法容器構(gòu)建與所述數(shù)據(jù)容器的數(shù)據(jù)采集通道并依據(jù)所述邊緣設(shè)備的設(shè)備模型加載相應(yīng)的功能模塊之后，所述方法還包括：

通過(guò)所述管理容器向通訊服務(wù)發(fā)起對(duì)所述邊緣設(shè)備的通信功能校驗(yàn)請(qǐng)求；

若校驗(yàn)失敗，則刪除創(chuàng)建的所述數(shù)據(jù)容器，關(guān)閉所述數(shù)據(jù)采集通道并觸發(fā)所述算法容器卸載所述功能模塊。

7.根據(jù)權(quán)利要求4至6任一項(xiàng)所述的方法，其特征在于，所述方法還包括：

若所述判斷結(jié)果為所述邊緣設(shè)備屬于所述數(shù)據(jù)來(lái)源已注冊(cè)的邊緣設(shè)備，則從所述邊緣網(wǎng)關(guān)設(shè)備的已創(chuàng)建數(shù)據(jù)容器中確定與所述來(lái)源信息對(duì)應(yīng)的數(shù)據(jù)容器；

所述根據(jù)所述數(shù)據(jù)容器向算法容器申請(qǐng)數(shù)據(jù)管道，建立所述數(shù)據(jù)容器和所述算法容器的數(shù)據(jù)采集通道，包括：

暫停所述算法容器的功能模塊和所述數(shù)據(jù)容器的數(shù)據(jù)采集功能；

通過(guò)所述數(shù)據(jù)容器觸發(fā)所述算法容器依據(jù)所述邊緣設(shè)備的設(shè)備模型更新所述數(shù)據(jù)采集通道的數(shù)據(jù)采集節(jié)點(diǎn)信息，以及通過(guò)所述數(shù)據(jù)容器觸發(fā)所述管理容器依據(jù)所述邊緣設(shè)備的設(shè)備模型更新所述來(lái)源信息；

啟動(dòng)所述算法容器的功能模塊和所述數(shù)據(jù)容器的數(shù)據(jù)采集功能。