[發明專利]時序數據并發入庫的方法和裝置

有效

• 申請號: 201410828696.7
• 申請日: 2014-12-26
• 公開（公告）號: CN105786917B
• 公開（公告）日: 2020-01-14
• 發明（設計）人: 張濤
• 申請（專利權）人: 億陽信通股份有限公司
• 主分類號: G06F16/245
• 分類號: G06F16/245
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.時序數據并發入庫的方法，其特征在于，所述方法包括：

獲取所述時序數據中同類型數據的唯一標識，預設數據處理器數量，根據所述數據處理器數量和所述同類型數據唯一標識確定與該類型數據對應的所述數據處理器的名稱序號；

創建下標與所述數據處理器名稱序號相應的隊列數組存儲空間，分別設定隊列深度與數組長度；

所述各數據處理器接收與其數據類型一致的時序數據，解析獲取所述時序數據中的各屬性和值，并將所述屬性和值依次存入所述隊列數組相應下標的存儲位置中；

當所述隊列數組中的隊列達到設定深度時，觸發數據庫接口獲取所述隊列數組中的所有數據并進行入庫操作。

2.根據權利要求1所述的方法，其特征在于，所述方法還包括：

所述數據庫接口完成所述數據入庫操作后，清除所述隊列數組中的所有數據，清除所述數據處理器的名稱序號。

3.根據權利要求1或2所述的方法，其特征在于：

將時序數據特征屬性的名稱進行組合，計算其消息摘要碼，所述消息摘要碼相同的時序數據為同類型數據，所述消息摘要碼為同類型數據的唯一標識；

對所述各類型數據消息摘要碼取模，模數為所述數據處理器數量，取模的余數做為各類型數據對應的數據處理器名稱序號。

4.根據權利要求3所述的方法，其特征在于：

配置預裝載數組對象，綁定所述隊列數組的數組名稱、數組下標和數據類型；

所述數據庫接口通過所述預裝載數組對象綁定的數組下標，直接獲取所述隊列數組相應下標存儲位置中的所有數據。

5.根據權利要求4所述的方法，其特征在于：

設置所述隊列數組定時監控時間，對所述隊列數組進行監控；

若所述隊列數組在所述設置的監控時間內仍未達到設定深度，則觸發數據庫接口獲取所述隊列數組中的所有數據并進行入庫操作。

6.根據權利要求5所述的方法，其特征在于：

所述數據庫接口為ODBC的BULK接口，根據所述隊列深度設定所述BULK接口的批量提交數量參數。

7.根據權利要求6所述的方法，其特征在于：

將所述隊列數組中隊列的深度設定為存儲1200條數據對象，將所述隊列數組的長度設定為10，數組下標為0～9；

所述接收的時序數據為Protobuf時序數據。

8.時序數據并發入庫的裝置，其特征在于，所述裝置包括：

唯一標識獲取單元，用于獲取所述時序數據中同類型數據的唯一標識；

數據處理器調度單元，用于根據預設數據處理器數量調度相應數量的數據處理器，并根據所述數據處理器數量和所述唯一標識獲取單元獲取的同類型數據唯一標識確定與該類型數據對應的所述數據處理器的名稱序號；

數據存儲單元，用于創建下標與所述數據處理器名稱序號相應的隊列數組存儲空間，分別設定隊列深度與數組長度；

數據處理器，用于接收與其數據類型一致的時序數據，解析獲取所述時序數據中的各屬性和值，并將所述屬性和值依次存入所述隊列數組相應下標的存儲位置中；

數據入庫單元，當所述數據存儲單元隊列數組中的隊列達到設定深度時，觸發數據庫接口獲取所述隊列數組中的所有數據并進行入庫操作。

9.根據權利要求8所述的裝置，其特征在于，所述裝置還包括：

數據清除單元，用于當所述數據入庫單元完成所述數據入庫操作后，清除所述隊列數組中的所有數據，清除所述數據處理器的名稱序號。

10.根據權利要求9所述的裝置，其特征在于，唯一標識獲取單元獲取所述時序數據中同類型數據的唯一標識的方法具體為：

將時序數據特征屬性的名稱進行組合計算其消息摘要碼，所述消息摘要碼相同的時序數據為同類型數據，所述消息摘要碼為同類型數據的唯一標識。