基于智能电视实时区域收视率和收视份额统计系统及方法

技术领域

本发明涉及智能电视技术领域，具体涉及一种基于智能电视实时区域收视 率和收视份额统计系统及方法。

背景技术

实时区域收视率就是区域当前时刻采集周期内实际收看某频道(节目)人数 除以该区域总观众人数，实时区域收视份额就是某区域当前时刻采集周期内收 看某频道(节目)的观众人数除以该区域所有正在看电视人数。现在收视率和收 视份额都采取采样收集，并且隔天才会产出收视信息，并且采样数据小，不能 够准确实时的反应区域收视率和收视份额。对于广告投放方，如果能够掌握准 确有效的区域收视率，并且能够实时掌握各个时间的区域收视份额，不仅能够 准确定位到自己的细分市场中对应人群的收视习惯，而且还能够对自己的广告 进行精准定位和精准投放，从而大大增加广告投入产出比。对于各大电视台， 通过掌握准确有效的实时区域收视率和收视份额，可以对各个时间段节目安排 与广告收入进行精准分析。但是现在的收视份额都采取采样分析，由于受限于 采样样本数目，并且受限于时间，从而不具备实时性，准确性。并且原始计算 方法都是统计采集周期内的收视行为，在数据量庞大的时候，不能够更高效的 计算出结果。

发明内容

本发明克服了现有技术的不足，通过采用分组机制，滑动窗口机制和先入 先出队列，提供一种基于智能电视实时区域收视率和收视份额统计系统及方法。

为解决上述的技术问题，本发明采用以下技术方案：

一种基于智能电视实时区域收视率和收视份额统计的方法，所述的方法包括

以下步骤：

1)、智能电视日志采集系统记录用户观看记录数据，在固定采集周期T₁时间 内实时上报所述用户观看记录数据给消息分发服务；

2)、消息分发服务接收到所述用户观看记录数据，获取用户IP，通过IP解 析服务获取到用户的区域信息，然后把所述用户观看记录数据发送给分布式 消息队列里；

3)、实时处理平台实时获取分布式消息队列中的数据，并格式化成元组数据 发送至实时处理平台的数据处理模块；

4)、数据处理模块首先把用户id发送至用户中心，如果该用户在用户中心 注册过，则不再重复注册，如果该用户不在用户中心，则对该用户进行注册；

5)、数据处理模块获取到元组数据，对所选择的区域信息进行分组计数，并 采用滑动窗口的机制进行计数，所述滑动窗口机制是：在采集周期T₁内上报 的数据根据展示周期T₂的时间分成S组；把S组放入先进先出队列中，根据 公式：

队列总数＝当前队列总数-删除分组数据总数+新入分组数据总数

计算出该区域该采集周期内正在观看电视的总人数，同时根据该区域各频道 或者该区域各节目进行分组计数，从而算出该区域该采集周期内正在观看某 频道或者某节目的人数；

6)、把步骤5)中计算结果按照区域实时收视率和区域实时收视份额公式计 算，并把计算结果T₂周期内存入数据存储平台。

更进一步的技术方案是用户观看记录数据包括用户IP，用户id，用户观看 的频道，用户观看的节目信息。

更进一步的技术方案是数据处理模块是分布式实时数据处理模块。

更进一步的技术方案是S组为：S＝T₁/T₂组，其中T₂<T₁，且能整除。

更进一步的技术方案是步骤6)中公式为：

区域实时收视率(％)＝某区域当前时刻采集周期内实际收看某频道人数/ 某区域总观众人数*100％

区域节目实时收视率(％)＝某区域当前时刻采集周期内实际收看某节目人 数/某区域总观众人数*100％。

更进一步的技术方案是步骤6)中公式为：

区域频道收视份额(％)＝采集周期内该区域当前正在观看该频道人数/该区 域正在观看电视的人数*100％

区域节目收视份额(％)＝采集周期内该区域当前正在观看该节目人数/该区 域正在观看电视的人数*100％。

更进一步的技术方案是还包括：步骤7)、实时展示平台T2周期内获取所述 步骤6)中所述计算结果，并实时展示给用户。

