直播数据

通过HTTP/HTTPS方式上报跳转收银台｜商品点击次数数据上报

推送上报数据action:1

一：涉及脚本：1、百家云用户进出回调实时计算脚本：live:room_export_user_events【live:user_join_room_event:[用户进入房间 Redis Set]、live:user_leave_room_event:[用户离开房间 Redis Set]、live:user_click_goods:[商品点击数]、live:user_click_cashier:[跳转收银台]】，根据用户行为创建Redis Set去重，后台查询当天进出用户曲线、跳转收银台、商品点击次数时进行读取，有效期5小时。2、百家云用户进出回调入库脚本live:room_export_user_events_import_mysql：监听消息后进行数据存库处理，供后端查询历史数据时读取使用3、百家云清洗数据脚本live:room_cleaning_data：在直播结束之后清洗百家云回调过来的用户进出直播间数据，清洗8到10点数据，每5分钟一批落库，供后台查询4、用户进出教室数据并记录进直播间记录：live:room_export_user_events_enter_log：处理百家云回调过来的用户进出直播间数据，记录用户在直播间状态5、查看回放数据更新脚本：live:vod_data_update：直播结束后拉取回放数据并入库6、拉取直播间聊天内容：room_user_chat_msg，直播结束后拉取聊天历史记录7、直播间用户信息：room_user_info_data：添加直播间总听课时长8、直播间数据统计：room_user_summary_data：添加学员数据9、初始化用户统计记录：live:inituseritem 初始化学员数据10、批量拉取直播间聊天内容：batch_room_user_chat_msg，直播结束后批量拉取聊天历史记录并落库二：涉及数据表：1、mh_live_room_user_click_detail【学员点击详情表】2、mh_live_room_user_action_log【学员进出直播间日志】3、mh_live_room_realtime_data【学员进出直播间统计(分钟粒度)】4、mh_live_room_user_vod_log_00~31【回放日志表，拆分成32张表】5、mh_live_room_user_item【直播间统计学员数据】[课节与班级数据基于此表汇总]6、mh_live_room_chat_msg_00~31【直播间聊天记录，拆分成32张表】

监听队列，读取数据

处理百家云回放、直播等数据脚本

展示数据

【当天实时数据读取Redis，历史数据读取数据库】

小白营直播系统【wm-live-api】

清洗完成，入库

跳转收银台/商品点击数/进出直播间实时计算脚本

读取并处理完成，数据落库

百家云服务

进出直播间调用百家云

阿里云Rds数据库

用户进入直播间鉴权通过

H5直播间客户端

读取进出直播间数据

提供直播、回放、聊天记录数、直播观看时长、回放时长等数据

跳转收银台/商品点击数/进出直播间入库脚本

计算完成，放入Redis Set中

清洗百家云进出直播间数据

拉取百家云数据

记录用户是否进出直播间脚本

阿里云Redis

推送上报数据action:2

阿里云RocketMq

小白营图文系统【wm-market-new】

通过HTTP/HTTPS方式上报用户进出直播间数据

小白营直播进出直播间及埋点数据处理

查看数据统计

小白营直播后台管理系统