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

有效

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

本發明一種實時推薦系統設計方法，包括：A.對業務系統數據庫進行實時數據采集，并發送到不同消息隊列中；B.根據不同消息隊列中的數據流，對不同數據流進行數據流與數據流之間的關聯，關聯之后形成一個結果流；C.對結果流與規則配置表進行動態關聯，輸出滿足規則的數據。本發明可以針對設置的不同的推薦規則，能夠立馬感知到規則變化，并應用與數據流中，實時輸出符合規則的數據，做到精準推薦。

技術領域

本發明涉及數據實時計算技術領域，具體涉及一種實時推薦系統設計方法。

背景技術

互聯網的出現和普及給用戶帶來了大量的信息，滿足了用戶在信息時代對信息的需求，但隨著網絡的迅速發展而帶來的網上信息量的大幅增長，使得用戶在面對大量信息時無法從中獲得對自己真正有用的那部分信息，對信息的使用效率反而降低了，這就是所謂的信息超載問題。解決信息超載問題一個非常有潛力的辦法是推薦系統，它是根據用戶的信息需求、興趣等，將用戶感興趣的信息、產品等推薦給用戶的個性化信息推薦系統。一個好的推薦系統不僅能為用戶提供個性化的服務，還能和用戶之間建立密切關系，讓用戶對推薦產生依賴。

提高信息推薦的及時性是提升用戶良好體驗的關鍵之一，因此實時推薦是對推薦系統的一種提升和優化。目前，企業有實時推薦的業務場景下，通常是利用離線數據倉庫概念，將相關數據存入數據庫，然后經過各種關聯關系篩選出符合規則的用戶，然后將邏輯封裝，通過調度器定時調度，隔天跑出前一天的滿足規則的用戶推送給業務部門或者采用小時的調度間隔跑批。

此方案不能實時動態感知和調整規則，不能實時篩選出滿足規則的用戶，導致用戶體驗感較差。

發明內容

針對現有方案中不能實時動態調整規則，用戶體驗感較差的問題，本發明提供了一種實時推薦系統設計方法。其目的在于能動態感知規則，及時調整，以便最大程度上讓推薦活動起到最好的效果給用戶良好的體驗。

本發明一種實時推薦系統設計方法，包括：

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

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

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

本發明通過對數據實時采集，收集到最新數據，進行數據流和數據流之間的匹配關聯；并實時采集規則配置表的數據，再次進行匹配關聯篩選出符合規則的數據。能夠針對設置的不同的推薦規則，立馬感知到規則變化，并應用于數據流中，實時輸出符合規則的數據，做到精準推薦。

進一步的，步驟A包括采集業務系統數據庫中數據日志，得到用戶修改的數據和對應的字段；根據數據所屬表的不同，將數據發送到不同的消息隊列中。

所述步驟A實時數據采集，獲取數據日志，得到相應的字段以便之后數據流之間進行匹配關聯。

進一步的，步驟B包括：

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

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

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

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