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

在審

• 申請號: 202010157583.4
• 申請日: 2020-03-09
• 公開（公告）號: CN111352803A
• 公開（公告）日: 2020-06-30
• 發明（設計）人: 張芳棟;袁青松
• 申請（專利權）人: 廣州市百果園信息技術有限公司
• 主分類號: G06F11/30
• 分類號: G06F11/30;G06F9/54
• 代理公司: 北京品源專利代理有限公司 11332
• 代理人: 孟金喆

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

根據消費進程對待處理業務數據進行業務處理；

確定所述消費進程異常時，根據守護進程對所述消費進程進行異常處理。

2.根據權利要求1所述的方法，其特征在于，所述根據消費進程對待處理業務數據進行業務處理，包括：

控制所述消費進程啟動，獲取數據待處理隊列中的待處理業務數據；

確定所述待處理業務數據未被處理時，控制所述消費進程處理所述待處理業務數據。

3.根據權利要求2所述的方法，其特征在于，所述數據待處理隊列為流處理集群隊列。

4.根據權利要求2所述的方法，其特征在于，所述確定所述待處理業務數據未被處理時，控制所述消費進程處理所述待處理業務數據，包括：

將所述待處理業務數據的記錄序號與數據緩存中的已處理業務數據的記錄序號進行對比；

若所述待處理業務數據的記錄序號大于所述已處理業務數據的記錄序號，控制所述消費進程對所述待處理業務數據進行業務處理。

5.根據權利要求4所述的方法，其特征在于，所述數據緩存包括分布式集群緩存。

6.根據權利要求1或2所述的方法，其特征在于，所述確定所述消費進程異常時，根據守護進程對所述消費進程進行異常處理，包括：

基于所述守護進程監測所述消費進程的運行參數；

確定所述運行參數異常時，重新啟動新的消費進程以處理所述待處理業務數據。

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

確定所述待處理業務數據的數量超過告警閾值時，發出處理性能下降告警。

8.根據權利要求7所述的方法，其特征在于，所述確定所述待處理業務數據的數量超過告警閾值時，發出處理性能下降告警，包括：

獲取數據待處理隊列中的待處理數據的數量；

若所述數量大于所述告警閾值，則生成處理性下降告警并根據所述處理效降告警進行警報。

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

業務處理模塊，用于根據消費進程對待處理業務數據進行業務處理；

異常處理模塊，用于確定所述消費進程異常時，根據守護進程對所述消費進程進行異常處理。

10.一種設備，其特征在于，所述設備包括：

一個或多個處理器；

存儲器，用于存儲一個或多個程序，當所述一個或多個程序被所述一個或多個處理器執行，使得所述一個或多個處理器實現如權利要求1-8中任一所述的業務數據處理方法。

11.一種計算機可讀存儲介質，其上存儲有計算機程序，其特征在于，該程序被處理器執行時實現如權利要求1-8中任一所述的業務數據處理方法。