基于Oceanus流计算平台搭建实时数据仓库系统，使用Flink CDC 进行业务数据拉取并下层到Kafka，基于Kafka数据进行分层搭建实时数据仓库，对Kafka的数据进行指标运算输出到ClickHouse。该项目旨在为业务实时的全链路转化分析，帮助业务、高层及时决策，以及挖掘出高潜用户帮助社群精准定位人群能及时跟单，提高社群转化率。1.通过flink实时流计算架构以直播以及订单为核心的实时项目2.通过对每天晚上直播过程中数据监控等多维度分析标记高意向用户3.通过对订单数据进行课程进行分流处理，处理过程补充相关维度表形成实时订单数据4.通过后台埋点数据进行直播过程中的监控对直播过程中的卡顿率、敏感词、清晰度切换进行实时监控5.对业务系统某些需要实时处理的表进行Sink至ClickHouse6.后期项目的持续维护和更新优化查看全文
声明：本文仅代表作者观点，不代表本站立场。如果侵犯到您的合法权益，请联系我们删除侵权资源！如果遇到资源链接失效，请您通过评论或工单的方式通知管理员。未经允许，不得转载，本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态
评论