GRPO 算法(损失函数)——原理讲解与代码讲解

视频讲解链接:8.calculating-loss-in-grpo.zh_en_哔哩哔哩_bilibili

论文:《DeepSeek-R1: Incentivizing Reasoning Capability in LLMs via Reinforcement Learning》

一、GRPO 损失函数

二、GRPO 算法可以分解为四个关键组成部分:

(1)策略损失(policy loss):模型在有适配器和没有适配器情况下的词元概率分布比率
(2)从奖励函数中计算出来的优势值(advantages)
(3)比率裁剪(clip):用于确保在任何单独步骤中都没有大的损失值
(4)KL散度:用于确保在训练过程中,我们正在训练的模型不会偏离它已经知道的基准模型太多

下面我们对每个部分逐一介绍。

1. 首先加载所需的模型和分词器,并打印模型的网络结构和生成文本的效果。
from transformers import AutoModelForCausalLM, AutoTokenizer # 初始化 model 和 tokenizer model_str = "babylm/babyllama-100m-2024" base_model = AutoModelForCausalLM.from_pretrained(model_str) tokenizer = AutoTokenizer.from_pretrained(model_str) # pad on the left so we can append new tokenizer on the right tokenizer.padding_side = "left" tokenizer.truncation_side = "left" print(base_model) import torch prompt = "The quick brown fox jumped over the " # Tokenizer the prompt input_ids = tokenizer(prompt, return_tensors="pt") print(input_ids) # 将文本进行分词,得到 token,在尾部添加了一个终止符 # Generate next 2 tokens with torch.no_grad(): outputs = base_model.generate( **input_ids, max_new_tokens=2, pad_token_id=tokenizer.pad_token_id ) # Decode the generated text 将 token 重新转换为文本 generated_text = tokenizer.decode( outputs[0], skip_special_tokens=True ) generated_portion = generated_text[len(prompt):] print(f"Generated text: {prompt}\033[94m{generated_portion}\033[0m")

        在 GRPO 中,使用两个不同的模型来指导学习过程,一个是参考模型(没有 LoRA 的基础模型,在整个训练过程中保持冻结),另一个是策略模型(要训练的模型,使用一组在整个学习过程中不断更新的 LORA 权重)。下面我们来分别定义参考模型(ref_model)和策略模型(model)

import copy from peft import LoraConfig, get_peft_model # Create a copy of the base model to use as the reference model(参考模型) ref_model = copy.deepcopy(base_model) # 初始化 LoRA 配置文件:用于我们想要添加到模型中的 LoRA 权重 lora_config = LoraConfig( r=8, # 秩 lora_alpha=32, target_modules=["q_proj", "v_proj"], # 插入权重的目标模块 init_lora_weights=False, bias="none", task_type="CAUSAL_LM" ) # Apply LoRA to model model = get_peft_model(base_model, lora_config) print(model)
2. 有了参考模型和策略模型之后,我们可以实现策略函数(policy_loss)部分。

两个辅助函数:

(1)prepare_inputs:将文本 prompt 和 completion 转换为 tokenizer,并进行合并,方便作为模型的提示词输入。

(2)compute_log_probs:计算通过模型生成的每个 token 的对数概率。概率越大说明模型对生

成的 token 的准确信心越大。

