文哥的学习笔记: https://www.jianshu.com/p/af5226c7fbbb

知识图谱特征学习在推荐系统中的应用步骤大致有以下三种方式:


依次训练的方法主要有:Deep knowledge-aware Network(DKN)
联合训练的方法有: Ripple Network
交替训练主要采用multi-task的思路,主要方法有: Multi-task Learning for KG enhanced Recommendation(MKR)

1、MKR原理介绍

由于推荐系统中的物品和知识图谱中的实体存在重合,因此可以采用多任务学习的框架,将推荐系统和知识图谱特征学习视为两个分离但是相关的任务,进行交替式的学习。

MKR的模型框架如下图,其中左侧是推荐系统任务,右侧是知识图谱特征学习任务。推荐部分的输入是用户和物品的特征表示,点击率的预估值作为输出。知识图谱特征学习部分使用的是三元组的头节点和关系作为输入,预测的尾节点作为输出

由于推荐系统中的物品和知识图谱中的实体存在重合,所以两个任务并非相互独立。所以作者在两个任务中设计了交叉特征共享单元(cross-feature-sharing units)作为两者的连接纽带。

交叉特征共享单元是一个可以让两个任务交换信息的模块。由于物品向量和实体向量实际上是对同一个对象的两种描述,他们之间的信息交叉共享可以让两者都获得来自对方的额外信息,从而弥补了自身的信息稀疏性的不足,其结构如下:


关于这个交叉单元具体实现,大家可以参照代码进行理解。

最后是损失函数部分,由于是交替训练的方式,所以在训练时首先固定推荐系统模块的参数,训练知识图谱特征学习模块的参数;然后固定知识图谱特征学习模块的参数,训练推荐系统模块的参数。

推荐系统模块是点击率预估模型,损失函数是对数损失加l2正则项;知识图谱特征学习模块希望预测得到的tail向量和真实的tail向量相近,因此首先计算二者的内积(内积可近似表示向量之间的余弦相似度),内积经过sigmoid之后取相反数,再加上l2正则项,即得到了知识图谱特征学习模块的损失。关于损失的计算,我们在代码里可以更清楚的看到

本文的代码地址为:https://github.com/princewen/tensorflow_practice/tree/master/recommendation/Basic-MKR-Demo
参考代码地址为:https://github.com/hwwang55/MKR
数据下载地址为:https://pan.baidu.com/s/1uHkQXK_ozAgBWcMUMzOfZQ 密码:qw30

在对数据进行预处理后,我们得到了两个文件:kg_final.txt和rating_final.txt

rating_final.txt数据形式如下,三列分别是user-id,item-id以及label(0是通过负采样得到的,正负样本比例为1:1)。

kg_final.txt格式如下,三类分别代表h,r,t(这里entity和item用的是同一套id):

好了,接下来我们重点介绍一下我们的MKR框架的构建。

2. 模型

模型输入

模型输入有以下几个部分: 用户的id、物品的id、推荐系统部分的lablel、知识图谱三元组的head、relation、tail的对应id:

def _build_inputs(self):self.user_indices = tf.placeholder(tf.int32,[None],'user_indices')self.item_indices = tf.placeholder(tf.int32,[None],'item_indices')self.labels = tf.placeholder(tf.float32,[None],'labels')self.head_indices = tf.placeholder(tf.int32,[None],'head_indices')self.tail_indices = tf.placeholder(tf.int32,[None],'tail_indices')self.relation_indices = tf.placeholder(tf.int32,[None],'relation_indices')

低层网络构建

低层网络指下面的部分:

可以看到,user_id、item_id、head_id以及relation_id首先转换为对应的Embedding,user_id和relation_id经由多层神经网络向上传播、而head_id和item_id经过交叉单元进行传播!

def _build_low_layers(self,args):self.user_emb_matrix = tf.get_variable('user_emb_matrix', [self.n_user, args.dim])self.item_emb_matrix = tf.get_variable('item_emb_matrix', [self.n_item, args.dim])self.entity_emb_matrix = tf.get_variable('entity_emb_matrix', [self.n_entity, args.dim])self.relation_emb_matrix = tf.get_variable('relation_emb_matrix', [self.n_relation, args.dim])# [batch_size, dim]self.user_embeddings = tf.nn.embedding_lookup(self.user_emb_matrix, self.user_indices)self.item_embeddings = tf.nn.embedding_lookup(self.item_emb_matrix, self.item_indices)self.head_embeddings = tf.nn.embedding_lookup(self.entity_emb_matrix, self.head_indices)self.relation_embeddings = tf.nn.embedding_lookup(self.relation_emb_matrix, self.relation_indices)self.tail_embeddings = tf.nn.embedding_lookup(self.entity_emb_matrix, self.tail_indices)for _ in range(args.L):user_mlp = Dense(input_dim=args.dim,output_dim=args.dim)  #通过dense网络tail_mlp = Dense(input_dim=args.dim,output_dim = args.dim)  #通过dense网络cc_unit = CrossCompressUnit(args.dim)   #这是交叉单元self.user_embeddings = user_mlp(self.user_embeddings)self.item_embeddings,self.head_embeddings = cc_unit([self.item_embeddings,self.head_embeddings])self.tail_embeddings = tail_mlp(self.tail_embeddings)self.vars_rs.extend(user_mlp.vars)self.vars_rs.extend(cc_unit.vars)self.vars_kge.extend(tail_mlp.vars)self.vars_kge.extend(cc_unit.vars)

