[發明專利]實時數倉的風控聯動預警方法、系統、設備及存儲介質

有效

• 申請號: 202110444985.7
• 申請日: 2021-04-24
• 公開（公告）號: CN113222223B
• 公開（公告）日: 2023-02-21
• 發明（設計）人: 葛昊
• 申請（專利權）人: 上海鋼銀科技發展有限公司
• 主分類號: G06Q10/04
• 分類號: G06Q10/04;G06Q10/0635;G06Q10/0639;G06F16/28;G06F9/54
• 代理公司: 北京維正專利代理有限公司 11508
• 代理人: 張惠敏

1.實時數倉的風控聯動預警方法，其特征在于，包括：

預警模型配置，基于業務預先配置不同業務的風控預警模型，所述風控預警模型為基于業務配置其各標準mysql數據庫的預警條件；

數據預警指標定義，基于標準mysql數據庫定義數據不同風險區間的風險指標，包括授信指標、黑名單指標、白名單指標；

預警指標取數，為不同業務的風控預警模型中對應的預警條件配置不同風險區間的數據預警指標；

數據抽取，基于業務將mysql數據庫中的數據抽取至消息隊列Kafka中；

數據轉換，基于根據用戶需求預先在mysql數據庫中配置的轉換策略對進入消息隊列Kafka中的數據進加，包括：設置默認值、數據匯總、以其他數據庫的數據作為取值條件，以及上傳腳本描述；

數據加載，基于預先在mysql數據庫中配置的數據來源地和目標地的對應關系，將進加后的數據加載至標準mysql數據庫；

風險指標計算，為計算各標準mysql數據庫內各數據風險指標值；

預警監控，基于對應業務配置的風控預警模型及風控預警模型對應的數據預警指標對數據的風險指標進行監控，包括：

基于風控預警模型提取對應標準mysql數據庫內各數據風險指標值；

將提取的標準mysql數據庫內各數據風險指標值與其對應的數據預警指標進行比對，區分數據風險區間。

2.根據權利要求1所述的實時數倉的風控聯動預警方法，其特征在于，數據抽取步驟具體為：通過偽裝成mysql的slave獲取數據的binlog日志，并進行解析，并將解析到的數據發往Kafka隊列中。

3.根據權利要求2所述的實時數倉的風控聯動預警方法，其特征在于，將解析的binlog日志進度的標識保存至Redis中，通過改變Redis中相應的數值，以切換binlog的解析進度；同時，通過Zookeeper實現分布多節點。

4.根據權利要求1所述的實時數倉的風控聯動預警方法，其特征在于，所述數據轉換和數據加載在同一個consumer服務器控件中完成，consumer消費Kafka中的加工前的原始數據；

consumer服務器控件從在mysql數據庫中獲取轉換策略，然后通過動態代理成對象，將相應的轉換策略保存至該代理對象中；

consumer服務器控件從Kafka中消費加工前的原始數據，根據原始數據找到對應的動態代理對象，該動態代理對象根據配置中的轉換策略對原始數據進加；

再根據配置的數據來源地和目標地的對應關系將加工好的數據存儲至標準mysql數據庫。

5.實時數倉的風控聯動預警系統，其特征在于，包括：

數據抽取單元（1），用于將mysql數據庫中的數據抽取至消息隊列Kafka中；

轉換策略配置單元（21），用于配置數據的轉換策略；

溯源關系配置單元（22），用于配置數據來源地和目標地的對應關系，并存儲至mysql數據庫；

預警模型配置單元（23），用于基于業務配置不同業務的風控預警模型；

數據預警指標配置單元（24），用于基于標準mysql數據庫定義數據不同風險區間的風險指標；

預警指標取數（25），用于為不同業務的風控預警模型配置對應的數據預警指標；

數據轉換單元（3），用于基于根據用戶需求預先在mysql數據庫中配置的轉換策略對進入消息隊列Kafka中的數據進加；

數據加載單元（4），用于基于預先在mysql數據庫中配置的數據來源地和目標地的對應關系，將進加后的數據加載至標準mysql數據庫；

風險指標計算單元（5），用于計算數據的分享指標；

預警監控單元（6），用于基于對應業務配置的風控預警模型及風控預警模型對應的數據預警指標對數據的風險指標進行監控。

6.一種計算機設備，其特征在于，包括存儲器和處理器，所述存儲器上存儲有能夠被處理器加載并執行如權利要求1至4中任一種方法的計算機程序。

7.一種計算機可讀存儲介質，其特征在于，存儲有能夠被處理器加載并執行如權利要求1至4中任一種方法的計算機程序。