[發(fā)明專利]一種交互式網(wǎng)絡(luò)電視系統(tǒng)及用戶數(shù)據(jù)實時獲取方法

在審

• 申請?zhí)枺?/td>: 201610338286.3
• 申請日: 2016-05-19
• 公開（公告）號: CN107404658A
• 公開（公告）日: 2017-11-28
• 發(fā)明（設(shè)計）人: 徐淑波
• 申請（專利權(quán)）人: 中興通訊股份有限公司
• 主分類號: H04N21/258
• 分類號: H04N21/258;H04N21/231;H04N21/442
• 代理公司: 北京安信方達知識產(chǎn)權(quán)代理有限公司11262
• 代理人: 解婷婷,龍洪

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

本發(fā)明涉及IPTV(交互式網(wǎng)絡(luò)電視)用戶管理、信息實時采集、大數(shù)據(jù)存儲與分析、應(yīng)用等領(lǐng)域，特別涉及一種IPTV系統(tǒng)及用戶數(shù)據(jù)實時獲取方案。

背景技術(shù)

截止到2015年底，國內(nèi)IPTV用戶數(shù)已超過5000萬，預(yù)計2016年用戶數(shù)將過億。獲取如此龐大的用戶群的實時數(shù)據(jù)對于精準(zhǔn)營銷、實時推薦、用戶間交互、系統(tǒng)維護等都具有十分重要的意義。

IPTV用戶每天產(chǎn)生海量的用戶數(shù)據(jù)，但由于IPTV系統(tǒng)架構(gòu)各不相同，機頂盒、服務(wù)系統(tǒng)等廠商不一，使得這些數(shù)據(jù)分布零散，結(jié)構(gòu)不一，采集與分析利用的難度很大。隨著大數(shù)據(jù)概念興起和相關(guān)技術(shù)、標(biāo)準(zhǔn)的完善，對這些數(shù)據(jù)的采集、分析與利用成為可能。

由于目前的IPTV系統(tǒng)對用戶的實時在線狀態(tài)及觀看內(nèi)容等數(shù)據(jù)沒有顯式記錄，無法直接從當(dāng)前業(yè)務(wù)數(shù)據(jù)庫中獲取用戶的實時狀態(tài)及觀看內(nèi)容等信息；同時由于IPTV系統(tǒng)由CDN、EPG、CP等多個模塊組合而成，對現(xiàn)有結(jié)構(gòu)的變動將耗費巨大且效果待驗證；因此，如何在不改變現(xiàn)有系統(tǒng)架構(gòu)的情況下加入對IPTV用戶數(shù)據(jù)的實時獲取功能成為需要解決的問題。

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

本發(fā)明公開了一種IPTV系統(tǒng)及用戶數(shù)據(jù)實時獲取方法，可以解決現(xiàn)有IPTV系統(tǒng)架構(gòu)下無法實時獲取用戶數(shù)據(jù)的問題。

本發(fā)明公開了一種交互式網(wǎng)絡(luò)電視IPTV系統(tǒng)，包括：

日志實時采集模塊，實時采集IPTV服務(wù)器上符合設(shè)定格式的日志信息；

數(shù)據(jù)分析模塊，對日志實時采集模塊采集的日志信息進行計算與分析，得到分析結(jié)果并儲存至數(shù)據(jù)存儲及查詢模塊；

數(shù)據(jù)存儲及查詢模塊，對所述日志實時采集模塊采集的日志信息以及所述數(shù)據(jù)分析模塊得到的分析結(jié)果進行分布式存儲，并提供查詢。

可選地，上述系統(tǒng)中，所述日志實時采集模塊至少包括一個數(shù)據(jù)采集服務(wù)端和在每個IPTV系統(tǒng)服務(wù)器上分別部署的一個數(shù)據(jù)采集客戶端，其中：

分別部署在IPTV系統(tǒng)服務(wù)器上數(shù)據(jù)采集客戶端，實時采集IPTV系統(tǒng)服務(wù)器上符合設(shè)定格式的日志信息，并傳送至數(shù)據(jù)采集服務(wù)端；

所述數(shù)據(jù)采集服務(wù)端，將數(shù)據(jù)采集客戶端采集的日志信息分別傳送給所述數(shù)據(jù)分析模塊和數(shù)據(jù)存儲及查詢模塊。

可選地，上述系統(tǒng)中，所述數(shù)據(jù)采集服務(wù)端，將各數(shù)據(jù)采集客戶端采集的日志信息合并為文本文件傳輸給所述數(shù)據(jù)存儲及查詢模塊，其中，對于來自不同IPTV系統(tǒng)服務(wù)器的日志信息，在合并前要將不同格式的文件標(biāo)準(zhǔn)化。

可選地，上述系統(tǒng)中，所述數(shù)據(jù)存儲及查詢模塊，采用分布式文件系統(tǒng)存儲所述日志實時采集模塊采集的日志信息，采用分布式數(shù)據(jù)庫集群承載數(shù)據(jù)的分析結(jié)果的存儲，并提供rest接口實現(xiàn)數(shù)據(jù)的實時查詢。

本發(fā)明還公開了一種交互式網(wǎng)絡(luò)電視IPTV系統(tǒng)用戶數(shù)據(jù)實時獲取方法，包括：

實時采集每個IPTV系統(tǒng)服務(wù)器上符合設(shè)定格式的日志信息并進行分布式存儲；

對采集的每個IPTV系統(tǒng)服務(wù)器上的日志信息進行計算與分析，得到分析結(jié)果并進行分布式儲存；

當(dāng)接收到用戶查詢指令時，從儲存的分析結(jié)果中查詢對應(yīng)的數(shù)據(jù)。

可選地，上述方法中，實時采集每個IPTV系統(tǒng)服務(wù)器上符合設(shè)定格式的日志信息包括：

在每個IPTV系統(tǒng)服務(wù)器上分別部署一個數(shù)據(jù)采集客戶端，每個數(shù)據(jù)采集客戶端實時采集該IPTV系統(tǒng)服務(wù)器上符合設(shè)定格式的日志信息；

所有數(shù)據(jù)采集客戶端將采集的日志信息傳送至數(shù)據(jù)采集服務(wù)端。

可選地，上述方法中，對采集的日志信息進行計算與分析，得到分析結(jié)果并進行分布式儲存的過程包括：

將每個IPTV系統(tǒng)服務(wù)器上采集的日志信息合并為文本文件進行儲存，其中，對于來自不同IPTV系統(tǒng)服務(wù)器的日志信息，在合并前要將不同格式的文件標(biāo)準(zhǔn)化。

可選地，上述方法中，實時采集符合設(shè)定格式的信息并進行分布式存儲指：

采用分布式文件系統(tǒng)存儲所采集的符合設(shè)定格式的信息；

得到分析結(jié)果進行分布式儲存指：

采用分布式數(shù)據(jù)庫集群承載數(shù)據(jù)的分析結(jié)果的存儲。

本申請技術(shù)方案，在不改變現(xiàn)有IPTV系統(tǒng)架構(gòu)的情況下，實現(xiàn)IPTV用戶數(shù)據(jù)的實時采集、存儲與分析。

附圖說明

圖1是本發(fā)明實施例中數(shù)據(jù)實時獲取方案整體架構(gòu)示意圖；

圖2是本發(fā)明實施例實時采集數(shù)據(jù)流向示意圖；

圖3是本發(fā)明實施例分布式文件系統(tǒng)示意圖；

圖4是本發(fā)明實施例分布式數(shù)據(jù)庫結(jié)構(gòu)示意圖；

圖5是本發(fā)明實施例用戶觀看數(shù)據(jù)分析示意圖；