[發明專利]一種實時推薦系統設計方法

有效

• 申請號: 202010950935.1
• 申請日: 2020-09-11
• 公開（公告）號: CN111931066B
• 公開（公告）日: 2021-09-07
• 發明（設計）人: 田浩兵;張奎;陳思成
• 申請（專利權）人: 四川新網銀行股份有限公司
• 主分類號: G06F16/9535
• 分類號: G06F16/9535;G06F16/2458;G06F16/2455
• 代理公司: 成都智言知識產權代理有限公司 51282
• 代理人: 濮云杉

1.一種實時推薦系統設計方法，其特征在于，包括:

A.對業務系統數據庫進行實時數據采集，并發送到不同消息隊列中；

B.根據不同消息隊列中的數據流，對不同數據流進行數據流與數據流之間的關聯，關聯之后形成一個結果流；

C.對結果流與規則配置表進行動態關聯，實時輸出滿足規則的數據；

其中步驟C包括:

C1.實時采集規則配置表的數據日志，將數據發送到消息隊列d中；

C2.建立規則配置數據緩存器，對發送到消息隊列c中的數據進行同步緩存；

C3.消息隊列c中的結果流對存入緩存器的規則配置數據進行查詢和匹配，匹配后結果流與規則配置數據流進行關聯，實時輸出符合規則的數據。

2.如權利要求1所述的一種實時推薦系統設計方法，其特征在于：步驟A包括：采集業務系統數據庫中數據日志，得到用戶修改的數據和對應的字段；根據數據所屬表的不同，將數據發送到不同的消息隊列中。

3.如權利要求2所述的一種實時推薦系統設計方法，其特征在于：步驟B包括:

B1:建立緩存器，對發送到不同消息隊列中的數據分別進行同步緩存并且設置一個定時器；

B2：對消息隊列a中流入的數據流進行數據存儲，將先流入的數據流A存儲到數據庫中；

B3：另一消息隊列b中后流入的數據流B對存入數據庫中的數據流A進行查詢，讓其與數據流B通過相應的字段進行匹配關聯：如果數據流A與數據流B能夠匹配，則關聯數據流A和數據流B，并輸出關聯后的結果流到消息隊列c；如果數據流A與數據流B不能匹配，則進入緩存器中查詢數據流A，匹配后關聯數據流A和數據流B并且清空緩存，輸出關聯后的結果流到消息隊列c；

B4.針對緩存器中的每條數據配置數據失效時間，達到該時間時觸發清除機制，清除該條數據。