Project 5: 统计模块

学习目标

• 实现 PV/UV 统计
• 用 ClickHouse 做数据洞察

---

统计方案

数据类型	存储	更新频率	说明
PV	Redis + MySQL	实时	INCR article:pv:{id}
UV	Redis HyperLogLog	实时	PFADD article:uv:{id} {user_id}
阅读日志	ClickHouse	批量导入	分析趋势、热门文章
用户行为	Kafka → ClickHouse	流式	留存分析、转化率

Redis + HyperLogLog UV 统计

func RecordUV(ctx context.Context, articleID string, userID string) error {
    key := fmt.Sprintf("article:uv:%s", articleID)
    _, err := redis.PFAdd(ctx, key, userID).Result()
    return err
}

func GetUV(ctx context.Context, articleID string) (int64, error) {
    key := fmt.Sprintf("article:uv:%s", articleID)
    return redis.PFCount(ctx, key).Result()
}