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

在審

• 申請號: 202211193176.4
• 申請日: 2022-09-28
• 公開（公告）號: CN115640319A
• 公開（公告）日: 2023-01-24
• 發明（設計）人: 劉增文;覃鵬;陳大平;李威;王澤龍;周建;康偉洲;吳曉文
• 申請（專利權）人: 中國建設銀行股份有限公司;建信金融科技有限責任公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458;G06F9/54
• 代理公司: 北京清亦華知識產權代理事務所(普通合伙) 11201
• 代理人: 張潤

1.一種業務數據處理方法，其特征在于，被實時數據處理引擎執行，所述方法包括：

獲取第一業務數據；

根據所述第一業務數據的數據類型，向目標數據庫發送數據獲取消息，其中，所述數據獲取消息參考數據處理周期生成，所述數據處理周期由所述數據類型確定；

接收所述目標數據庫發送的第二業務數據，其中，所述第二業務數據是所述目標數據庫基于所述數據處理周期查詢得到；以及

聚合所述第一業務數據和所述第二業務數據，得到目標業務數據。

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

確定所述第一業務數據的獲取時間信息；

根據所述數據處理周期和所述獲取時間信息，生成數據存儲消息，其中，所述數據存儲消息用于將所述目標業務數據存儲至所述目標數據庫；以及

向所述目標數據庫發送所述數據存儲消息和所述目標業務數據。

3.如權利要求2所述的方法，其特征在于，所述根據所述數據處理周期和所述獲取時間信息，生成數據存儲消息，包括：

獲取所述第一業務數據所屬數據源的源標識；

根據所述源標識、所述數據處理周期，以及所述獲取時間信息，生成所述目標業務數據的索引項；以及

根據所述目標業務數據和所述索引項，生成所述數據存儲消息，其中，所述數據存儲消息用于基于所述索引項將所述目標業務數據存儲至所述目標數據庫。

4.如權利要求3所述的方法，其特征在于，所述根據所述源標識、所述數據處理周期，以及所述獲取時間信息，生成所述目標業務數據的索引項，包括：

獲取所述數據處理周期對應的周期標識；

根據所述獲取時間信息和所述周期標識，生成處理時間標識；以及

對所述源標識、所述周期標識，以及所述處理時間標識進行拼接，并將拼接所得結果作為所述目標業務數據的索引項。

5.如權利要求4所述的方法，其特征在于，所述根據第一業務數據的數據類型，向目標數據庫發送數據獲取消息，其中，所述數據獲取消息參考數據處理周期生成，所述數據處理周期由所述數據類型確定，包括：

根據所述獲取時間信息和所述數據處理周期，生成獲取時間標識；

根據所述獲取時間標識，生成所述數據獲取消息，其中，所述獲取時間標識用于使所述目標數據庫查詢得到所述第二業務數據；

向所述目標數據庫發送所述數據獲取消息。

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

根據所述目標業務數據，生成數據更新消息，其中，所述數據更新消息用于更新所述目標數據庫中的所述第二業務數據；

向所述目標數據庫發送所述數據更新消息。

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

根據所述第一業務數據的數據類型，確定數據存儲的時長閾值；

確定所述目標業務數據在所述目標數據庫中的存儲時長；

如果所述存儲時長達到所述時長閾值，則生成數據釋放消息，其中，所述數據釋放消息用于釋放所述目標數據庫中的所述目標業務數據；

向所述目標數據庫發送所述數據釋放消息。

8.如權利要求1-7任一項所述的方法，其特征在于，所述方法還包括：

接收數據查詢請求，其中，所述數據查詢請求包括：源標識、數據類型，以及獲取時間信息；

根據所述數據類型，確定所述數據處理周期；

根據所述源標識、所述獲取時間信息，以及所述數據處理周期，生成數據查詢消息，其中，所述數據查詢消息用于從所述目標數據庫中查詢所述目標業務數據；

向所述目標數據庫發送所述數據查詢消息。