[發明專利]一種風險偵測方法、裝置、電子設備和可讀存儲介質

在審

• 申請號: 202110077003.5
• 申請日: 2021-01-20
• 公開（公告）號: CN112766975A
• 公開（公告）日: 2021-05-07
• 發明（設計）人: 洪湃;宋倩;褚中成;曾常安;解安芳
• 申請（專利權）人: 中信銀行股份有限公司
• 主分類號: G06Q20/40
• 分類號: G06Q20/40;G06F9/54
• 代理公司: 北京市蘭臺律師事務所 11354
• 代理人: 張峰

1.一種風險偵測方法，其特征在于，所述方法包括：

將獲取的目標用戶的目標交易數據存儲于Kafka消息系統；

基于Apache Storm的程序讀取Kafka消息系統中的目標交易數據；

基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理并輸出分析結果；

如果所述分析結果符合預設的風險告警規則，則啟動風險告警。

2.根據權利要求1所述的風險偵測方法，其特征在于，所述將獲取的目標用戶的目標交易數據存儲于Kafka消息系統包括：

提取所述目標交易數據至少一個特征信息；其中所述目標交易數據至少包括以下特征信息：目標用戶身份信息、目標交易卡片信息、目標交易類型、目標交易方向、目標交易時間、目標交易地理位置、目標交易金額；

根據所述提取的至少一個特征信息將所述目標交易數據劃分為N個分片；

將所述N個分片存儲于所述Kafka消息系統。

3.根據權利要求2所述的風險偵測方法，其特征在于，在基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理之前，所述方法還包括：

將所述N個分片的目標交易數據存儲于Cassandra數據庫。

4.根據權利要求3所述的風險偵測方法，其特征在于，所述基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理包括：

解析N個分片的目標交易數據中特征信息并處理為可以被Esper處理的格式數據；

將所述處理的格式目標交易數據存儲于Cassandra數據庫；

根據解析的特征信息和預存規則配置表，生成風險偵測規則；

Esper讀取Cassandra數據庫中的目標交易數據，并按照所述的風險偵測規則對所述的目標交易數據進行分析處理。

5.根據權利要求4所述的風險偵測方法，其特征在于，所述啟動風險告警包括：

將所述風險告警信息發送至Kafka消息系統；

所述Kafka消息系統根據所述風險告警信息向系統發送風險處置消息。

6.根據權利要求5所述的風險偵測方法，其特征在于，所述基于Apache Storm和Esper復雜事件處理組件的程序分別讀取N個分片的目標數據。

7.根據權利要求1-6任一項所述的風險偵測方法，其特征在于，所述方法還包括：

在Esper組件中構建時間窗口；其中所述時間窗口具有可編輯的顯示界面；

所述時間窗口可用于寫入目標交易數據和風險偵測規則。

8.一種風險偵測裝置，其特征在于，所述裝置包括：讀取模塊、存儲模塊、處理模塊、輸出模塊、判斷模塊和告警模塊，其中，

所述讀取模塊，用于獲取的目標用戶的目標交易數據；

所述存儲模塊，用于將獲取的目標用戶的目標交易數據存儲于Kafka消息系統；

所述讀取模塊，還用于基于Apache Storm的程序讀取Kafka消息系統中的目標交易數據；

所述處理模塊，還用于基于Apache Storm和Esper復雜事件處理組件的程序對所述目標交易數據進行分析處理；

所述輸出模塊，還用于輸出分析結果；

所述判斷模塊，用于判斷所述分析結果是否符合預設的風險告警規則；

所述告警模塊，用于啟動風險告警。

9.一種電子設備，其特征在于，包括處理器和存儲器；

所述存儲器，用于存儲操作指令；

所述處理器，用于通過調用所述操作指令，執行權利要求1-7中任一項所述的方法。

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