[發明專利]一種邊緣端數據傳輸與存儲的方法以及裝置

在審

• 申請號: 202110431076.X
• 申請日: 2021-04-21
• 公開（公告）號: CN113032492A
• 公開（公告）日: 2021-06-25
• 發明（設計）人: 牛世元
• 申請（專利權）人: 新奧數能科技有限公司
• 主分類號: G06F16/27
• 分類號: G06F16/27;G06F16/25;G06F9/54
• 代理公司: 北京嘉科知識產權代理事務所(特殊普通合伙) 11687
• 代理人: 張艷

1.一種邊緣端數據傳輸與存儲的方法，其特征在于，包括：

數據采集模塊根據采集的邊緣端設備數據創建初始消息隊列，并將所述初始消息隊列傳輸至第一消息中間件；

當數據處理模塊獲取到所述第一消息中間件中的初始消息隊列時，所述數據處理模塊根據數據存儲模塊與數據轉發模塊的需求對所述初始消息隊列進行處理，獲得轉發消息隊列信息和存儲消息隊列信息，并將所述轉發消息隊列信息和所述存儲消息隊列信息傳輸至第二消息中間件；

數據存儲模塊獲取到所述存儲消息隊列信息時，對所述存儲消息隊列信息進行存儲；

數據轉發模塊獲取到所述轉發消息隊列信息時，對所述轉發消息隊列信息進行轉發。

2.如權利要求1所述的邊緣端數據傳輸與存儲的方法，其特征在于，所述數據采集模塊根據采集的邊緣端設備數據創建初始消息隊列，并將所述初始消息隊列傳輸至第一消息中間件步驟，包括：

數據采集模塊通過傳輸協議采集邊緣端設備數據，所述傳輸協議包括Modbus-RTU、Modbus-TCP、S7或BACnet；

所述數據采集模塊基于所述邊緣端設備的數據，創建初始消息隊列；

所述數據采集模塊將所述初始消息隊列傳輸至第一消息中間件。

3.如權利要求1所述的邊緣端數據傳輸與存儲的方法，其特征在于，所述當數據處理模塊獲取到所述第一消息中間件中的初始消息隊列時，所述數據處理模塊根據數據存儲模塊與數據轉發模塊的需求對所述初始消息隊列進行處理，獲得轉發消息隊列信息和存儲消息隊列信息，并將所述轉發消息隊列信息和所述存儲消息隊列信息傳輸至第二消息中間件，包括：

所述數據處理模塊獲取數據存儲模塊設置的存儲周期，并根據所述存儲周期，按照消息隊列先進先出的原則，對所述初始消息隊列進行處理，獲得存儲消息隊列信息；

所述數據處理模塊獲取數據轉發模塊設置的轉發周期，并根據所述轉發周期，按照消息隊列先進先出的原則，對所述初始消息隊列進行處理，獲得轉發消息隊列信息。

4.如權利要求3所述的邊緣端數據傳輸與存儲的方法，其特征在于，所述存儲消息隊列信息包括實時數據消息隊列和歷史數據消費隊列。

5.如權利要求4所述的邊緣端數據傳輸與存儲的方法，其特征在于，所述數據存儲模塊獲取到所述存儲消息隊列信息時，對所述存儲消息隊列信息進行存儲步驟，包括：

所述數據存儲模塊獲取到所述實時數據消息隊列時，將所述實時數據消息隊列的數據緩存到指定哈希類中；

所述數據存儲模塊獲取到所述歷史數據消息隊列時，根據數據點的數量在時序數據庫中進行存儲。

6.如權利要求1所述的邊緣端數據傳輸與存儲的方法，其特征在于，所述數據轉發模塊獲取到所述轉發消息隊列信息時，對所述轉發消息隊列信息進行轉發步驟，包括：

數據轉發模塊獲取到所述轉發消息隊列信息，設置轉發周期；

基于所述轉發周期，所述數據轉發模塊通過消息隊列遙測傳輸協議將所述轉發消息隊列信息的數據傳輸到大數據平臺，以提供顯示與查詢服務。

7.如權利要求6所述的邊緣端數據傳輸與存儲的方法，其特征在于，所述數據存儲模塊獲取到所述存儲消息隊列信息時，對所述存儲消息隊列信息進行存儲步驟之后，還包括：

通過瀏覽器調用元數據模塊接口；

根據所述元數據模塊存儲的數據點標識，通過所述數據存儲模塊獲取數據點，以進行數據顯示。