更进一步的技术方案是提供一种基于智能电视实时区域收视率和收视份额 统计的系统，它包括：观看信息日志采集模块、日志预处理模块、上传日志模 块、实时处理平台、实时展示平台、用户中心、分布式数据存储系统；所述观 看信息日志采集模块与所述日志预处理模块连接；所述日志预处理模块与所述 上传日志模块连接；所述上传日志模块与所述实时处理平台连接；所述实时展 示平台与所述用户中心连接；所述实时展示平台与所述分布式数据存储系统连 接；所述分布式数据存储系统与所述实时展示平台连接。

更进一步的技术方案是实时处理平台包括：IP解析模块、分布式消息队列 模块和分布式实时数据处理模块；所述IP解析模块与所述分布式消息队列模块 连接；所述分布式消息队列模块与所述分布式实时数据处理模块连接。

更进一步的技术方案是IP解析模块与所述上传日志模块连接；所述上传日 志模块与所述分布式实时数据处理模块连接；所述分布式实时数据处理模块与 所述用户中心连接；所述分布式实时数据处理模块连接与所述分布式数据存储 系统连接。

与现有技术相比，本发明的有益效果是：本发明可以有效的统计区域频道 收视份额，区域节目收视份额等。从而对于广告投放方以及电视台广告的定价 都有了良好的依据。

附图说明

图1为本发明一个实施例的系统架构图。

图2为本发明一个实施例中区域实时收视率流程图。

图3为本发明一个实施例中区域实时收视份额流程图。

具体实施方式

本说明书中公开的所有特征，或公开的所有方法或过程中的步骤，除了互 相排斥的特征和/或步骤以外，均可以以任何方式组合。

本说明书(包括任何附加权利要求、摘要和附图)中公开的任一特征，除 非特别叙述，均可被其他等效或具有类似目的的替代特征加以替换。即，除非 特别叙述，每个特征只是一系列等效或类似特征中的一个例子而已。

下面结合附图及实施例对本发明的具体实施方式进行详细描述。

实施例1

如图1所示，根据本发明的一个实施例，本实施例公开一种基于智能电视实 时区域收视率和收视份额统计的系统，该系统主要分为智能电视，实时处理平 台，实时展示平台，用户中心，分布式数据存储系统，其中智能电视主要包括 观看信息日志采集模块，日志预处理模块，上传日志模块。具体的，实时处理 平台包括：IP解析模块、分布式消息队列模块和分布式实时数据处理模块；IP 解析模块与分布式消息队列模块连接；分布式消息队列模块与分布式实时数据 处理模块连接。

观看信息日志采集模块与日志预处理模块连接；日志预处理模块与上传日 志模块连接；上传日志模块与实时处理平台连接；实时展示平台与用户中心连 接；实时展示平台与分布式数据存储系统连接；分布式数据存储系统与实时展 示平台连接。进一步的，IP解析模块与上传日志模块连接；上传日志模块与分 布式实时数据处理模块连接；分布式实时数据处理模块与用户中心连接；分布 式实时数据处理模块连接与分布式数据存储系统连接。本实施例通过采用分组 机制，滑动窗口机制和先入先出队列，有效的统计区域频道收视份额，区域节 目收视份额等。从而对于广告投放方以及电视台广告的定价都有了良好的依据。

实施例2

如图2所示，本图为实时区域收视率流程图，根据本发明另一个实施例， 本实施例公开一种计算实时区域收视率的方法，其步骤包括：

a)智能电视日志采集系统获取用户观看行为，如果用户进入某一频道持续 观看时间等于采集周期T₁，如1分钟，则通过日志上报系统上报该日志，上报 后，日志进入时间归零，如该用户继续观看时间等于采集周期T₁，则再上报1 条日志。如用户切换频道，则进入时间归零。日志上报内容为用户IP，用户ID， 用户观看频道，用户观看节目。日志上报给实时处理平台。

b)IP解析模块通过对IP的解析，获取该IP对应的国家，省以及市等区域 信息。并把处理后的数据一起发送到实时数据处理模块。

c)实时平台接受到用户ID，首先判断是否为新注册用户，如果是新注册用 户，则存入用户中心，该区域用户中心总用户数加1。处理后把数据给IP解析 模块。

d)实时数据处理模块通过对区域_频道或者区域_节目组合成新的key值， 实时数据处理系统通过对key值进行分发，相同key值进入相同的处理单元。

e)数据处理单元接收到相同key值得信息，对数据分为S组，如采集周期 T₁为1分钟，展示周期T₂为2秒钟，则根据S＝T₁/T₂，即S＝30组，则根据时间对 数据进行分组，数据处理单元每次只计算小组里的数值，即这2秒钟的个数， 并插入到组数为30个的先进先出队列，并把最旧的小组数值从队列中删除。并 同时更新队列的总值，总值公式为：

