[發明專利]業務數據的處理方法、裝置和系統、存儲介質、電子裝置

在審

• 申請號: 202010949620.5
• 申請日: 2020-09-10
• 公開（公告）號: CN112181678A
• 公開（公告）日: 2021-01-05
• 發明（設計）人: 李潤靜;龍富永;邱實剛;柯秋賢;葛萬鵬;侯浩鑫
• 申請（專利權）人: 珠海格力電器股份有限公司;珠海聯云科技有限公司
• 主分類號: G06F9/54
• 分類號: G06F9/54
• 代理公司: 北京聿宏知識產權代理有限公司 11372
• 代理人: 吳大建;金淼

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

獲取第一分布式消息隊列中的原始業務數據，其中，所述第一分布式消息隊列用于保存來源于數據源的原始業務數據；

將對所述原始業務數據進行處理過的中間業務數據保存至第二分布式消息隊列，其中，每個所述第二分布式消息隊列用于保存一種類型的中間業務數據；

通過流處理系統對所述第二分布式消息隊列中的中間業務數據進行處理。

2.根據權利要求1所述的方法，其特征在于，將對所述原始業務數據進行處理過的中間業務數據保存至第二分布式消息隊列包括：

調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行處理，將得到的中間業務數據保存至所述第二分布式消息隊列。

3.根據權利要求2所述的方法，其特征在于，調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行處理，將得到的中間業務數據保存至所述第二分布式消息隊列包括以下至少之一：

調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行轉換處理，將得到的中間業務數據保存至所述第二分布式消息隊列；

調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行連接處理，將得到的中間業務數據保存至所述第二分布式消息隊列；

調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行聚合處理，將得到的中間業務數據保存至所述第二分布式消息隊列；

調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行窗口操作，將得到的中間業務數據保存至所述第二分布式消息隊列。

4.根據權利要求1所述的方法，其特征在于，通過流處理系統對所述第二分布式消息隊列中的中間業務數據進行處理包括：

在所述流處理系統中多個第二業務處理模塊的任一業務處理模塊被觸發時，通過所述任一業務處理模塊對所述第二分布式消息隊列中的中間業務數據進行處理，將處理得到的結果保存至數據庫。

5.根據權利要求1至4中任意一項所述的方法，其特征在于，在獲取第一分布式消息隊列中的原始業務數據之前，所述方法還包括：

在所述流處理系統中配置多個第一業務處理模塊和多個第二業務處理模塊，其中，所述多個第一業務處理模塊被設置為允許并行運行，所述多個第二業務處理模塊被設置為允許并行運行。

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

獲取單元，用于獲取第一分布式消息隊列中的原始業務數據，其中，所述第一分布式消息隊列用于保存來源于數據源的原始業務數據；

保存單元，用于將對所述原始業務數據進行處理過的中間業務數據保存至第二分布式消息隊列，其中，每個所述第二分布式消息隊列用于保存一種類型的中間業務數據；

處理單元，用于通過流處理系統對所述第二分布式消息隊列中的中間業務數據進行處理。

7.根據權利要求6所述的裝置，其特征在于，所述保存單元還用于：

調用所述流處理系統的第一業務處理模塊，對所述原始業務數據進行處理，將得到的中間業務數據保存至所述第二分布式消息隊列。

8.一種業務數據的處理系統，其特征在于，包括：

第一分布式消息隊列，用于保存來源于數據源的原始業務數據；

流處理系統，用于將對所述原始業務數據進行處理過的中間業務數據保存至第二分布式消息隊列，并對所述第二分布式消息隊列中的中間業務數據進行處理，其中，所述流處理系統中的每個所述第二分布式消息隊列用于保存一種類型的中間業務數據。

9.一種存儲介質，其特征在于，所述存儲介質包括存儲的程序，其中，所述程序運行時執行上述權利要求1至5任一項中所述的方法。

10.一種電子裝置，包括存儲器、處理器及存儲在所述存儲器上并可在所述處理器上運行的計算機程序，其特征在于，所述處理器通過所述計算機程序執行上述權利要求1至5任一項中所述的方法。