[發明專利]金融指標分布式計算方法及其系統

有效

• 申請號: 201810347176.2
• 申請日: 2018-04-18
• 公開（公告）號: CN108573348B
• 公開（公告）日: 2021-01-01
• 發明（設計）人: 汪金洋
• 申請（專利權）人: 鑫涌算力信息科技（上海）有限公司
• 主分類號: G06Q10/06
• 分類號: G06Q10/06;G06Q40/02
• 代理公司: 上海翰信知識產權代理事務所(普通合伙) 31270
• 代理人: 張維東

1.一種金融中用戶指標分布式計算方法，其特征在于，包括以下步驟：

步驟1，將用戶指標計算分為三種指標計算類型：離線計算、業務觸發計算、以及數據源變更觸發計算；

步驟2，定義用戶指標，包括用戶指標屬性和指標算子，定義的所述指標算子包括定義指標計算時使用的數據源、指標計算邏輯、指標計算類型，所述指標算子中指標計算類型至少為一個；

步驟3，定義觸發三種指標計算類型的條件；

步驟4，根據用戶指標所屬的指標計算類型，在觸發條件發生時采用與觸發條件對應的指標計算類型進行指標計算；

步驟5，存儲計算好的用戶指標。

2.根據權利要求1所述的金融中用戶指標分布式計算方法，其特征在于：

其中，離線計算指標的觸發條件為滿足下列任一條件：

當新增用戶指標或者更新指標計算邏輯時；

需要定時更新的用戶指標，達到更新時間時；

業務觸發計算指標實時計算壓力過重時，低優先級指標自動降級到離線計算指標處理，或數據源變更觸發計算指標時檢測到內存隊列中任務數量超過規定的閾值后，將內存隊列中低優先級指標任務降權到離線計算指標處理；

當上下游數據源發生問題導致數據出錯、丟失或延遲時，或業務人員發現某些指標計算有問題時。

3.根據權利要求1所述的金融中用戶指標分布式計算方法，其特征在于：

其中，業務觸發計算指標的觸發條件為：

新用戶注冊后。

4.根據權利要求1所述的金融中用戶指標分布式計算方法，其特征在于：

其中，數據源變更觸發計算指標的觸發條件為：數據源變更和/或指標計算邏輯改變。

5.根據權利要求1所述的金融中用戶指標分布式計算方法，其特征在于：

其中，數據源變更觸發計算的計算方法為：

在數據源和/或指標計算邏輯變更后，找出指標類型為數據源變更觸發計算的指標在計算時需要的數據源，將變更了數據源和/或指標計算邏輯的指標放入數據源變更觸發計算內存隊列；

從數據源變更觸發計算內存隊列中批量獲取指標，進行預處理；

將預處理后的指標根據變更后的數據源和/或指標計算邏輯進行計算；

將計算后的用戶指標進行存儲。

6.根據權利要求5所述的金融中用戶指標分布式計算方法，其特征在于：

其中，對數據源變更觸發計算內存隊列中指標進行預處理的方法為：

對用戶指標進行去重、同一個數據源變更時間聚合操作。

7.一種金融中用戶指標分布式計算系統，其特征在于，包含：

注冊中心，用于存儲用戶指標和與所述用戶指標對應的指標算子；

數據源變更指標計算模塊，用于在數據源或指標算子計算邏輯變更時批量計算用戶指標；

業務觸發指標計算模塊，用于在新用戶注冊后計算用戶指標；

離線指標計算模塊，用于在離線指標計算觸發條件發生時采用離線的方式計算用戶指標；

觸發模塊，根據用戶指標所屬的指標計算類型，在觸發條件發生時觸發與觸發條件對應的所述數據源變更指標計算模塊或業務觸發指標計算模塊或離線指標計算模塊進行用戶指標計算；以及

指標存儲模塊，用于存儲計算后的用戶指標，

其中，所述離線指標計算觸發條件為滿足下列任一條件：

當新增用戶指標或者更新指標計算邏輯時；

需要定時更新的用戶指標，達到更新時間時；

業務觸發計算指標實時計算壓力過重時，低優先級指標自動降級到離線計算指標處理，或數據源變更觸發計算指標時檢測到內存隊列中任務數量超過規定的閾值后，將內存隊列中低優先級指標任務降權到離線計算指標處理；

當上下游數據源發生問題導致數據出錯、丟失或延遲時，或業務人員發現某些指標計算有問題時。