接下来,我们来看一下交叉单元的代码:

v,e = inputsv = tf.expand_dims(v,dim=2)
e = tf.expand_dims(e,dim=1)# [batch_size, dim, dim]
c_matrix = tf.matmul(v, e)
c_matrix_transpose = tf.transpose(c_matrix, perm=[0, 2, 1])# [batch_size * dim, dim]
c_matrix = tf.reshape(c_matrix, [-1, self.dim])
c_matrix_transpose = tf.reshape(c_matrix_transpose, [-1, self.dim])v_output = tf.reshape(tf.matmul(c_matrix,self.weight_vv) + tf.matmul(c_matrix_transpose,self.weight_ev),[-1,self.dim]) + self.bias_ve_output = tf.reshape(tf.matmul(c_matrix, self.weight_ve) + tf.matmul(c_matrix_transpose, self.weight_ee),[-1, self.dim]) + self.bias_ereturn v_output,e_output

item对应的embedding用v表示,head对应的embedding用e表示,二者初始情况下都是batch * dim大小的。过程如下:
1、v扩展成三维batch * dim * 1,e扩展成三维batch * 1 * dim,随后二者进行矩阵相乘v * e,我们知道三维矩阵相乘实际上是后两维进行运算,因此得到c_matrix的大小为 batch * dim * dim
2、对得到的c_matrix进行转置,得到c_matrix_transpose,大小为batch * dim * dim。这相当于将e扩展成三维batch * dim * 1,v扩展成三维batch * 1 * dim,随后二者进行矩阵相乘e * v。这是两种不同的特征交叉方式。
3、对c_matrix和c_matrix_transpose 进行reshape操作,变为(batch * dim ) * dim的二维矩阵
4、定义两组不同的参数和偏置,分别得到交叉后的v_output和e_output.

高层网络构建

高层网络指下面的部分:

对于推荐部分,可以采用内积直接得到CTR的预估值,也可以经过多层神经网络得到预估值;对于知识图谱部分,将head和relation对应的向量进行拼接,经过多层神经网络,得到一个tail对应向量的预估值,并与真实的tail向量计算内积。代码如下:

def _build_high_layers(self,args):#RSuse_inner_product = Trueif use_inner_product:self.scores = tf.reduce_sum(self.user_embeddings*self.item_embeddings,axis=1)else:self.user_item_concat = tf.concat([self.user_embeddings,self.item_embeddings],axis=1)for _ in range(args.H - 1):rs_mlp = Dense(input_dim = args.dim * 2 , output_dim = args.dim * 2)self.user_item_concat = rs_mlp(self.user_item_concat)self.vars_rs.extend(rs_mlp.vars)rs_pred_mlp = Dense(input_dim=args.dim * 2,output_dim=1)self.scores = tf.squeeze(rs_pred_mlp(self.user_item_concat))self.vars_rs.extend(rs_pred_mlp)self.scores_normalized = tf.nn.sigmoid(self.scores)#KGEself.head_relation_concat = tf.concat([self.head_embeddings,self.relation_embeddings],axis=1)for _ in range(args.H - 1):kge_mlp = Dense(input_dim=args.dim * 2,output_dim = args.dim * 2)self.head_relation_concat = kge_mlp(self.head_relation_concat)self.vars_kge.extend(kge_mlp.vars)kge_pred_mlp = Dense(input_dim=args.dim * 2,output_dim = args.dim)self.tail_pred = kge_pred_mlp(self.head_relation_concat)self.vars_kge.extend(kge_pred_mlp.vars)self.tail_pred = tf.nn.sigmoid(self.tail_pred)self.scores_kge = tf.nn.sigmoid(tf.reduce_sum(self.tail_embeddings * self.tail_pred,axis=1))#self.rmse = tf.reduce_mean(tf.sqrt(tf.reduce_sum(tf.square(self.tail_embeddings - self.tail_pred),axis=1) / args.dim))

定义损失

推荐系统部分的损失是对数损失加l2正则项:

# RS
self.base_loss_rs = tf.reduce_mean(tf.nn.sigmoid_cross_entropy_with_logits(labels=self.labels, logits=self.scores))
self.l2_loss_rs = tf.nn.l2_loss(self.user_embeddings) + tf.nn.l2_loss(self.item_embeddings)
for var in self.vars_rs:self.l2_loss_rs += tf.nn.l2_loss(var)
self.loss_rs = self.base_loss_rs + self.l2_loss_rs * args.l2_weight

知识图谱特征学习模块用上一步计算的scores_kge的相反数再加上l2正则项:

