推荐介绍

主流推荐系统架构

推荐系统细分四阶段：召回+粗排+精排+ReRanker

召回：待计算的候选集合大、计算速度快、模型简单、特征较少，尽量让用户感兴趣的物品在这个阶段能够被快速召回，即保证相关物品的召回率。常用的有多路召回（即多种策略进行召回），embedding向量召回
精排：首要目标是得到精准的排序结果。需要处理的物品数量少，可以利用较多的特征，使用比较复杂的模型
重排：为了避免排序阶段的结果趋于同质化，让用户有更好的体验，这里对排序的结果进行多样化考虑，提高用户的使用体验

召回

召回的目的：从千万级别的item中为每个用户抽取数千、百个item进行推荐。

召回计算方式：离线凌晨计算，定时更新召回列表。

召回工具：spark hive flink（实时召回）。

召回方式：多路召回。算法层面上分为基于规则的，基于协同过滤的，基于向量召回的算法。

召回列表存储: 线上hbase、redis。

多路召回：策略为主，不同业务场景召回路线不一样，每一路的召回数量也不一样。

为什么要多路召回：让物品从不同来源被召回，满足用户兴趣的多样性，以及推荐结果的完备性。

兴趣标签召回：在用户注册信息的时候很多app都有询问用户兴趣的选项。此时需要的是从物品的自身标签中去计算与用户兴趣标签的匹配度，然后进行topk个召回。
兴趣topic召回：对用户兴趣进行打分，比如用户兴趣有90%时间在阅读军事，10%在阅读政治。
兴趣实体召回：兴趣实体指的是由算法分析用户历史浏览，对其关注的人、物体进行算法抽取，抽取最感兴趣的topk个实体。然后当新的物品来之后，看物品与用户兴趣实体是否匹配。
基于协同过滤：分为基于用户的协同过滤和基于物品的协同过滤两条召回路。
热度召回：根据新闻的曝光量，点击量，已经点击率做筛选，三者均满足要求的新闻进入新闻热度池，作为热度召回的来源，热度池需要实时维护更新（flink, streaming)。
基于模型的召回：youtube、dssm、fm、grapsage。为什么引入模型召回：综合更多信息。每一路相当于一个单特征模型。

基于向量的召回算法算是大量需要深度学习的一个召回算法的流派了，其主要可以分为一下流派：

I2I：计算item-item相似度，用于相似推荐、相关推荐、关联推荐
U2I：基于矩阵分解，直接给用户推荐item
U2U2I：基于用户的协同过滤，先找相似用户，再推荐相似用户喜欢的item
U2I2I：基于物品的协同过滤，先统计用户喜爱的item，再推荐他喜欢的item
U2TAG2I：基于标签偏好推荐，先统计用户偏好的tag，然后匹配所有的item；其中tag一般是item的标签、分类、关键词等。
X2X2X2X：......

其中这里用的最多的就是I2I和U2I这两类算法，其中基于I2I的召回算法大致有如下两个流派：

Item-Item相似度可以通过内容理解来生产Item向量，通过向量相似度来度量
Item-Item相似度可以通过图表示学习/GNN来生产Item向量，通过向量相似度来度量

这里的I2I向量召回的核心就是通过某种算法生产出Item的向量表征，然后通过向量的相似度来进行召回。计算向量的相似度可以用Faiss，它可以帮助我们快速的在大规模向量中找出和Query向量最相似的Top-K个向量，这就解决了我们向量召回计算效率的问题。

基于U2I的召回算法大致有如下两个流派：

输入User特征和Item特征，直接对齐User与Item的向量表征
通过User的历史序列提取User的向量表征，然后和Item的表征对齐

这里第一种方法通过对齐User和Item特征的向量空间的方法一般是一些双塔模型，例如：DSSM 第二种方法通过提取用户的序列特征来生产User的向量表征，然后将User的向量在全部的Item向量中进行召回，这就是序列召回，其实核心就在两个点：

序列信息的利用以及系列特征的提取
如何通过序列构建User的向量表征

粗排

粗排融合：当多路召回结束后，每一路都会召回若干物品,且都有顺序。

目的：如何将多路召回结果，融合为一个有序列表？

策略：

1.业务重要度排序：实时>CB>模型那么要排4个：（c、d、e、b）

2.加权平均：比如基于专家定义：实时：0.5，cb：0.3，模型：0.2。 $score(c)=0.50.5+0.30.5+0.2*0.9/(0.5+0.3+0.2)$

3.动态加权法：每隔一段时间动态更新每一路的权重。

第一天是：实时：0.5，cb：0.3，模型：0.2。

第二天是：实时：0.4，cb：0.5，模型：0.1。

4.模型打分：离线基于模型计算好各路的召回权重，然后一样做加权召回。

多路融合存在的问题：

1.多路的权重不好确定

2.多路的召回数量不好确定

3.多路召回的并发先后顺序

4.单路特征召回==单特征模型

5.每一路的衡量指标怎么确定

是否有一个大一统的方法，直接将物品塞入一个黑盒，就可以得到最终的物品列表。且最终列表自动做了权重、数量。——基于模型的召回。

youtube 模型召回工程：

需要在百万量级的视频规模下对用户进行个性化推荐。

考虑到在线推理延迟问题，对特别复杂的网络尤其是深度学习进行推荐就是一个难题。因此将整个网络构建分为两个流程：

1.用候选生成模型完成快速视频筛选，相当于召回。

2.用该模型更换目标完成精排序。

粗排阶段不足之处：

排序不够精确，没有引入更多的side info。
粗排阶段基本都是离线算好的，对用户的即时性捕捉不到位。
粗排使用推荐系统初期，当海量数据来临，需要靠精排做更个性化的排序，增加用户粘性。

精排要干什么：

用到更多特征，你能想到业务特征都可以做。
精排模型可以用复杂的深度学习算法 。
精排离线训练，在线排序。

LR、xgb阶段：大量的人工特征，此时属于推荐系统精排的机器学习阶段。

引入fm、ffm等自动交叉、filed交叉自动构建特征塞入模型。

从wide&deep开启深度学习与推荐的道路。deepfm、DCN、pnn....主要增加特征的高阶交叉，使得模型可以拟合更高阶特征。

着重建模在用户兴趣、行为捕捉模型、多任务、多模态的模型中。din、dien、bst、mmoe、essm...

精排模型如何上线

召回：离线召回后，不经过粗排直接去重存入hbase、redis中。实时召回：通过flink等实时召回存hbase、redis。
模型离线训练 ：固定一天的凌晨，增量训练或者重新训练模型，用于第二天的业务支持。
开启模型服务 ：基于模型预测服务开启，监听模型更新文件是否更新，打日志更新模型文件。
模型在线推理 ：当模型中包含了用户实行为序列后，就需要用户在线推理了，从redis中直接基于用户id拿用户近期行为历史，然后进行预测。此处为了减小服务端压力，如果模型比较小，可以将模型每天部署到客户端。