def prepare_inputs(prompt, completion): # Tokenization prompt_tokens = tokenizer(prompt, return_tensors="pt") completion_tokens = tokenizer(completion, return_tensors="pt") # Combined input input_ids = torch.cat( [ prompt_tokens["input_ids"], completion_tokens["input_ids"] ], dim = 1 ) # 注意力掩码 attention_mask = torch.cat( [ prompt_tokens["attention_mask"], completion_tokens["attention_mask"] ], dim = 1 ) prompt_length = prompt_tokens["input_ids"].shape[1] completion_length = completion_tokens["input_ids"].shape[1] total_length = prompt_length + completion_length # 补全掩码:Create a mask to identify the tokens that were generated by the model in the full sequence completion_mask = torch.zeros(total_length, dtype=torch.float32) completion_mask[prompt_length:] = 1.0 return input_ids, attention_mask, completion_mask
import torch.nn.functional as F def compute_log_probs(model, input_ids, attention_mask): outputs = model(input_ids, attention_masks=attention_mask) # outputs.logits 是神经网络输出中未经过归一化的概率,下一步通常是 softmax log_probs = F.log_softmax(outputs.logits, dim=-1) return log_probs.gather( dim=-1, index=input_ids.unsqueeze(-1) ).squeeze(-1)

        策略损失函数的含义是策略模型对每个 token 的对数概率,与参考模型对每个 token 的对数概率的比率。这个比率(retio)越大,说明策略模型对生成的 token 的信心越大,说明策略模型生成的结果越好。

        advantages 是通过奖励函数转换来的优势值,强化学习的目标就是获得最大的优势值。

        在 GRPO 算法中根据优势值缩放比率,来判断策略模型信心大的生成 token 的方向是不是和优势值方向一致(举个例子:对于优势值为负的策略,尽管策略模型对它生成的 token 信心很大,但这只能说明策略模型生成文本的功能很好,但不是我们想要的方向)。

        代码中的 completion_mask 是由模型生成的 token 的位置掩码(它是一个前面全是0,后面全是1的掩码),在计算策略损失时,我们只考虑由模型生成的 token 的损失。

def grpo_loss(model, ref_model, prompt, completion, advantage): input_ids, attention_mask, completion_mask = prepare_inputs(prompt, completion) # 策略模型对数概率 token_log_probs = compute_log_probs( model, input_ids, attention_mask ) # 参考模型对数概率 with torch.no_grad(): ref_token_log_probs = compute_log_probs( ref_model, input_ids, attention_mask ) # 这个比率(ratio)表示策略模型生成的 token 相比于参考模型,是具有更高的概率还是更低的概率 ratio = torch.exp(token_log_probs - ref_token_log_probs) # 根据优势值缩放比率,生成的 token 是否对模型学习方向有正向作用 policy_loss = ratio * advantage # We want to maximize reward, so we make the loss negative # because optimizers minimize loss per_token_loss = -policy_loss # 只考虑输出 tokens 的损失 loss = (per_token_loss * completion_mask).sum() / completion_mask.sum() return loss

        下面两个输出结果反应出:当参考模型和策略模型相同,比率是 1 ,policy_loss 等于 advantages。这也说明为什么奖励函数生成的奖励分数需要多样性,如果生成的奖励分数是固定的,那么得到优势值也都是0,导致损失为0,阻止训练过程。

grpo_loss(model, ref_model, prompt, "fence and", advantage=2.0) # tensor(-7.5770, grad_fn=<DivBackward0>) grpo_loss(ref_model, ref_model, prompt, "fence and", advantage=2.0) # tensor(-2., grad_fn=<DivBackward0>)
3. 比率裁剪(clip)

        policy_loss 是计算生成的每个 token 在策略模型和参考模型中的比率,但有时候某个 token 的比率会明显大于其他值,这是不可避免的,但这样会造成强化学习过程非常不稳定。所以我们需要一种方法来防止在任何单步训练步骤中产生过大的损失值。

        实现这一点方法是比率裁剪(clip):将比率控制在一个范围内,防止比率过大或过小,代码如下。