# KGE
self.base_loss_kge = -self.scores_kge
self.l2_loss_kge = tf.nn.l2_loss(self.head_embeddings) + tf.nn.l2_loss(self.tail_embeddings)
for var in self.vars_kge:self.l2_loss_kge += tf.nn.l2_loss(var)
self.loss_kge = self.base_loss_kge + self.l2_loss_kge * args.l2_weight

知识图谱论文阅读(九)【转】推荐系统遇到知识图谱之MKR模型相关推荐

  1. 论文浅尝 | 打通推荐系统与知识图谱: 第一个公开的大规模链接数据集合

    本文转载自:RUC智能情报站,知乎专栏链接:https://zhuanlan.zhihu.com/RucAIBox 前言:近年来,知识图谱(KB)被广泛应用于推荐系统(RS),但尚未有公开将推荐系统物 ...

  2. 知识图谱论文阅读(十五)【arxiv】A Survey on Knowledge Graph-Based Recommender Systems

    论文题目: A Survey on Knowledge Graph-Based Recommender Systems 论文链接: 论文代码: 想法 出现Refine就是用某些方法更好的优化特征表示 ...

  3. 知识图谱论文阅读(十三)【2020 arXiv】Attentive Knowledge Graph Embedding for Personalized Recommendation

    题目: Attentive Knowledge Graph Embedding for Personalized Recommendation 论文链接: 代码链接: 知识图谱特征学习在推荐系统中的应 ...

  4. 【论文阅读】强化学习与知识图谱关系路径发现

    论文标题:DeepPath: A Reinforcement Learning Method for Knowledge Graph Reasoning 中文标题:深度路径:知识图谱推理的强化学习方法 ...

  5. 知识图谱论文阅读(八)【转】推荐系统遇上深度学习(二十六)--知识图谱与推荐系统结合之DKN模型原理及实现

    学习的博客: 推荐系统遇上深度学习(二十六)–知识图谱与推荐系统结合之DKN模型原理及实现 知识图谱特征学习的模型分类汇总 知识图谱嵌入(KGE):方法和应用的综述 论文: Knowledge Gra ...

  6. 知识图谱论文阅读(十八)【KDD2019】AKUPM: Attention-Enhanced Knowledge-Aware User Preference Model for Recommend

    论文题目: AKUPM: Attention-Enhanced Knowledge-Aware User Preference Model for Recommendation 论文代码: 论文链接: ...

  7. 知识图谱论文阅读(二十三)【SIGIR2020】Multi-behavior Recommendation with Graph Convolutional Networks

    题目: Multi-behavior Recommendation with Graph Convolutional Networks 论文地址: 论文代码: 想法 将相同行为的交互方式进行了聚合来计 ...

  8. 知识图谱论文阅读(二十)【WWW2020】Heterogeneous Graph Transformer

    题目: Heterogeneous Graph Transformer 论文链接: https://arxiv.org/abs/2003.01332 代码链接:https://github.com/a ...

  9. 知识图谱论文阅读(十六)【WWW2019】Knowledge Graph Convolutional Networks for Recommender

    题目: KGCN 论文链接: 代码链接:https://github.com/hwwang55/KGCN 想法 高阶的意思就是multi-hop的意思 注意是从外向里聚合的,第h-1跳是外侧,第h跳是 ...

最新文章

  1. CBS多机器人路径规划
  2. linux使用线程实现生产者消费者问题,Linux平台下线程同步,实现“生产者消费者问题”...
  3. hdu 4679 树状dp
  4. Spring event 使用完全指南
  5. 协调多个对象之间的交互——中介者模式
  6. HTML变列自适应布局三行,CSS三行三列DIV高度自适应的设置
  7. MySQL触发器(转载)
  8. Pycharm社区版安装教程(永久免费,随时升级)
  9. TBXML常用API
  10. 【BZOJ2440】完全平方数,莫比乌斯反演+二分答案+容斥思想
  11. docker 网络设置
  12. jni直接转byte_JNI jbyteArray转char*
  13. node 更新_ESLint v7.0.0 发布:不再支持 Node.js v8
  14. main方法中args_public static void main(String [] args)– Java main方法
  15. php 12小时,使用php怎么将12小时制转换为24小时制
  16. 虚拟机未安装音频设备_如何使用虚拟音频设备录制PC的音频
  17. 万网如何修改dns服务器,万网域名如何修改DNS设置方法
  18. 虾皮店铺如何快速上传商品
  19. 802.1X与portal的无线认证
  20. 产品经理三大领域的技术

热门文章

  1. Spring MVC-视图解析器(View Resolverr)-内部资源视图解析器(Internal Resource View Resolver)示例(转载实践)...
  2. Codis的源码编译生成tar包
  3. 微信企业号开发[二]——获取用户信息
  4. Supervised Convolutional Neural Network
  5. Nginx反向代理配置配置实例
  6. Oracl数据库中大数据的备份-2
  7. [芦半山]Binder的异常机制
  8. Linux内核中的GPIO系统
  9. 在git上push代码时缺少Change-Id
  10. Linux静态库和动态库的设计