[feat] update eval-llm
parent
43726a7c34
commit
d74d8451c7
|
|
@ -0,0 +1,88 @@
|
|||
import argparse
|
||||
import random
|
||||
import warnings
|
||||
import numpy as np
|
||||
from transformers import AutoTokenizer, AutoModelForCausalLM, TextStreamer
|
||||
from model.model_minimind import MiniMindConfig, MiniMindForCausalLM
|
||||
from model.model_lora import *
|
||||
from trainer.trainer_utils import setup_seed
|
||||
warnings.filterwarnings('ignore')
|
||||
|
||||
def init_model(args):
|
||||
tokenizer = AutoTokenizer.from_pretrained(args.load_from)
|
||||
if args.load_from == 'model':
|
||||
model = MiniMindForCausalLM(MiniMindConfig(
|
||||
hidden_size=args.hidden_size,
|
||||
num_hidden_layers=args.num_hidden_layers,
|
||||
use_moe=args.use_moe,
|
||||
inference_rope_scaling=args.inference_rope_scaling
|
||||
))
|
||||
moe_suffix = '_moe' if args.use_moe else ''
|
||||
ckp = f'./{args.save_dir}/{args.weight}_{args.hidden_size}{moe_suffix}.pth'
|
||||
model.load_state_dict(torch.load(ckp, map_location=args.device), strict=True)
|
||||
if args.lora_weight != 'None':
|
||||
apply_lora(model)
|
||||
load_lora(model, f'./{args.save_dir}/lora/{args.lora_weight}_{args.hidden_size}.pth')
|
||||
else:
|
||||
model = AutoModelForCausalLM.from_pretrained(args.load_from, trust_remote_code=True)
|
||||
print(f'MiniMind模型参数: {sum(p.numel() for p in model.parameters()) / 1e6:.2f} M(illion)')
|
||||
return model.eval().to(args.device), tokenizer
|
||||
|
||||
def main():
|
||||
parser = argparse.ArgumentParser(description="MiniMind模型推理与对话")
|
||||
parser.add_argument('--load_from', default='model', type=str, help="模型加载路径(model=原生torch权重,其他路径=transformers格式)")
|
||||
parser.add_argument('--save_dir', default='out', type=str, help="模型权重目录")
|
||||
parser.add_argument('--weight', default='full_sft', type=str, help="权重名称前缀(pretrain, full_sft, rlhf, reason, ppo_actor, grpo, spo)")
|
||||
parser.add_argument('--lora_weight', default='None', type=str, help="LoRA权重名称(None表示不使用,可选:lora_identity, lora_medical)")
|
||||
parser.add_argument('--hidden_size', default=512, type=int, help="隐藏层维度(512=Small-26M, 640=MoE-145M, 768=Base-104M)")
|
||||
parser.add_argument('--num_hidden_layers', default=8, type=int, help="隐藏层数量(Small/MoE=8, Base=16)")
|
||||
parser.add_argument('--use_moe', default=False, type=bool, help="是否使用MoE架构")
|
||||
parser.add_argument('--inference_rope_scaling', default=False, action='store_true', help="启用RoPE位置编码外推(4倍,仅解决位置编码问题)")
|
||||
parser.add_argument('--max_new_tokens', default=8192, type=int, help="最大生成长度(注意:并非模型实际长文本能力)")
|
||||
parser.add_argument('--temperature', default=0.85, type=float, help="生成温度,控制随机性(0-1,越大越随机)")
|
||||
parser.add_argument('--top_p', default=0.85, type=float, help="nucleus采样阈值(0-1)")
|
||||
parser.add_argument('--historys', default=0, type=int, help="携带历史对话轮数(需为偶数,0表示不携带历史)")
|
||||
parser.add_argument('--device', default='cuda' if torch.cuda.is_available() else 'cpu', type=str, help="运行设备")
|
||||
args = parser.parse_args()
|
||||
|
||||
prompts = [
|
||||
'你有什么特长?',
|
||||
'为什么天空是蓝色的',
|
||||
'请用Python写一个计算斐波那契数列的函数',
|
||||
'解释一下"光合作用"的基本过程',
|
||||
'如果明天下雨,我应该如何出门',
|
||||
'比较一下猫和狗作为宠物的优缺点',
|
||||
'解释什么是机器学习',
|
||||
'推荐一些中国的美食'
|
||||
]
|
||||
|
||||
conversation = []
|
||||
model, tokenizer = init_model(args)
|
||||
input_mode = int(input('[0] 自动测试\n[1] 手动输入\n'))
|
||||
streamer = TextStreamer(tokenizer, skip_prompt=True, skip_special_tokens=True)
|
||||
|
||||
prompt_iter = prompts if input_mode == 0 else iter(lambda: input('👶: '), '')
|
||||
for prompt in prompt_iter:
|
||||
setup_seed(2026) # or setup_seed(random.randint(0, 2048))
|
||||
if input_mode == 0: print(f'👶: {prompt}')
|
||||
conversation = conversation[-args.historys:] if args.historys else []
|
||||
conversation.append({"role": "user", "content": prompt})
|
||||
|
||||
templates = {"conversation": conversation, "tokenize": False, "add_generation_prompt": True}
|
||||
if args.weight == 'reason': templates["enable_thinking"] = True # 仅Reason模型使用
|
||||
inputs = tokenizer.apply_chat_template(**templates) if args.weight != 'pretrain' else (tokenizer.bos_token + prompt)
|
||||
inputs = tokenizer(inputs, return_tensors="pt", truncation=True).to(args.device)
|
||||
|
||||
print('🤖️: ', end='')
|
||||
generated_ids = model.generate(
|
||||
inputs=inputs["input_ids"], attention_mask=inputs["attention_mask"],
|
||||
max_new_tokens=args.max_new_tokens, do_sample=True, streamer=streamer,
|
||||
pad_token_id=tokenizer.pad_token_id, eos_token_id=tokenizer.eos_token_id,
|
||||
top_p=args.top_p, temperature=args.temperature, repetition_penalty=1.0
|
||||
)
|
||||
response = tokenizer.decode(generated_ids[0][len(inputs["input_ids"][0]):], skip_special_tokens=True)
|
||||
conversation.append({"role": "assistant", "content": response})
|
||||
print('\n\n')
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
182
eval_model.py
182
eval_model.py
|
|
@ -1,182 +0,0 @@
|
|||
import argparse
|
||||
import random
|
||||
import warnings
|
||||
import numpy as np
|
||||
from transformers import AutoTokenizer, AutoModelForCausalLM, TextStreamer
|
||||
from model.model_minimind import MiniMindConfig, MiniMindForCausalLM
|
||||
from model.model_lora import *
|
||||
|
||||
warnings.filterwarnings('ignore')
|
||||
|
||||
|
||||
def init_model(args):
|
||||
tokenizer = AutoTokenizer.from_pretrained('./model/')
|
||||
if args.load == 0:
|
||||
moe_path = '_moe' if args.use_moe else ''
|
||||
modes = {0: 'pretrain', 1: 'full_sft', 2: 'rlhf', 3: 'reason', 4: 'ppo_actor', 5: 'grpo'}
|
||||
ckp = f'./{args.out_dir}/{modes[args.model_mode]}_{args.hidden_size}{moe_path}.pth'
|
||||
|
||||
model = MiniMindForCausalLM(MiniMindConfig(
|
||||
hidden_size=args.hidden_size,
|
||||
num_hidden_layers=args.num_hidden_layers,
|
||||
use_moe=args.use_moe,
|
||||
inference_rope_scaling=args.inference_rope_scaling
|
||||
))
|
||||
|
||||
model.load_state_dict(torch.load(ckp, map_location=args.device), strict=True)
|
||||
|
||||
if args.lora_name != 'None':
|
||||
apply_lora(model)
|
||||
load_lora(model, f'./{args.out_dir}/lora/{args.lora_name}_{args.hidden_size}.pth')
|
||||
else:
|
||||
transformers_model_path = './MiniMind2'
|
||||
tokenizer = AutoTokenizer.from_pretrained(transformers_model_path)
|
||||
model = AutoModelForCausalLM.from_pretrained(transformers_model_path, trust_remote_code=True)
|
||||
print(f'MiniMind模型参数量: {sum(p.numel() for p in model.parameters() if p.requires_grad) / 1e6:.2f}M(illion)')
|
||||
return model.eval().to(args.device), tokenizer
|
||||
|
||||
|
||||
def get_prompt_datas(args):
|
||||
if args.model_mode == 0:
|
||||
# pretrain模型的接龙能力(无法对话)
|
||||
prompt_datas = [
|
||||
'马克思主义基本原理',
|
||||
'人类大脑的主要功能',
|
||||
'万有引力原理是',
|
||||
'世界上最高的山峰是',
|
||||
'二氧化碳在空气中',
|
||||
'地球上最大的动物有',
|
||||
'杭州市的美食有'
|
||||
]
|
||||
else:
|
||||
# 非LoRA模型的通用对话问题
|
||||
if args.lora_name == 'None':
|
||||
prompt_datas = [
|
||||
'请介绍一下自己。',
|
||||
'你更擅长哪一个学科?',
|
||||
'鲁迅的《狂人日记》是如何批判封建礼教的?',
|
||||
'我咳嗽已经持续了两周,需要去医院检查吗?',
|
||||
'详细的介绍光速的物理概念。',
|
||||
'推荐一些杭州的特色美食吧。',
|
||||
'请为我讲解“大语言模型”这个概念。',
|
||||
'如何理解ChatGPT?',
|
||||
'Introduce the history of the United States, please.'
|
||||
]
|
||||
else:
|
||||
# LoRA微调模型的特定领域问题
|
||||
lora_prompt_datas = {
|
||||
'lora_identity': [
|
||||
"你是ChatGPT吧。",
|
||||
"你叫什么名字?",
|
||||
"你和openai是什么关系?"
|
||||
],
|
||||
'lora_medical': [
|
||||
'我最近经常感到头晕,可能是什么原因?',
|
||||
'我咳嗽已经持续了两周,需要去医院检查吗?',
|
||||
'服用抗生素时需要注意哪些事项?',
|
||||
'体检报告中显示胆固醇偏高,我该怎么办?',
|
||||
'孕妇在饮食上需要注意什么?',
|
||||
'老年人如何预防骨质疏松?',
|
||||
'我最近总是感到焦虑,应该怎么缓解?',
|
||||
'如果有人突然晕倒,应该如何急救?'
|
||||
],
|
||||
}
|
||||
prompt_datas = lora_prompt_datas[args.lora_name]
|
||||
|
||||
return prompt_datas
|
||||
|
||||
|
||||
# 设置可复现的随机种子
|
||||
def setup_seed(seed):
|
||||
random.seed(seed)
|
||||
np.random.seed(seed)
|
||||
torch.manual_seed(seed)
|
||||
torch.cuda.manual_seed(seed)
|
||||
torch.cuda.manual_seed_all(seed)
|
||||
torch.backends.cudnn.deterministic = True
|
||||
torch.backends.cudnn.benchmark = False
|
||||
|
||||
|
||||
def main():
|
||||
parser = argparse.ArgumentParser(description="Chat with MiniMind")
|
||||
parser.add_argument('--lora_name', default='None', type=str)
|
||||
parser.add_argument('--out_dir', default='out', type=str)
|
||||
parser.add_argument('--temperature', default=0.85, type=float)
|
||||
parser.add_argument('--top_p', default=0.85, type=float)
|
||||
parser.add_argument('--device', default='cuda' if torch.cuda.is_available() else 'cpu', type=str)
|
||||
# 此处max_seq_len(最大输出长度)并不意味模型具有对应的长文本的性能,仅防止QA出现被截断的问题
|
||||
# MiniMind2-moe (145M):(hidden_size=640, num_hidden_layers=8, use_moe=True)
|
||||
# MiniMind2-Small (26M):(hidden_size=512, num_hidden_layers=8)
|
||||
# MiniMind2 (104M):(hidden_size=768, num_hidden_layers=16)
|
||||
parser.add_argument('--hidden_size', default=512, type=int)
|
||||
parser.add_argument('--num_hidden_layers', default=8, type=int)
|
||||
parser.add_argument('--max_seq_len', default=8192, type=int)
|
||||
parser.add_argument('--use_moe', default=False, type=bool)
|
||||
parser.add_argument('--model_mode', default=1, type=int, help="【必要的】0: 预训练模型,1: SFT-Chat模型 | 【非必要的】2: RLHF模型,3: Reason模型,4/5: RLAIF模型")
|
||||
# 启用长度外推,默认为4倍(注:仅解决位置编码外推问题,不代表模型真实具备长文本能力)
|
||||
parser.add_argument('--inference_rope_scaling', default=False, action='store_true')
|
||||
# 携带历史对话上下文条数history_cnt需要设为偶数,即【用户问题, 模型回答】为1组;设置为0时,即当前query不携带历史上文
|
||||
# 模型未经过多轮对话微调时,在多轮次的长上下文难免出现能力的明显退化,因此需要注意此处设置
|
||||
parser.add_argument('--history_cnt', default=0, type=int)
|
||||
# load模式为1时,前置hidden_size、num_hidden_layers、max_seq_len等参数失效,即以加载的transformers模型的config.json配置为准
|
||||
parser.add_argument('--load', default=0, type=int, help="0: 原生torch权重,1: transformers加载")
|
||||
args = parser.parse_args()
|
||||
|
||||
model, tokenizer = init_model(args)
|
||||
|
||||
prompts = get_prompt_datas(args)
|
||||
test_mode = int(input('[0] 自动测试\n[1] 手动输入\n'))
|
||||
streamer = TextStreamer(tokenizer, skip_prompt=True, skip_special_tokens=True)
|
||||
|
||||
messages = []
|
||||
for idx, prompt in enumerate(prompts if test_mode == 0 else iter(lambda: input('👶: '), '')):
|
||||
# setup_seed(random.randint(0, 2048))
|
||||
setup_seed(2026) # 如需固定每次输出则换成【固定】的随机种子
|
||||
if test_mode == 0: print(f'👶: {prompt}')
|
||||
|
||||
messages = messages[-args.history_cnt:] if args.history_cnt else []
|
||||
messages.append({"role": "user", "content": prompt})
|
||||
|
||||
# 1. Pretrain:接龙模型
|
||||
if args.model_mode == 0:
|
||||
new_prompt = tokenizer.bos_token + prompt
|
||||
# 2. SFT/RL:聊天模型
|
||||
else:
|
||||
template_args = {
|
||||
"conversation": messages,
|
||||
"tokenize": False,
|
||||
"add_generation_prompt": True
|
||||
}
|
||||
# 只可对Reason模型使用,非思考模型不能加此参数
|
||||
if args.model_mode == 3:
|
||||
template_args["enable_thinking"] = True # False则关闭think
|
||||
new_prompt = tokenizer.apply_chat_template(**template_args)
|
||||
|
||||
inputs = tokenizer(
|
||||
new_prompt,
|
||||
return_tensors="pt",
|
||||
truncation=True
|
||||
).to(args.device)
|
||||
|
||||
print('🤖️: ', end='')
|
||||
generated_ids = model.generate(
|
||||
inputs["input_ids"],
|
||||
max_new_tokens=args.max_seq_len,
|
||||
num_return_sequences=1,
|
||||
do_sample=True,
|
||||
attention_mask=inputs["attention_mask"],
|
||||
pad_token_id=tokenizer.pad_token_id,
|
||||
eos_token_id=tokenizer.eos_token_id,
|
||||
streamer=streamer,
|
||||
top_p=args.top_p,
|
||||
temperature=args.temperature,
|
||||
repetition_penalty=1.0 # 重复惩罚力度,1.0使用默认分布
|
||||
)
|
||||
|
||||
response = tokenizer.decode(generated_ids[0][inputs["input_ids"].shape[1]:], skip_special_tokens=True)
|
||||
messages.append({"role": "assistant", "content": response})
|
||||
print('\n\n')
|
||||
|
||||
|
||||
if __name__ == "__main__":
|
||||
main()
|
||||
Loading…
Reference in New Issue