队列总数＝当前队列总数-删除分组数据总数+新入分组数据总数。

f)数据处理单元每T₂周期取出先进先出队列里数据的总数，并计算出区域 实时收视率，并存入分布式数据存储系统。比如2秒钟取出该数值，该数值即 为某区域_频道，或者某区域_节目的数值，即某区域正在看某频道或者某节目 的数值。通过区域频道收视率公式和区域节目收视率公式计算出区域实时收视 率，公式如下：

区域实时收视率(％)＝某区域当前时刻采集周期内实际收看某频道人数/ 某区域总观众人数*100％。

区域节目实时收视率(％)＝某区域当前时刻采集周期内实际收看某节目人 数/某区域总观众人数*100％。

g)实时展示平台每T₂读取分布式数据存储系统中最新的区域实时收视率数 据，并展示。

实施例3

如图3所示，本图为实时区域收视份额流程图，根据本发明的再一个实施 例，本实施例公开一种计算实时区域收视份额的方法，其包括以下步骤：

a)智能电视日志采集系统获取用户观看行为，如果用户进入某一频道持续 观看时间等于采集周期T₁，如1分钟，则通过日志上报系统上报该日志，上报 后，日志进入时间归零，如该用户继续观看时间等于采集周期T₁，则再上报1 条日志。如用户切换频道，则进入时间归零。日志上报内容为用户IP，用户ID， 用户观看频道，用户观看节目。日志上报给实时处理平台。

b)IP解析模块通过对IP的解析，获取该IP对应的国家，省以及市等区域 信息。并把处理后的数据一起发送到实时数据处理模块。

c)实时数据处理模块通过对区域，区域_频道或者区域_节目组合成新的key 值，实时数据处理系统通过对key值进行分发，相同key值进入相同的处理单 元。

d)数据处理单元接收到相同key值得信息，对数据分为S组，如采集周期 T₁为1分钟，展示周期T₂为2秒钟，则根据S＝T₁/T₂，即S＝30组，则根据时间对 数据进行分组，数据处理单元每次只计算小组里的数值，即这2秒钟的个数， 并插入到组数为30个的先进先出队列，并把最旧的小组数值从队列中删除。并 同时更新队列的总值，总值公式为：

队列总数＝当前队列总数-删除分组数据总数+新入分组数据总数

e)数据处理单元每T₂周期取出先进先出队列里数据的总数，并计算出区域 实时收视份额，并存入分布式数据存储系统。比如2秒钟取出该数值，该数值 即为某区域_频道，或者某区域_节目的数值，以及某区域数值，其中把同一区 域所有数据进行相加，如对某区域_频道的所有key中的数值相加，即为该区域 正在看电视的人数，利用收视份额公式计算得出区域实时收视份额，公式如下：

区域频道收视份额＝采集周期内该区域当前正在观看该频道人数/该区域正 在观看电视的人数。

区域节目收视份额＝采集周期内该区域当前正在观看该节目人数/该区域正 在观看电视的人数。

f)实时展示平台每T₂周期读取分布式数据存储系统中最新的区域实时收视 率数据，并前端展示。

本发明上述实施例实时的、准确的区域收视份额的统计方法，根据此方法 可以有效的统计区域频道收视份额，区域节目收视份额等。从而对于广告投放 方以及电视台广告的定价都有了良好的依据。

在本说明书中所谈到的“一个实施例”、“另一个实施例”、“实施例”、等， 指的是结合该实施例描述的具体特征、结构或者特点包括在本申请概括性描述 的至少一个实施例中。在说明书中多个地方出现同种表述不是一定指的是同一 个实施例。进一步来说，结合任一个实施例描述一个具体特征、结构或者特点 时，所要主张的是结合其他实施例来实现这种特征、结构或者特点也落在本发 明的范围内。

尽管这里参照发明的多个解释性实施例对本发明进行了描述，但是，应该 理解，本领域技术人员可以设计出很多其他的修改和实施方式，这些修改和实 施方式将落在本申请公开的原则范围和精神之内。更具体地说，在本申请公开 权利要求的范围内，可以对主题组合布局的组成部件和/或布局进行多种变型和 改进。除了对组成部件和/或布局进行的变型和改进外，对于本领域技术人员来 说，其他的用途也将是明显的。