def grpo_loss_with_clip(model, ref_model, prompt, completion, advantage, epsilon = 0.2): input_ids, attention_mask, completion_mask = prepare_inputs(prompt, completion) # 策略模型对数概率 token_log_probs = compute_log_probs( model, input_ids, attention_mask ) # 参考模型对数概率 with torch.no_grad(): ref_token_log_probs = compute_log_probs( ref_model, input_ids, attention_mask ) # 这个比率(ratio)表示策略模型生成的 token 相比于参考模型,是具有更高的概率还是更低的概率 ratio = torch.exp(token_log_probs - ref_token_log_probs) # 根据优势值缩放比率,生成的 token 是否对模型学习方向有正向作用 unclipped = ratio * advantage # 裁剪比率:将比率控制在一个范围,防止比率过大或过小 clipped = torch.clamp(ratio, 1-epsilon, 1+epsilon) * advantage policy_loss = torch.min(unclipped, clipped) # We want to maximize reward, so we make the loss negative # because optimizers minimize loss per_token_loss = -policy_loss # 只考虑输出 tokens 的损失 loss = (per_token_loss * completion_mask).sum() / completion_mask.sum() return loss

        加入比率裁剪之后,损失值比之前的更靠近 -2.0 ( -2.0 表示策略模型与参考模型对生成 token 信心相同,这是我们希望的最终结果),说明损失稳定很多(由 -7.5770 → -2.4000)。

grpo_loss_with_clip(model, ref_model, prompt, "fence and", advantage=2.0, epsilon = 0.2) # tensor(-2.4000, grad_fn=<DivBackward0>)
4. KL 散度(惩罚项)

        强化学习中的一个常见问题是:随着更新策略模型,它在生成的词元上开始与参考模型有所偏差。因此我们通常引入一个称为 KL 散度的惩罚项,以防止策略模型偏离参考模型太远。KL 散度是一种衡量策略模型与参考模型之间的分布偏差程度的方法。

def grpo_loss_with_kl(model, ref_model, prompt, completion, advantage, epsilon = 0.2, beta = 0.1): input_ids, attention_mask, completion_mask = prepare_inputs(prompt, completion) # 策略模型对数概率 token_log_probs = compute_log_probs( model, input_ids, attention_mask ) # 参考模型对数概率 with torch.no_grad(): ref_token_log_probs = compute_log_probs( ref_model, input_ids, attention_mask ) # 这个比率(ratio)表示策略模型生成的 token 相比于参考模型,是具有更高的概率还是更低的概率 ratio = torch.exp(token_log_probs - ref_token_log_probs) # 根据优势值缩放比率,生成的 token 是否对模型学习方向有正向作用 unclipped = ratio * advantage # 裁剪比率:将比率控制在一个范围,防止比率过大或过小 clipped = torch.clamp(ratio, 1-epsilon, 1+epsilon) * advantage policy_loss = torch.min(unclipped, clipped) # 当 delta 为正值时,意味着策略模型相比于参考模型对生成的词元更有信心 delta = token_log_probs - ref_token_log_probs per_token_kl = torch.exp(-delta) - (-delta) -1 # policy_loss 是优势值,越大越好 # Kl 散度是惩罚值,越小越好 # We want to maximize reward, so we make the loss negative because optimizers minimize loss per_token_loss = -(policy_loss - beta * per_token_kl) # 只考虑输出 tokens 的损失 loss = (per_token_loss * completion_mask).sum() / completion_mask.sum() return loss

        KL 散度计算公式中 delta 与 KL 损失值之间的关系如下。

(1)当 delta=0 时,意味着策略模型和参考模型对输出分配了相同的概率。所以他们对生成的词元具有相同的信心。
(2)当 delta>0 时,意味着策略模型相比于参考模型对生成的词元有更多的信心,在这种情况下 KL 散度是一个非常小的惩罚项,它告诉策略模型生成的词元很好,同时防止策略模型与参考模型偏差太多。
(3)当 delta<0 时,意味着策略模型相比于参考模型对生成的词元缺乏信心,KL 散度会非常迅速地增加,很快告诉模型它偏离了参考模型,需要向更接近参考模型的位置来修正方向。

Read more

安装 启动 使用 Neo4j的超详细教程

安装 启动 使用 Neo4j的超详细教程

