当前位置: 首页 > news >正文

别再只用MNIST了!Permuted/Split MNIST数据集实战:用PyTorch搭建你的第一个连续学习模型

用PyTorch实战连续学习:Permuted与Split MNIST数据集全解析

当你在Kaggle上看到第20个MNIST分类项目时,是否想过这个经典数据集还能玩出什么新花样?今天我们要打破常规,用PyTorch实现连续学习中的两个关键变体——Permuted MNIST和Split MNIST,让你亲身体验模型如何在不同任务间保持知识不遗忘。

1. 环境准备与数据加载

工欲善其事,必先利其器。我们先搭建好实验环境:

conda create -n cl python=3.8 conda activate cl pip install torch torchvision matplotlib

Permuted MNIST的核心在于对图像像素进行随机重排。下面这段代码展示了如何生成10个不同排列顺序的任务:

import torch from torchvision import datasets, transforms def get_permuted_mnist(num_tasks=10): tasks = [] base_dataset = datasets.MNIST('./data', train=True, download=True) for i in range(num_tasks): if i == 0: # 第一个任务使用原始MNIST permutation = torch.arange(784) else: permutation = torch.randperm(784) transform = transforms.Compose([ transforms.ToTensor(), transforms.Lambda(lambda x: x.view(-1)[permutation].view(1, 28, 28)) ]) task_dataset = datasets.MNIST('./data', train=True, transform=transform) tasks.append(task_dataset) return tasks

Split MNIST的处理则完全不同,它将数字类别拆分到不同任务中:

def get_split_mnist(): tasks = [] base_transform = transforms.Compose([ transforms.ToTensor() ]) # 5个任务,每个任务包含两个数字类别 class_pairs = [(0,1), (2,3), (4,5), (6,7), (8,9)] for pair in class_pairs: class_mask = (dataset.targets == pair[0]) | (dataset.targets == pair[1]) task_data = dataset.data[class_mask] task_targets = dataset.targets[class_mask] # 将标签重新映射为0和1 task_targets = (task_targets == pair[1]).long() tasks.append((task_data, task_targets)) return tasks

2. 连续学习模型架构设计

连续学习模型需要解决的核心问题是"灾难性遗忘"。我们实现两个经典方法:EWC(弹性权重固化)和LwF(学习不遗忘)。

2.1 EWC实现关键代码

EWC通过约束重要参数的更新来保护已有知识:

class EWC_Model(nn.Module): def __init__(self): super().__init__() self.fc1 = nn.Linear(784, 100) self.fc2 = nn.Linear(100, 10) def forward(self, x): x = x.view(-1, 784) x = F.relu(self.fc1(x)) return self.fc2(x) def compute_fisher(model, dataset, samples=100): fisher = {} for n, p in model.named_parameters(): fisher[n] = torch.zeros_like(p.data) for _ in range(samples): data, target = dataset[random.randint(0, len(dataset)-1)] output = model(data.unsqueeze(0)) loss = F.cross_entropy(output, torch.tensor([target])) model.zero_grad() loss.backward() for n, p in model.named_parameters(): fisher[n] += p.grad.data ** 2 / samples return fisher

2.2 LwF实现要点

LwF使用知识蒸馏技术保留旧任务知识:

def lwf_loss(current_output, old_output, target, T=2, alpha=0.5): # 当前任务的交叉熵损失 ce_loss = F.cross_entropy(current_output, target) # 蒸馏损失 soft_target = F.softmax(old_output/T, dim=1) soft_current = F.log_softmax(current_output/T, dim=1) distill_loss = F.kl_div(soft_current, soft_target, reduction='batchmean') * (T**2) return alpha * ce_loss + (1-alpha) * distill_loss

3. 训练流程与评估策略

连续学习的训练需要特别设计评估环节,以检测模型在所有已学任务上的表现。

3.1 训练循环示例

def train_task(model, task_data, optimizer, ewc=None, fisher=None, lambda_=1000): model.train() for epoch in range(10): # 每个任务训练10个epoch for data, target in DataLoader(task_data, batch_size=32): optimizer.zero_grad() output = model(data) loss = F.cross_entropy(output, target) # 如果是EWC,添加正则项 if ewc and fisher: for n, p in model.named_parameters(): loss += (lambda_/2) * torch.sum(fisher[n] * (p - ewc[n])**2) loss.backward() optimizer.step()

3.2 评估指标设计

我们使用两个关键指标评估模型性能:

指标名称计算公式意义说明
准确率正确预测数/总样本数单任务表现
遗忘率(初始准确率-当前准确率)知识保留程度
正向迁移新任务表现-随机初始化表现旧知识对新任务的帮助

评估所有已学任务的代码片段:

def evaluate_all_tasks(model, tasks_so_far): results = {} model.eval() with torch.no_grad(): for i, task in enumerate(tasks_so_far): correct = 0 for data, target in DataLoader(task, batch_size=64): output = model(data) pred = output.argmax(dim=1) correct += (pred == target).sum().item() acc = correct / len(task) results[f"Task_{i}"] = acc return results

4. 结果可视化与分析

可视化是理解模型行为的关键。我们使用Matplotlib绘制两个关键图表:

4.1 准确率矩阵

def plot_acc_matrix(acc_history): plt.figure(figsize=(10,8)) tasks = len(acc_history) acc_matrix = np.zeros((tasks, tasks)) for eval_task in range(tasks): for train_task in range(eval_task+1): acc_matrix[eval_task, train_task] = acc_history[train_task][eval_task] plt.imshow(acc_matrix, cmap='Blues', vmin=0, vmax=1) plt.colorbar() plt.xlabel("Evaluation Task") plt.ylabel("Training Task") plt.title("Accuracy Matrix")

