[發明專利]用戶行為數據的處理方法及裝置、計算機設備、存儲介質

在審

• 申請號: 202010896909.5
• 申請日: 2020-08-31
• 公開（公告）號: CN112017007A
• 公開（公告）日: 2020-12-01
• 發明（設計）人: 汪兆千
• 申請（專利權）人: 中國平安財產保險股份有限公司
• 主分類號: G06Q30/06
• 分類號: G06Q30/06;G06Q30/02;G06F16/27;G06Q40/08
• 代理公司: 北京中強智尚知識產權代理有限公司 11448
• 代理人: 黃耀威

1.一種用戶行為數據的處理方法，應用于軟件即服務SaaS平臺，所述SaaS平臺安裝于服務器中，其特征在于，所述SaaS平臺至少包括配置模塊和Flink引擎，所述方法包括：

獲取在客戶端的操作界面上操作的用戶行為數據；

通過所述配置模塊對所述用戶行為數據進行預定義，得到預定義數據；

通過所述Flink引擎處理所述預定義數據，以確定與所述用戶行為數據匹配的業務規則；

基于所述業務規則向所述客戶端推送目標業務，并在所述客戶端的操作界面上展示所述目標業務。

2.根據權利要求1所述的方法，其特征在于，獲取在客戶端的操作界面上操作的用戶行為數據包括：

獲取所述客戶端實時上報的加密后的埋點數據，其中，所述客戶端的操作界面上埋入預設程序，所述預設程序用于實時采集用戶的行為數據；

對所述埋點數據進行解密，得到所述用戶行為數據。

3.根據權利要求1所述的方法，其特征在于，將所述用戶行為數據寫入區塊鏈節點中，所述通過所述配置模塊對所述用戶行為數據進行預定義，得到預定義數據包括：

所述通過所述配置模塊預定義所述用戶行為數據的數據源；

所述通過所述配置模塊根據所述用戶行為數據的數據源預定義所述用戶行為數據的場景，并根據所述場景預定義所述場景選擇使用的數據源；

所述通過所述配置模塊基于所述場景選擇使用的數據源預定義所述場景對應的原始變量所關聯的數據源；

所述通過所述配置模塊預定義所述場景對應的原始變量所關聯的數據源中的預定義業務規則，得到所述預定義數據。

4.根據權利要求1所述的方法，其特征在于，在通過所述Flink引擎處理所述預定義數據，以確定與所述用戶行為數據匹配的業務規則之前，所述方法還包括以下之一：

通過所述SaaS平臺的應用程序接口API將所述預定義數據存儲至所述SaaS平臺的緩存區；

通過所述SaaS平臺的消息緩存隊列將所述所述預定義數據寫入所述SaaS平臺的緩存區。

5.根據權利要求1所述的方法，其特征在于，通過所述Flink引擎處理所述預定義數據，以確定與所述用戶行為數據匹配的業務規則，包括：

通過所述SaaS平臺的應用程序接口API或消息緩存隊列實時讀取所述預定義數據；

基于接入的目標業務方，通過所述Flink引擎中的解析引擎利用正則表達式解析所述預定義數據中包含的預定義業務規則，以使所述預定義業務規則適應于所述業務方的執行引擎；

將所述預定義業務規則與所述目標業務方的目標業務規則進行匹配，以確定與所述用戶行為數據匹配的業務規則。

6.根據權利要求5所述的方法，其特征在于，將所述預定義業務規則與所述目標業務方的目標業務規則進行匹配，以確定與所述用戶行為數據匹配的業務規則，包括：

判斷所述預定義業務規則對應的第一閾值與所述目標業務規則對應的第二閾值是否相同；

若所述第一閾值與所述第二閾值不同，則通過所述Flink引擎中的改寫引擎將所述第一閾值改寫為所述第二閾值，并將改寫后的預定義業務規則作為與所述用戶行為數據匹配的業務規則；若所述第一閾值與所述第二閾值相同，則將所述預定義業務規則作為與所述用戶行為數據匹配的業務規則；

通過所述API接口或所述消息隊列輸出與所述用戶行為數據匹配的業務規則至所述Flink引擎中的執行引擎。

7.根據權利要求1所述的方法，其特征在于，基于所述業務規則向所述客戶推送目標業務包括：

通過所述Flink引擎運用邏輯與和邏輯或的運算方式執行與所述所述預定義數據匹配的業務規則；并向所述客戶端推送與所述業務規則對應的目標業務；或，

若所述業務規則有多個規則，通過所述Flink引擎中的歸并引擎從所述多個規則中篩選優先級較高的一個或多個規則；并向所述客戶端推送與所述一個或多個規則對應的目標業務。