【推荐系统】手写ItemCF/UserCF代码，你会吗？

前言

之前朋友说有同学在面字节算法实习时让复现DeepFM算法（包括训练），然后就懵了。因此最近在整理传统推荐算法的一些内容时，大概是这样的：

就想到「基于邻域的协同过滤（UserCF与ItemCF），除了了解原理、应用场景的区别外，如果现场写实现伪代码你会么？」 有很多文章在讲协同过滤的原理，很少具体到代码，所以这次把以前写的CF代码优化下进行分享。
本文约1.7k字，预计阅读5分钟.

概要

协同过滤是「基于用户行为」设计的推荐算法，具体来说，是「通过群体的行为来找到某种相似性」（用户之间的相似性或者物品之间的相似性），通过相似性来为用户做决策和推荐。当然，协同过滤有基于邻域的、隐语义模型等，这里我们主要指的是基于邻域的ItemCF和UserCF。具体的原理就不多做解释了，见下图：

ItemCF与UserCF的代码其实很相近，因此以ItemCF为例，两个算法的具体代码可以在github：https://github.com/ZiyaoGeng/SimpleCF（阅读原文）中找到。

ItemCF

对于ItemCF算法的实践，我采用类的方式进行建立，主要内容包括：

模型的输入;
初始化【计算相似度矩阵】；
对单个用户进行推荐；
对测试集的所有内容进行推荐；

因此大体框架为：

class ItemCF:def __init__(self, user_item_dict, item_hot_list, sim_item_topK, topN, i2i_sim=None):"""Item-based collaborative filtering:param user_item_dict: A dict. {user1: [(item1, score),...], user2: ...}:param item_hot_list: A list. The popular movies list.:param sim_item_topK: A scalar. Choose topK items for calculate.:param topN: A scalar. The number of recommender list.:param i2i_sim: dict. If None, the model should calculate similarity matrix."""def __get_item_sim(self):"""calculate item similarity weight matrix:return: i2i_sim"""def recommend(self, user_id):def recommend_all(self, test):

输入

user_item_dict：首先最重要的是建立user-item共现矩阵作为「输入」，当然在实际应用中，我们采用字典的形式减少不必要的空间。对于ItemCF，需要user-item-dict字典，而对于UserCF，需要user-item-dict和item-user-dict两个字典：

item-user-dict：

user-item-dict：

【注】元组部分score可以去除或者替换为其他内容；
item_hot_list：热门物品的列表，主要是当推荐物品数量不够时（冷启动等），用热门物品进行填充，计算也比较简单；
sim_item_topK：选取某个物品最相似的TopK个物品，不然选择所有物品会产生很大的计算量；
topN：推荐列表的大小；
i2i_sim：物品相似度矩阵。一般计算相似度矩阵后会在本地进行保存，因此如果之前计算过，则只需读取，不用重复计算；

物品相似度矩阵

ItemCF算法认为「物品A和物品B具有很大的相似度是因为喜欢物品A的用户也大多喜欢物品B」，因此需要计算物品相似度矩阵，主要分为两步：

统计两两物品之间的共现次数，即「用户同时喜欢两个物品」；
通过Jaccard距离、余弦相似度等方式计算两个物品的相似性；

当然对于1来说，需要对于活跃的用户进行惩罚，通过增加IUF（Inverse User Frequence），用户活跃度对数倒数的参数，对应代码中：

i2i_sim[i][j] += 1 / math.log(len(items) + 1)

在2中，通过余弦相似度的计算可以降低热门物品会和很多物品相似的可能性，因为基于物品的推荐主要是挖掘长尾信息。

i2i_sim[i][j] = wij / math.sqrt(item_cnt[i] * item_cnt[j])

具体代码如下：

    def __get_item_sim(self):"""calculate item similarity weight matrix:return: i2i_sim"""i2i_sim = dict()item_cnt = defaultdict(int)  # Count the number of visits to the itemfor user, items in tqdm(self.user_item_dict.items()):for i, score_i in items:item_cnt[i] += 1i2i_sim.setdefault(i, {})for j, score_j in items:if i == j:continuei2i_sim[i].setdefault(j, 0)i2i_sim[i][j] += 1 / math.log(len(items) + 1)  for i, related_items in i2i_sim.items():for j, wij in related_items.items():i2i_sim[i][j] = wij / math.sqrt(item_cnt[i] * item_cnt[j])  return i2i_sim

评估

「数据集」：ml-1m，当然也可以选择其它。预处理主要包括：

选择评分大于x的作为正样本（当然可以直接将所有交互过的物品都作为正样本，将评分融入推荐时权重分数的计算）；
选取每个用户的最后一次发生交互的物品作为测试集（所以评估的结果会比项亮《推荐系统实战》的结果差很多）；
建立user-item和item-user字典；

「评估指标」：

HR（点击率）与NDCG，当每个用户真实的交互物品只有一个时，HR等价于Recall；

评估代码如下：

def evaluate_model(model, test):"""evaluate model:param model: model of CF:param test: dict.:return: hit rate, ndcg"""hit, ndcg = 0, 0for user_id, item_id in tqdm(test.items()):item_rank = model.recommend(user_id)if item_id in item_rank:hit += 1ndcg += 1 / np.log2(item_rank.index(item_id) + 2)return hit / len(test), ndcg / len(test)

实验

对于ItemCF算法，超参数：

sim_item_topK = 20；
topN = 20；

使用自己的笔记本，结果如下：

数据读取：2s；

模型建立（计算相似度矩阵）：3min52s；

模型评估：19min47s，HR = 0.065232, NDCG = 0.024265；

总结

之前参考《推荐算法实践》进行过复现，然后这次结合了Datawhale中新闻推荐的Baseline进行优化，确实对算法中如何惩罚热门物品与活跃用户有了更深的认识。所有代码在github “https://github.com/ZiyaoGeng/SimpleCF”中，如果存在一些Bug或者更好的优化（评估时间太长），欢迎提出Issues。


往期精彩回顾适合初学者入门人工智能的路线及资料下载机器学习及深度学习笔记等资料打印机器学习在线手册深度学习笔记专辑《统计学习方法》的代码复现专辑
AI基础下载机器学习的数学基础专辑
本站知识星球“黄博的机器学习圈子”（92416895）
本站qq群704220115。
加入微信群请扫码：