电商双速行为分析平台(BiSpeed-Ecom)

基于 Flink + PySpark 的实时+离线双引擎电商行为分析系统。采用 Lambda 架构,实时层通过 Flink DataStream API 实现滚动窗口 + TopN 计算,离线层通过 PySpark 完成数仓分层(ODS→DWD→DWS→ADS),最终经 Flask + ECharts 可视化大屏统一展示。

双引擎 实时+离线
Flink 1.17 实时计算
4层 数仓分层
3节点 集群规模
FlinkKafkaRedisMySQLPySparkFlaskEChartsScala

淘宝用户行为多维分析系统

基于阿里巴巴淘宝用户行为数据集(约 1 亿条记录),构建完整的电商用户行为分析流水线:从数据清洗、多维统计分析到交互式可视化,覆盖 RFM 用户分层、转化漏斗、留存分析、行为路径等核心电商指标。

~1亿 行为记录
98.8万 独立用户
10 分析模块
20 可视化图表
Hadoop HDFSPySparkFlaskEChartsPython