Skip to content
G

guttv_bds4

环球合一数据平台kafka消息格式说明

业务平台输出kafka

  • 主题名称:guttv_log_v4
  • 用途:业务平台消息接收程序将apk上报的json格式的消息,转换为\t分割的字符串。
  • 输入:业务平台消息接收程序,device_report。
  • 输出:活跃主题,点播主题

头部通用字段说明

字段名称 类型 序号 备注
版本 浮点 1 消息的版本号
盒端IP地址 字符串 2 盒端获取额终端设备本身的IP地址
时间戳 long 3 终端产生的时间戳,单位:秒
用户编码 字符串 4
业务组合编码 字符串 5
渠道编码 字符串 6
盒端apk版本 字符串 7
分屏值 字符串 8
业务分组编码 字符串 9
活跃标识 字符串 10 每次开机产生一个随机数,建议不差过6位
活跃时长 字符串 11 本机开机的时长,单位:秒

格式:

以下所有的消息均含有头部通用信息。

1、开机消息

  • 格式:去除头部信息后包含reportType=PON和截止标识EOF。
  • 样例:

0.4\t127.0.0.1\t1530869566\tu000\tcombo\tag\tapk_ver\t0\tsg\tact_session\t11\tPON\tEOF

2、关机消息

  • 格式:去除头部信息后包含reportType=POFF和截止标识EOF
  • 样例:

0.4\t127.0.0.1\t1530869566\tu000\tcombo\tag\tapk_ver\t0\tsg\tact_session\t11\tPOFF\tEOF

3、市场活动消息

  • 格式:去除头部信息后包含reportType=ACT,然后依次是:1.活动标识, 2.活动点击项编码, 3.活动点击项对应的资产编码和截止标识EOF
  • 样例:

0.4\t127.0.0.1\t1530869566\tu000\tcombo\tag\tapk_ver\t0\tsg\tact_session\t11\tACT\tACT001\tBTN01\tqq\tEOF

4、点击事件消息

  • 格式:去除头部信息后包含reportType=CLICK,然后依次是:1.点击类型, 2.点击项编码, 3.点击想绑定的资产编码, 4.推荐项的行号(从1开始), 5.推荐项的列号(从1开始)和截止标识EOF。
  • 样例:

0.4\t127.0.0.1\t1530869566\tu000\tcombo\tag\tapk_ver\t0\tsg\tact_session\t11\tCLICK\tREC\tItem\tAsset\t1\t4\tEOF

5、心跳消息

  • 格式:去除头部信息后包含reportType=HEART和截止标识EOF
  • 样例:

0.4\t127.0.0.1\t1530869566\tu000\tcombo\tag\tapk_ver\t0\tsg\tact_session\t11\tHEART\tEOF

6、播放消息

  • 格式:去除头部信息后包含reportType=VOD,然后依次是:1.点播session, 2.节目编码, 3.节目集编码, 4.订单编码,5.有效播放百分比,6.开始播放的时间戳, 7.小屏播放时长, 8.大屏播放时长, 9.暂停时长, 10.影片总时长, 11.有效播放的比率,最后是截止标识EOF。
  • 样例:

0.4\t127.0.0.1\t1531818208\tu000\t1100121022985423839948843\tag\tapk_ver\t0\tsg\tact_session\t11\tVOD\tjfKDFU\tPRG0001\tS0001\tO0002\t12\t1531818208\t1\t5\t2\t100\t0\tEOF

活跃主题

是经过spark数据清洗后产生的有效活跃数据。收集所有的消息。

点播主题

是经过spark实时数据清洗后产生的有效点播信息。收集reporttype=VOD的消息。

活动主题

是经过spark实时数据清洗后产生的市场活动有关的数据。收集reporttype=ACT的消息。

点击主题

是经过spark实时数据清洗后产生的用户点击事件有关的数据。收集reporttype=CLICK的消息。