最近在做一个基于知识图谱的智能生成项目。需要用到Neo4j图数据库。写这篇文章记录一下Neo4j的安装及其使用。 一.Neo4j的安装 1.首先安装JDK,配环境变量。(参照网上教程,很多) Neo4j是基于Java的图形数据库,运行Neo4j需要启动JVM进程,因此必须安装JAVA SE的JDK。从Oracle官方网站下载 Java SE JDK。我使用的版本是JDK1.8 2.官网上安装neo4j。 官方网址:https://neo4j.com/deployment-center/  在官网上下载对应版本。Neo4j应用程序有如下主要的目录结构: bin目录:用于存储Neo4j的可执行程序; conf目录:用于控制Neo4j启动的配置文件; data目录:用于存储核心数据库文件; plugins目录:用于存储Neo4j的插件; 3.配置环境变量 创建主目录环境变量NEO4J_HOME,并把主目录设置为变量值。复制具体的neo4j文件地址作为变量值。 配置文档存储在conf目录下,Neo4j通过配置文件neo4j.conf控制服务器的工作。默认情况下,不需

企业微信群机器人Webhook配置全攻略:从创建到发送消息的完整流程

企业微信群机器人Webhook配置全攻略:从创建到发送消息的完整流程 在数字化办公日益普及的今天,企业微信作为国内领先的企业级通讯工具,其群机器人功能为团队协作带来了极大的便利。本文将手把手教你如何从零开始配置企业微信群机器人Webhook,实现自动化消息推送,提升团队沟通效率。 1. 准备工作与环境配置 在开始创建机器人之前,需要确保满足以下基本条件: * 企业微信账号:拥有有效的企业微信管理员或成员账号 * 群聊条件:至少包含3名成员的群聊(这是创建机器人的最低人数要求) * 网络环境:能够正常访问企业微信服务器 提示:如果是企业管理员,建议先在"企业微信管理后台"确认机器人功能是否已对企业开放。某些企业可能出于安全考虑会限制此功能。 2. 创建群机器人 2.1 添加机器人到群聊 1. 打开企业微信客户端,进入目标群聊 2. 点击右上角的群菜单按钮(通常显示为"..."或"⋮") 3. 选择"添加群机器人"选项 4.

Flowise物联网融合:与智能家居设备联动的应用设想

Flowise物联网融合:与智能家居设备联动的应用设想 1. Flowise:让AI工作流变得像搭积木一样简单 Flowise 是一个真正把“AI平民化”落地的工具。它不像传统开发那样需要写几十行 LangChain 代码、配置向量库、调试提示词模板,而是把所有这些能力打包成一个个可拖拽的节点——就像小时候玩乐高,你不需要懂塑料怎么合成,只要知道哪块该拼在哪,就能搭出一座城堡。 它诞生于2023年,短短一年就收获了45.6k GitHub Stars,MIT协议开源,意味着你可以放心把它用在公司内部系统里,甚至嵌入到客户交付的产品中,完全不用担心授权问题。最打动人的不是它的技术多炫酷,而是它真的“不挑人”:产品经理能搭出知识库问答机器人,运营同学能配出自动抓取竞品文案的Agent,连刚学Python两周的实习生,也能在5分钟内跑通一个本地大模型的RAG流程。 它的核心逻辑很朴素:把LangChain里那些抽象概念——比如LLM调用、文档切分、向量检索、工具调用——变成画布上看得见、摸得着的方块。你拖一个“Ollama LLM”节点,再拖一个“Chroma Vector

OpenClaw配置Bot接入飞书机器人+Kimi2.5

OpenClaw配置Bot接入飞书机器人+Kimi2.5

上一篇文章写了Ubuntu_24.04下安装OpenClaw的过程,这篇文档记录一下接入飞书机器+Kimi2.5。 准备工作 飞书 创建飞书机器人 访问飞书开放平台:https://open.feishu.cn/app,点击创建应用: 填写应用名称和描述后就直接创建: 复制App ID 和 App Secret 创建成功后,在“凭证与基础信息”中找到 App ID 和 App Secret,把这2个信息复制记录下来,后面需要配置到openclaw中 配置权限 点击【权限管理】→【开通权限】 或使用【批量导入/导出权限】,选择导入,输入以下内容,如下图 点击【下一步,确认新增权限】即可开通所需要的权限。 配置事件与回调 说明:这一步的配置需要先讲AppId和AppSecret配置到openclaw成功之后再设置订阅方式,