[發明專利]業務數據處理方法、裝置、存儲介質以及電子設備

在審

• 申請號: 202210158528.6
• 申請日: 2022-02-21
• 公開（公告）號: CN114675983A
• 公開（公告）日: 2022-06-28
• 發明（設計）人: 趙海宇
• 申請（專利權）人: 青島海爾科技有限公司;海爾智家股份有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京康信知識產權代理有限責任公司 11240
• 代理人: 劉赟

1.一種業務數據處理方法，其特征在于，包括：

將從消息中間件獲取到的消息數據同步推送至本地隊列中；

通過多線程從所述本地隊列中異步拉取所述消息數據，并對所述消息數據進行業務處理，得到業務處理數據；

將所述業務處理數據批量存入至目標數據庫。

2.根據權利要求1所述的方法，其特征在于，所述將從消息中間件獲取到的消息數據同步推送至本地隊列中，包括：

檢測所述消息數據的數據量的大??；

如果所述數據量大于等于預設數據閾值，則將所述消息數據同步推送至所述本地隊列中；

如果所述數據量小于所述預設數據閾值，則直接將所述消息數據存入至所述目標數據庫。

3.根據權利要求1或2所述的方法，其特征在于，將所述消息數據同步推送至所述本地隊列的處理速度為第一速度，從所述本地隊列中異步拉取并對所述消息數據進行業務處理的處理速度為第二速度，所述方法還包括：

檢測將所述消息數據同步推送至所述本地隊列的第一處理速度，從所述本地隊列中異步拉取并對所述消息數據進行業務處理的第二處理速度；

在檢測到所述第一處理速度大于所述第二處理速度時，獲取所述本地隊列的當前長度值，其中，所述當前長度值用于確定所述本地隊列中暫存的當前數據量；

根據所述當前長度值，動態調整用于對所述消息數據進行業務處理的處理線程的數量。

4.根據權利要求3所述的方法，其特征在于，所述根據所述當前長度值，動態調整用于對所述消息數據進行業務處理的處理線程的數量，包括：

判斷所述當前長度值是否超出長度預警閾值；

如果所述當前長度值超出所述長度預警閾值，則根據所述第二處理速度和所述當前長度值，確定增加所述處理線程的數量；

如果所述當前長度值未超出所述長度預警閾值，則根據所述第二處理速度和所述當前長度值，確定減少所述處理線程的數量。

5.根據權利要求3所述的方法，其特征在于，所述將所述業務處理數據批量存入至目標數據庫，包括：

分別將各個所述處理線程處理得到的所述業務處理數據，批量存入至所述目標數據庫。

6.根據權利要求3所述的方法，其特征在于，所述獲取所述本地隊列的所述當前長度值，包括：

采用守護線程監控所述本地隊列，得到所述當前長度值。

7.一種業務數據處理裝置，其特征在于，包括：

推送單元，用于將從消息中間件獲取到的消息數據同步推送至本地隊列中；

獲取單元，用于通過多線程從所述本地隊列中異步拉取所述消息數據，并對所述消息數據進行業務處理，得到業務處理數據；

存儲單元，用于將所述業務處理數據批量存入至目標數據庫。

8.根據權利要求7所述的裝置，其特征在于，所述推送單元，包括：

第一檢測單元，用于檢測所述消息數據的數據量的大??；

第一判斷單元，用于如果所述數據量大于等于預設數據閾值，則將所述消息數據同步推送至所述本地隊列中；

第二判斷單元，用于如果所述數據量小于所述預設數據閾值，則直接將所述消息數據存入至所述目標數據庫。

9.一種計算機可讀的存儲介質，其特征在于，所述計算機可讀的存儲介質包括存儲的程序，其中，所述程序運行時執行上述權利要求1至6任一項中所述的業務數據處理方法。

10.一種電子設備，包括存儲器和處理器，其特征在于，所述存儲器中存儲有計算機程序，所述處理器被設置為通過所述計算機程序執行所述權利要求1至6任一項中所述的業務數據處理方法。