[發(fā)明專利]數(shù)據(jù)關(guān)聯(lián)方法及裝置

有效

• 申請(qǐng)?zhí)枺?/td>: 201810219031.4
• 申請(qǐng)日: 2018-03-16
• 公開（公告）號(hào): CN108616415B
• 公開（公告）日: 2020-11-27
• 發(fā)明（設(shè)計(jì)）人: 朱磊;吳昊
• 申請(qǐng)（專利權(quán)）人: 新華三大數(shù)據(jù)技術(shù)有限公司
• 主分類號(hào): H04L12/26
• 分類號(hào): H04L12/26;H04L29/08;H04L29/06;H04L29/12
• 代理公司: 北京林達(dá)劉知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11277
• 代理人: 劉新宇

1.一種數(shù)據(jù)關(guān)聯(lián)方法，其特征在于，所述方法包括：

按照第一頻率獲取用戶認(rèn)證數(shù)據(jù)和終端在線數(shù)據(jù)，并將包括相同的標(biāo)識(shí)的所述用戶認(rèn)證數(shù)據(jù)和所述終端在線數(shù)據(jù)進(jìn)行整合處理，得到用戶在線數(shù)據(jù)，將所述用戶在線數(shù)據(jù)持久化到用戶在線數(shù)據(jù)表中；其中，所述用戶認(rèn)證數(shù)據(jù)包括用戶IP地址和帳號(hào)名；所述終端在線數(shù)據(jù)包括用戶IP地址和接入設(shè)備序列號(hào)；

實(shí)時(shí)獲取流量日志，并對(duì)所述流量日志進(jìn)行流式數(shù)據(jù)處理，得到網(wǎng)絡(luò)行為數(shù)據(jù)，將所述網(wǎng)絡(luò)行為數(shù)據(jù)持久化到網(wǎng)絡(luò)行為數(shù)據(jù)表中；

按照第二頻率，從所述用戶在線數(shù)據(jù)表、所述網(wǎng)絡(luò)行為數(shù)據(jù)表和接入設(shè)備位置數(shù)據(jù)表中，將包括相同的標(biāo)識(shí)的所述用戶在線數(shù)據(jù)、所述網(wǎng)絡(luò)行為數(shù)據(jù)和接入設(shè)備位置數(shù)據(jù)進(jìn)行關(guān)聯(lián)；所述第二頻率小于或等于所述第一頻率。

2.根據(jù)權(quán)利要求1所述的方法，其特征在于，按照第一頻率獲取用戶認(rèn)證數(shù)據(jù)和終端在線數(shù)據(jù)，包括：

按照所述第一頻率，通過應(yīng)用程序編程接口API分別獲取所述用戶認(rèn)證數(shù)據(jù)和所述終端在線數(shù)據(jù)。

3.根據(jù)權(quán)利要求1所述的方法，其特征在于，對(duì)所述流量日志進(jìn)行流式數(shù)據(jù)處理，得到網(wǎng)絡(luò)行為數(shù)據(jù)，包括：

將實(shí)時(shí)獲取的所述流量日志分發(fā)到消息隊(duì)列，并根據(jù)解析協(xié)議對(duì)所述消息隊(duì)列輸出的流量日志進(jìn)行解析處理，得到所述網(wǎng)絡(luò)行為數(shù)據(jù)。

4.根據(jù)權(quán)利要求1至3任一所述的方法，其特征在于，

所述網(wǎng)絡(luò)行為數(shù)據(jù)包括用戶IP地址、應(yīng)用名稱、上傳流量、下載流量、統(tǒng)計(jì)開始時(shí)間和統(tǒng)計(jì)結(jié)束時(shí)間；

所述接入設(shè)備位置數(shù)據(jù)包括接入設(shè)備序列號(hào)和對(duì)應(yīng)的接入設(shè)備位置。

5.根據(jù)權(quán)利要求4所述的方法，其特征在于，將包括相同的標(biāo)識(shí)的所述用戶認(rèn)證數(shù)據(jù)和所述終端在線數(shù)據(jù)進(jìn)行整合處理，得到用戶在線數(shù)據(jù)，包括：

將包括相同的用戶IP地址的所述用戶認(rèn)證數(shù)據(jù)和所述終端在線數(shù)據(jù)進(jìn)行整合處理，得到所述用戶在線數(shù)據(jù)；

所述用戶在線數(shù)據(jù)包括：用戶IP地址、帳號(hào)名和接入設(shè)備序列號(hào)。

6.根據(jù)權(quán)利要求5所述的方法，其特征在于，將包括相同的標(biāo)識(shí)的所述用戶在線數(shù)據(jù)、所述網(wǎng)絡(luò)行為數(shù)據(jù)和接入設(shè)備位置數(shù)據(jù)進(jìn)行關(guān)聯(lián)，包括：

將包括相同的用戶IP地址的所述用戶在線數(shù)據(jù)和所述網(wǎng)絡(luò)行為數(shù)據(jù)進(jìn)行關(guān)聯(lián)；

將包括相同的接入設(shè)備序列號(hào)的所述用戶在線數(shù)據(jù)和所述接入設(shè)備位置數(shù)據(jù)進(jìn)行關(guān)聯(lián)。

7.一種數(shù)據(jù)關(guān)聯(lián)裝置，其特征在于，所述裝置包括：

第一處理模塊，用于按照第一頻率獲取用戶認(rèn)證數(shù)據(jù)和終端在線數(shù)據(jù)，并將包括相同的標(biāo)識(shí)的所述用戶認(rèn)證數(shù)據(jù)和所述終端在線數(shù)據(jù)進(jìn)行整合處理，得到用戶在線數(shù)據(jù)，將所述用戶在線數(shù)據(jù)持久化到用戶在線數(shù)據(jù)表中；其中，所述用戶認(rèn)證數(shù)據(jù)包括用戶IP地址和帳號(hào)名；所述終端在線數(shù)據(jù)包括用戶IP地址和接入設(shè)備序列號(hào)；

第二處理模塊，用于實(shí)時(shí)獲取流量日志，并對(duì)所述流量日志進(jìn)行流式數(shù)據(jù)處理，得到網(wǎng)絡(luò)行為數(shù)據(jù)，將所述網(wǎng)絡(luò)行為數(shù)據(jù)持久化到網(wǎng)絡(luò)行為數(shù)據(jù)表中；

數(shù)據(jù)關(guān)聯(lián)模塊，用于按照第二頻率，從所述用戶在線數(shù)據(jù)表、所述網(wǎng)絡(luò)行為數(shù)據(jù)表和接入設(shè)備位置數(shù)據(jù)表中，將包括相同的標(biāo)識(shí)的所述用戶在線數(shù)據(jù)、所述網(wǎng)絡(luò)行為數(shù)據(jù)和接入設(shè)備位置數(shù)據(jù)進(jìn)行關(guān)聯(lián)；所述第二頻率小于或等于所述第一頻率。

8.根據(jù)權(quán)利要求7所述的裝置，其特征在于，所述第一處理模塊包括：

采集子模塊，用于按照所述第一頻率，通過應(yīng)用程序編程接口API分別獲取所述用戶認(rèn)證數(shù)據(jù)和所述終端在線數(shù)據(jù)。

9.根據(jù)權(quán)利要求7所述的裝置，其特征在于，所述第二處理模塊包括：

解析子模塊，用于將實(shí)時(shí)獲取的所述流量日志分發(fā)到消息隊(duì)列，并根據(jù)解析協(xié)議對(duì)所述消息隊(duì)列輸出的流量日志進(jìn)行解析處理，得到所述網(wǎng)絡(luò)行為數(shù)據(jù)。