4.2 遗忘曲线

def plot_forgetting(acc_history): plt.figure(figsize=(10,6)) for task in range(len(acc_history)-1): initial_acc = acc_history[task][task] final_acc = acc_history[-1][task] plt.plot([task, len(acc_history)-1], [initial_acc, final_acc], label=f"Task {task}") plt.xlabel("Current Task") plt.ylabel("Accuracy") plt.title("Forgetting Curve") plt.legend()

5. 实战技巧与常见问题

在真实项目中,我们积累了一些宝贵经验:

  • 学习率调整:每个新任务开始时适当降低学习率(通常为初始值的1/5)
  • 批次平衡:确保每个批次包含来自当前任务和之前任务的数据
  • 正则化强度:EWC中的λ参数需要根据任务相似度调整

注意:Permuted MNIST最好使用MLP而非CNN,因为像素重排会破坏CNN依赖的空间局部性

常见错误及解决方案:

  1. 梯度爆炸

    • 现象:训练时loss突然变为NaN
    • 解决:添加梯度裁剪torch.nn.utils.clip_grad_norm_(model.parameters(), 1.0)
  2. 内存不足

    • 现象:训练多个任务后显存耗尽
    • 解决:及时清理旧任务的缓存torch.cuda.empty_cache()
  3. 评估模式错误

    • 现象:测试准确率远低于预期
    • 解决:确保评估时调用model.eval()并禁用梯度计算

6. 扩展与进阶方向

掌握了基础实现后,你可以尝试以下进阶方案:

  • 混合策略:结合EWC和LwF的优点
  • 动态架构:为每个任务添加专用子网络
  • 元学习:使用MAML等元学习算法优化初始参数
# 混合策略示例 class Hybrid_Model(nn.Module): def __init__(self): super().__init__() self.shared = nn.Sequential( nn.Linear(784, 256), nn.ReLU() ) self.task_specific = nn.ModuleList([ nn.Linear(256, 10) for _ in range(num_tasks) ]) def forward(self, x, task_id): x = x.view(-1, 784) x = self.shared(x) return self.task_specific[task_id](x)

在真实业务场景中,连续学习技术可以应用于:

  • 用户行为预测(随时间变化的偏好)
  • 金融风控(不断演变的欺诈模式)
  • 医疗诊断(新增疾病类别的识别)

最后分享一个实用技巧:在Permuted MNIST实验中,记录下每个任务使用的排列顺序,这样可以在后续分析时重现完全相同的实验条件。这看似简单,却能让你的实验结果更具可重复性和说服力。

http://www.jsqmd.com/news/737087/

相关文章:

  • 别再为TOG投稿格式发愁了!手把手教你用最新ACM LaTeX模板搞定SIGGRAPH论文
  • 怎样高效使用BBDown:7个专业技巧深度解析哔哩哔哩视频下载
  • Rdkit批量处理技巧:如何用PandasTools高效可视化你的化合物库(DataFrame操作指南)
  • 大模型KV缓存卸载技术:原理、挑战与优化方案
  • 从“特别版”到“够用版”:CodeWarrior for S12(X) V5.1 Special的32K代码限制与学习路径探讨
  • 2026年越野叉车口碑好的品牌 - mypinpai
  • 手把手教你用Arduino UNO的单个串口,轮询读取多个激光测距模块(Modbus RTU实战)
  • CGAL实战:手把手教你修复3D打印模型常见的Mesh问题(含代码示例)
  • 小红书数据采集完全指南:Python xhs库实战手册
  • 机器人视觉运动策略泛化:对象中心表示与Slot Attention机制
  • 2026年好用的跑步机厂家排名,奥邦体育受青睐 - mypinpai
  • 语言模型微调与BoN优化方法详解
  • 如何用Zotero茉莉花插件快速搞定中文文献管理:3大核心功能详解
  • io_uring 凭什么比 epoll 快——从共享环形缓冲区到内核线程池,追踪零拷贝提交的 3 层设计
  • 别再让CPU当搬运工了!STM32CubeMX配置DMA驱动串口,释放主循环性能(F407实战)
  • 网络工程师的日常:一次真实的办公室网络改造——用华为/华三交换机配置VLAN隔离财务部与研发部
  • 墨水屏Web内容生成器:AI布局与E-ink优化实战
  • Arm DesignStart项目IP资源解析与应用指南
  • Apriori算法实战避坑指南:处理大规模数据时,如何优化你的Python代码性能?
  • 数据大屏新宠:用ECharts水滴图打造动态数据监控面板(附完整Vue3+TS代码)
  • 基于文档布局感知的智能RAG系统:从结构理解到精准检索的工程实践
  • V-Reason框架:无训练视频推理的动态熵优化技术
  • Zotero GPT插件:5步打造你的AI文献研究助手
  • Steam成就管理器终极指南:免费开源工具让成就管理变得简单高效
  • 超越理论:在Python/Matlab中动手模拟三种光子,可视化理解散射介质成像的底层逻辑
  • 本地AI编程助手SwiftIDE:私有化部署与IDE集成实践
  • Autodesk Fusion 360 的 AI 助手 Adam Fusion 扩展:一键约 10 秒安装,免费使用!
  • 别再死记硬背了!我用Python爬虫+AI,5分钟搞定高校邦职业规划题库(附源码)
  • 保姆级教程:在ROS Noetic上为你的机器人接入科大讯飞星火大模型(附完整代码)
  • 从电视盒子到Armbian服务器:Amlogic S9xxx系列完整改装指南