[發(fā)明專利]一種基于分布式實時計算的能源商品及能源需求的精準推送方法

在審

• 申請?zhí)枺?/td>: 202110955296.2
• 申請日: 2021-08-19
• 公開（公告）號: CN113852664A
• 公開（公告）日: 2021-12-28
• 發(fā)明（設計）人: 胡浩瀚;郭正雄;張立;楊少春;張海濤;朱傳晶;張志陶;劉萬龍;許娜;李艷
• 申請（專利權）人: 天津市普迅電力信息技術有限公司;國網信息通信產業(yè)集團有限公司
• 主分類號: H04L29/08
• 分類號: H04L29/08;G06Q30/06;G06F16/9535
• 代理公司: 天津盛理知識產權代理有限公司 12209
• 代理人: 董一寧

一種基于分布式實時計算的能源商品及能源需求的精準推送方法，包括以下步驟：步驟一：用戶操作日志采集，負責采集用戶在網頁端或APP端產生的各類點擊日志；步驟二：數據緩沖，與日志采集部分對接，利用消息中間件接收并緩存日志消息，與實時計算部分對接，將日志消息傳遞給計算程序；步驟三：混合分布式計算，綜合利用各種數據，實時產生針對能源用戶或能源服務商的推送結果；步驟四：數據存儲，用于存儲能源用戶信息等，便于步驟一種的用戶調取實用。該推送方法實現針對能源商品及能源需求的智能化、個性化、精準化的推送系統(tǒng)。幫助能源用戶快速找到自己需要的能源商品，幫助能源服務商快速找到目標能源客戶，促進供需共贏。

技術領域

本發(fā)明涉及大數據推送技術領域，具體為一種基于分布式實時計算的能源商品及能源需求的精準推送方法。

背景技術

隨著能源行業(yè)的飛速發(fā)展,電子商務在能源市場的參與度也越來越高.打造一個能源市場的“淘寶”，讓其中用戶發(fā)布需求，服務商發(fā)布商品，則可以充分發(fā)揮市場服務對接的紐帶作用，會吸引全社會能源用戶和各類能源服務商在此開展服務。而市場的商品推送系統(tǒng)則是其中的關鍵,推送系統(tǒng)是自動聯系用戶和商品的一種工具，它通過收集市場與用戶的各類信息，然后根據這些行為數據，分析出一定的規(guī)則或者直接對用戶對其他物品的喜好進行預測計算。從而主動給用戶推送可滿足他們興趣和需求的信息。每個用戶所得到的推送信息都是與自己的行為特征和興趣有關的，而不是籠統(tǒng)的大眾化信息。一是可以反映用戶對物品的真實喜好,對用戶線上和線下行為進行深度洞察,提高用戶時間效率.二是提高了商家的個性化服務，進一步提升顧客在店鋪的消費體驗。

現有推送系統(tǒng)的推送結果產生基于全品類商品熱度統(tǒng)計，沒有采用分析用戶的歷史行為來對用戶的興趣進行分析，無法針對具體用戶產生個性化、精準化的推送結果。而且一般的實現方案是基于離線統(tǒng)計實現，推送結果產生存在滯后性。推送結果類型單一，沒有針對用戶當下及歷史感興趣商品做區(qū)別推送。其次現有推送系統(tǒng)沒有綜合考慮商品評分、用戶消費水平等重要影響因素。再其次沒有針對能源用戶需求的推送實現方案。

所以為了讓商家更了解用戶，推送系統(tǒng)既要服務于電商，更要服務于用戶，提高推送結果精準度是現有技術中亟待解決的技術問。

通過公開專利檢索，發(fā)現以下對比文件：

CN111061807A-公開了一種分布式數據采集分析系統(tǒng)及方法、服務器及介質，其通過不同的采集方式全面對數據進行采集，采用分布式架構有效的橫向擴展數據量的增加，且kafka數據庫高吞吐量優(yōu)勢滿足直接數據采集和傳輸需求。數據提取單元采用腳本語言實現，能夠在線及時修改調試，同時規(guī)則引擎子單元的使用能夠動態(tài)分配數據,靈活性的數據分發(fā)為系統(tǒng)的擴展性提供了基礎。

經分析，上述專利中的分布式數據采集分析系統(tǒng)與本申請相比，在實時計算功能等方面存在較大差異，因此不影響本申請的信用行。

發(fā)明內容

本發(fā)明的目的在于克服現有技術的不足之處，提供一種基于分布式實時計算的能源商品及能源需求的精準推送方法，該方法實現針對能源商品及能源需求的智能化、個性化、精準化的推送系統(tǒng)。幫助能源用戶快速找到自己需要的能源商品，幫助能源服務商快速找到目標能源客戶，促進供需雙方合作，實現雙方共贏。

一種基于分布式實時計算的能源商品及能源需求的精準推送方法，包括以下步驟：

步驟一：用戶操作日志采集，負責采集用戶在網頁端或APP端產生的各類點擊日志；

步驟二：數據緩沖，與日志采集部分對接，利用消息中間件接收并緩存日志消息，與實時計算部分對接，將日志消息傳遞給計算程序；

步驟三：混合分布式計算，將現有獨立式的流計算與批計算融合為混合分布式計算，處理實時流數據的同時利用自定義累加器在內存中計算并維護批量數據統(tǒng)計指標，實時產生針對能源用戶或能源服務商的推薦結果；