
Flink-RecommandSystem-Demo: 基于Flink的实时商品推荐系统,统计商品热度并存入Redis...
5星
- 浏览量: 0
- 大小:None
- 文件类型:None
简介:
Flink-RecommandSystem-Demo是一个基于Apache Flink构建的实时商品推荐系统项目。该项目通过分析用户行为数据来计算商品热度,并将结果存储在Redis中以供快速查询和推荐使用。
商品实时推荐系统1.0 系统架构
1.1 系统架构图
1.2 模块说明:
a. 在日志数据模块(flink-2-hbase)中,主要分为6个Flink任务:用户-产品浏览历史。该部分实现基于协同过滤的推荐逻辑,通过记录用户在某个类目下浏览过的产品信息为后续项目间的协同过滤提供基础;实时地将用户的评分存储到HBase数据库中的p_history表里,以便于未来的离线处理工作。
b. 用户-兴趣:此模块采用基于行为分析的方法来实现产品推荐功能。根据用户对同一产品的操作记录(如浏览、收藏等),通过计算不同操作之间的间隔时间等方式确定出其对该商品的兴趣程度,并以此为依据进行个性化的产品推荐服务。
全部评论 (0)
还没有任何评论哟~


