TorchEasyRec为什么推荐用 OdpsDataset 而不是 OdpsDatasetV1来读数据?

简介: OdpsDataset(默认)是阿里TorchEasyRec推荐的数据集实现,相比旧版OdpsDatasetV1,其性能更优(批量Arrow读取+LZ4压缩)、支持断点续训、分布式协调精准分片、兼容30+复杂类型;V1仅作旧PAI环境兼容保留。

data.proto 可以看到,OdpsDataset 是 默认值(default = OdpsDataset),OdpsDatasetV1 是后来加的编号 4,实际上是保留的旧版兼容入口。

核心原因有以下几点:

1. 性能差距巨大

维度 OdpsDatasetV1 (common_io) OdpsDataset (Storage API)
读取方式 逐行 Python 循环 _do_read_with_retry() 批量 Arrow RecordBatch(C++ 层一次数万行)
序列化 每行独立序列化 → Python 对象 → pa.array Arrow IPC 列式格式,零拷贝
压缩 LZ4_FRAME(减少 ~60% 网络传输)
列裁剪 弱(selected_cols 字符串传入) 强(required_data_columns 服务端只发需要的列)

训练时数据量大(数十亿样本),V1 的逐行 Python 循环会成为严重瓶颈,数据加载速度远跟不上 GPU 计算速度。

2. 训练必需的断点续训(Checkpoint)

V2 支持完整的断点续训机制:

  • 每个 batch 注入 source_id(input_path#session_id:start)追踪读取位置
  • load_state_dict / _restore_sessions 可从中断处恢复读取
  • Session 有效期内可精确恢复到上次读取的行

V1 没有任何 checkpoint 支持,训练中断后只能从头开始。

3. 分布式训练支持

V2 内置分布式协调:

  • Rank 0 创建 session → broadcast_object_list 广播 sessionid 给所有 worker
  • calc_slice_intervals 精确的行级分片,确保多 worker 不重复不遗漏
  • Session 刷新守护线程(_refresh_sessions_daemon)防止长时间训练 session 超时

V1 只有简单的 slice_id / slice_count,没有分布式协调,多机训练时容易出问题。

4. 复杂类型支持

V1 只支持 5 种基础类型(bigint, double, boolean, string, datetime),训练中常见的 ARRAY<BIGINT>、MAP<STRING,FLOAT> 等特征类型无法直接读取,需要预先序列化为字符串。

V2 支持 30+ 种类型,包括嵌套的 ARRAY<ARRAY<T>> 和 MAP<K,V>,直接读取无需额外预处理。

5. V1 的存在意义

V1 保留下来主要是为了兼容旧版 PAI 平台环境,那些环境只有 common_io 而没有新版 Storage API SDK。新的训练任务都应该使用 OdpsDataset(默认值)。

总结

OdpsDataset 是生产训练的唯一合理选择,V1 在性能、断点续训、分布式、类型支持上全面落后,仅作为旧环境的兜底方案保留。


相关实践学习
使用PAI+LLaMA Factory微调Qwen2-VL模型,搭建文旅领域知识问答机器人
使用PAI和LLaMA Factory框架,基于全参方法微调 Qwen2-VL模型,使其能够进行文旅领域知识问答,同时通过人工测试验证了微调的效果。
机器学习概览及常见算法
机器学习(Machine Learning, ML)是人工智能的核心,专门研究计算机怎样模拟或实现人类的学习行为,以获取新的知识或技能,重新组织已有的知识结构使之不断改善自身的性能,它是使计算机具有智能的根本途径,其应用遍及人工智能的各个领域。 本课程将带你入门机器学习,掌握机器学习的概念和常用的算法。
相关文章
|
3月前
|
存储 搜索推荐 PyTorch
为什么使用 TorchRec 训练和推理更快
本文结合TorchEasyRec实践,从四大维度解析推荐系统加速:1)KeyedJaggedTensor统一变长特征,实现Embedding批量融合查找;2)自动分布式分片突破单卡显存瓶颈;3)TrainPipelineSparseDist流水线并行,重叠通信与计算;4)fbgemm-gpu融合优化器,减少显存访问。端到端提升训练效率与扩展性。
507 9
|
机器学习/深度学习 分布式计算 DataWorks
EasyRec 使用介绍|学习笔记
快速学习 EasyRec 使用介绍。
2200 0
|
1月前
|
机器学习/深度学习 人工智能 网络架构
深度解析:Transformer 的“灵魂”——QKV 变换的物理直觉
本文用图书馆检索等生活隐喻,从物理意义与认知科学角度解析Transformer中QKV设计的精妙本质:解耦查询(q)、键(k)、值(v)三重角色,实现语义分离、避免自注意力“自恋”,模拟人类动态信息路由的认知过程。(239字)
413 13
|
3月前
|
分布式计算 MaxCompute iOS开发
TorchEasyRec 在 macOS 上的功能限制总结
本文总结tzrec在macOS上的功能限制:核心依赖(如torchrec、fbgemm-gpu、graphlearn等)无法安装;分布式训练、原生数据管线、Embedding模块、Triton/CUDA算子、TDM树模型等功能完全不可用;优化器与模型导出部分失效;单元测试大多因强依赖而失败。
260 15
|
3月前
|
存储 搜索推荐 Python
TorchRec大量使用Jagged Tensor
Jagged Tensor(锯齿张量)是专为变长序列设计的紧凑存储格式,用values+lengths/offsets替代padding,显著节省内存与计算。广泛应用于推荐系统中用户行为、多值标签等不等长特征处理,如HSTU模型中的拼接、拆分与矩阵乘法操作。
423 8
|
3月前
|
机器学习/深度学习 分布式计算 搜索推荐
PAI-Rec 召回引擎:构建高性能推荐系统的核心引擎
PAI-Rec是阿里云智能推荐平台的核心召回引擎,经阿里大规模场景验证。支持多路召回融合(U2I/I2I/向量/随机)、召回即过滤、毫秒级实时更新与分布式弹性架构,开箱即用,助力企业构建毫秒级、高精度、强实时的推荐系统。
471 9
|
3月前
|
机器学习/深度学习 自然语言处理 iOS开发
Feature Generator(FG)特征算子配置指南
本文档全面介绍Feature Generator(FG)的各类特征算子配置方法,涵盖基础(ID/原始特征)、计算(表达式)、交叉(组合)、查找(Lookup/Match)、文本(重叠/BM25)、序列、预处理(分词/归一化)及字符串处理(正则替换/切片)等9大类算子,附详细配置示例与说明。
458 9
|
3月前
|
机器学习/深度学习 JSON 自然语言处理
PAI-Rec 特征工程全解析:统计特征、实时特征、序列特征与 FG 特征算子
PAI-Rec是阿里云智能推荐的特征工程解决方案,支持离线统计、实时及序列特征自动衍生,并通过Feature Generator(17种内置算子)保障离线/在线特征一致性,大幅降低开发与维护成本。
646 9
|
3月前
|
并行计算 算法框架/工具 iOS开发
TorchRec在macos ARM芯片(Apple Silicon)上无法安装
JaggedTensor等在macOS ARM芯片上无法运行,主因是ARM64与x86_64架构不兼容,且TorchRec深度依赖CUDA——而Apple Silicon仅支持Metal。fbgemm-gpu缺失、Rosetta 2不支持CUDA指令,导致关键操作失败。建议改用MLX框架或标准PyTorch张量替代。
401 4