基于Oceanus流计算平台搭建实时数据仓库系统，使用Flink CDC 进行业务数据拉取并下层到Kafka，基于Kafka数据进行分层搭建实时数据仓库，对Kafka的数据进行指标运算输出到ClickHouse。该项目旨在为业务实时的全链路转化分析，帮助业务、高层及时决策，以及挖掘出高潜用户帮助社群精准定位人群能及时跟单，提高社群转化率。
1.通过flink实时流计算架构以直播以及订单为核心的实时项目
2.通过对每天晚上直播过程中数据监控等多维度分析标记高意向用户
3.通过对订单数据进行课程进行分流处理，处理过程补充相关维度表形成实时订单数据
4.通过后台埋点数据进行直播过程中的监控对直播过程中的卡顿率、敏感词、清晰度切换进行实时监控
5.对业务系统某些需要实时处理的表进行Sink至ClickHouse
6.后期项目的持续维护和更新优化
点击空白处退出提示
评论