<small id='KokjQB'></small> <noframes id='UWe0rHE'>

  • <tfoot id='rocpfiqNaT'></tfoot>

      <legend id='YE6FH'><style id='coQCF76'><dir id='pGO6'><q id='4XWr8DB'></q></dir></style></legend>
      <i id='uP7b25pFi'><tr id='h2VFmtQA'><dt id='VdKC'><q id='EnYr724'><span id='YrUmG4'><b id='1LO5KeHp'><form id='zg8ZyMU'><ins id='VnYBOoe'></ins><ul id='5dQBMKrI'></ul><sub id='DF3G'></sub></form><legend id='1rVNmjEk'></legend><bdo id='djO0rRTYs'><pre id='9TuzMY'><center id='SMdx'></center></pre></bdo></b><th id='HJV4z'></th></span></q></dt></tr></i><div id='qPEABu0Q'><tfoot id='JDu5XvPZxq'></tfoot><dl id='BjwR3'><fieldset id='xruVKsg'></fieldset></dl></div>

          <bdo id='HvVJu'></bdo><ul id='lXB8RjmK6'></ul>

          1. <li id='70teIBAOw'></li>
            登陆

            章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法

            admin 2019-10-29 315人围观 ,发现0个评论

            GitHub Java项目推荐|基于Flink实现的商品实时推荐系统flink统计商品热度放入redis缓存分析日志信息将画像标签章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法和实时记录放入Hbase在用户发起推荐请求后根据用户画像重排序热度榜并结合协同过滤和标签两个推荐模块为新生成的榜单的每一个产品添加关联产品最后返回新的用户列表

            项目分析

            仓库名称:flink-recommandSystem-demo

            标星(star):522 (不错哦,潜力股项目)

            标星趋势

            关注(watch):24

            拷贝(fork):140

            贡献人数:2

            仓库大小:4 MB

            最后更新

            代码提交周期分布

            综合推荐指数: 2星

            开发语言

            主要语言:Java

            语言分布:Java:99.07%、HTML:0.93%

            项目概述

            商品实时推荐系统

            1. 系统架构 v2.0

            • 1.1 系统架构图



            • 1.2模块说明
            • a.在日志数据模块(flink-2-hbase)中,又主要分为6个Flink任务:
            • 用户-产品浏览历史 -> 实现基于协同过滤的推荐逻辑
            • 通过Flink去记录用户浏览过这个类目下的哪些产品,为后面的基于Item的协同过滤做准备 实时的记录用户的评分到Hbase中,为后续离线处理做准备.
            • 数据存储在Hbase的p_history表
            • 用户-兴趣 -> 实现基于上下文的推荐逻辑
            • 根据用户对同一个产品的操作计算兴趣度,计算规则通过操作间隔时间(如购物 - 浏览 < 100s)则判定为一次兴趣事件 通过Flink的ValueState实现,如果用户的操作Action=3(收藏),则清除这个产品的state,如果超过100s没有出现Action=3的事件,也会清除这个state
            • 数据存储在Hbase的u_interest表
            • 用户画像计算 -> 实现基于标签的推荐逻辑
            • v1.0按照三个维度去计算用户画像,分别是用户的颜色兴趣,用户的产地兴趣,和用户的风格兴趣.根据日志不断的修改用户画像的数据,记录在Hbase中.
            • 数据存储在Hbase的user表
            • 产品画像记录 -> 实现基于标签的推荐逻辑
            • 用两个维度记录产品画像,一个是喜爱该产品的年龄段,另一个是性别
            • 数据存储在Hbase的prod表
            • 事实热度榜 -> 实现基于热度的推荐逻辑
            • 通过Flink时间窗口机制,统计当前时间的实时热度,并将数章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法据缓存在Redis中.
            • 通过Flink的窗口机制计算实时热度,使用ListState保存一次热度榜
            • 数据存储在redis中,按照时间戳存储list
            • 日志导澳大利亚签证入
            • 从Kafka接收的数据直接导入进Hbase事实表,保存完整的日志log,日志中包含了用户Id,用户操作的产品id,操作时间,行为(如购买,点击,推荐等).
            • 数据按时间窗口统计数据大屏需要的数据,返回前段展示
            • 数据存储在Hbase的con表
            • b. web模块
            • 前台用户界面
            • 该页面返回给用户推荐的产品list
            • 后台监控页面
            • 该页章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法面返回给管理员指标监控

            2.推荐引擎逻辑说明

            • 2.1 基于热度的推荐逻辑
            • 现阶段推荐逻辑图



            ​ 根据用户特征,重新排序热度榜,之后根据两种推荐算法计算得到的产品相关度评分,为每个热度榜中的产品推荐几个关联的产品

            • 2.2 基于产品画像的产品相似度计算方法
            • 基于产品画像的推荐逻辑依赖于产品画像和热度榜两个维度,产品画像有三个特征,包含color/country/style三个角度,通过计算用户对该类目产品的评分来过滤热度榜上的产品



            • 在已经有产品画像的基础上,计算item与item之间的关联章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法系,通过余弦相似度来计算两两之间的评分,最后在已有物品选中的情况章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法下推荐关联性更高的产品.

            相似度ABCA10.70.2B0.710.6C0.20.61

            • 2.3 基于协同过滤的产品相似度计算方法
            • 根据产品用户表(Hbase) 去计算公式得到相似度评分:

            3. 前台推荐页面

            ​ 当前推荐结果分为3列,分别是热度榜推荐,协同过滤推荐和产品画像推荐



            4. 后台数据大屏

            在后台上显示推荐系统的实时数据,数据来自其他Fl章鱼彩票推荐-GitHub Java项目引荐|根据Flink完成的产品实时引荐体系|引荐算法ink计算模块的结果.目前包含热度榜和1小时日志接入量两个指标. 真实数据位置在resource/database.sql



            项目地址

            https://github.com/CheckChe0803/flink-recommandSystem-demo

            程序员新视界:分享有趣、有料的流行程序员话题,每天进步一点点。

            请关注微信公众号
            微信二维码
            不容错过
            Powered By Z-BlogPHP