[發(fā)明專利]一種用戶分布信息的獲取方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201611104620.5
• 申請(qǐng)日: 2016-12-05
• 公開（公告）號(hào): CN108156197B
• 公開（公告）日: 2021-02-05
• 發(fā)明（設(shè)計(jì)）人: 王昌坤
• 申請(qǐng)（專利權(quán)）人: 北京國(guó)雙科技有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08
• 代理公司: 北京集佳知識(shí)產(chǎn)權(quán)代理有限公司 11227
• 代理人: 王寶筠

本申請(qǐng)公開了一種用戶分布信息的獲取方法及裝置，方法包括：實(shí)時(shí)獲取用戶的操作信息；提取所述操作信息中用戶的位置信息；在預(yù)先為用戶設(shè)置的分布表中查找是否存在與所述位置信息相對(duì)應(yīng)的區(qū)域標(biāo)識(shí)，所述分布表包括區(qū)域標(biāo)識(shí)及所述區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值；如果存在，將所述分布表中所述區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值增加預(yù)設(shè)的增量值；如果不存在，在所述分布表中設(shè)置與所述位置信息相對(duì)應(yīng)的區(qū)域標(biāo)識(shí)，并將新設(shè)置的區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值設(shè)置為預(yù)設(shè)的初始值。本申請(qǐng)中通過實(shí)時(shí)對(duì)操作信息進(jìn)行位置信息的提取并進(jìn)行表的設(shè)置，無需直接對(duì)數(shù)據(jù)庫(kù)進(jìn)行查詢或數(shù)據(jù)統(tǒng)計(jì)等操作，加快用戶分布信息的計(jì)算速率，實(shí)現(xiàn)本申請(qǐng)目的。

技術(shù)領(lǐng)域

本發(fā)明涉及流數(shù)據(jù)處理技術(shù)領(lǐng)域，特別涉及一種用戶分布信息的獲取方法及裝置。

背景技術(shù)

在數(shù)據(jù)爆炸的時(shí)代，流處理計(jì)算成為當(dāng)下熱門的研究領(lǐng)域，高效與快速的特性也成為主要研究的重點(diǎn)。而如何在流處理中計(jì)算用戶在地域或區(qū)域中的分布情況，也是一種值得研究的方案。

現(xiàn)有技術(shù)中，通過實(shí)時(shí)的將數(shù)據(jù)寫入到數(shù)據(jù)庫(kù)中，再通過數(shù)據(jù)庫(kù)的sql查詢，得到用戶分布情況的查詢結(jié)果。

但現(xiàn)有技術(shù)中的方案雖然簡(jiǎn)單，但在大數(shù)據(jù)量的情況下，通過這種方案計(jì)算的速度過慢，無法滿足流處理的需要。

發(fā)明內(nèi)容

鑒于上述問題，提出了本申請(qǐng)以便提供一種克服或者至少部分地解決現(xiàn)有技術(shù)中用戶分布信息計(jì)算的速率過慢的技術(shù)問題。

本申請(qǐng)?zhí)峁┝艘环N用戶分布信息的獲取方法，包括：

實(shí)時(shí)獲取用戶的操作信息；

提取所述操作信息中用戶的位置信息；

在預(yù)先為用戶設(shè)置的分布表中查找是否存在與所述位置信息相對(duì)應(yīng)的區(qū)域標(biāo)識(shí)，所述分布表包括區(qū)域標(biāo)識(shí)及所述區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值；如果存在，將所述分布表中所述區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值增加預(yù)設(shè)的增量值；如果不存在，在所述分布表中設(shè)置與所述位置信息相對(duì)應(yīng)的區(qū)域標(biāo)識(shí)，并將新設(shè)置的區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值設(shè)置為預(yù)設(shè)的初始值。

上述方法，優(yōu)選的，還包括：

接收查詢請(qǐng)求，所述查詢請(qǐng)求用于請(qǐng)求返回用戶的區(qū)域分布狀態(tài)，且所述查詢請(qǐng)求中至少包括用戶標(biāo)識(shí)；

基于所述查詢請(qǐng)求，將所述用戶標(biāo)識(shí)對(duì)應(yīng)的分布表進(jìn)行返回。

上述方法，優(yōu)選的，在所述提取所述操作信息中用戶的位置信息之后，所述方法還包括：

將所述位置信息寫入到預(yù)設(shè)的總表中，使得所述總表中包括用戶所有操作信息中的位置信息。

上述方法，優(yōu)選的，還包括：

接收查詢請(qǐng)求，所述查詢請(qǐng)求至少包括用戶標(biāo)識(shí)；

監(jiān)測(cè)所述操作信息的流處理過程中是否生成故障信息，如果生成故障信息，將所述用戶標(biāo)識(shí)對(duì)應(yīng)的總表進(jìn)行返回，如果沒有生成故障信息，將所述用戶標(biāo)識(shí)對(duì)應(yīng)的分布表進(jìn)行返回。

本申請(qǐng)還提供了一種用戶分布信息的獲取裝置，包括：

操作獲取單元，用于實(shí)時(shí)獲取用戶的操作信息；

位置提取單元，用于提取所述操作信息中用戶的位置信息；

標(biāo)識(shí)查找單元，用于在預(yù)先為用戶設(shè)置的分布表中查找是否存在與所述位置信息相對(duì)應(yīng)的區(qū)域標(biāo)識(shí)，所述分布表中包括區(qū)域標(biāo)識(shí)及所述區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值；如果存在，觸發(fā)數(shù)值累加單元，如果不存在，觸發(fā)標(biāo)識(shí)設(shè)置單元；

數(shù)值累加單元，用于將所述分布表中所述區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值增加預(yù)設(shè)的增量值；

標(biāo)識(shí)設(shè)置單元，用于在所述分布表中設(shè)置與所述位置信息相對(duì)應(yīng)的區(qū)域標(biāo)識(shí)，并將新設(shè)置的區(qū)域標(biāo)識(shí)對(duì)應(yīng)的數(shù)值設(shè)置為預(yù)設(shè)的初始值。