Keyboard shortcuts

Press ← or → to navigate between chapters

Press S or / to search in the book

Press ? to show this help

Press Esc to hide this help


title: “Accelerate — Run PyTorch training across GPUs with minimal changes” sidebar_label: “Accelerate” description: “Run PyTorch training across GPUs with minimal changes”

{/* 本页面由 website/scripts/generate-skill-docs.py 根据技能对应的 SKILL.md 文件自动生成。请直接编辑源文件 SKILL.md,而非此页面。 */}

Accelerate

通过最少的代码修改即可实现跨 GPU 的 PyTorch 训练。

技能元数据

来源可选 — 通过 hermes skills install official/mlops/accelerate 安装
路径optional-skills/mlops\accelerate
版本1.0.1
开发者Orchestra Research
许可协议MIT
依赖项accelerate, torch, transformers
支持平台linux, macos, windows
标签分布式训练, HuggingFace, Accelerate, DeepSpeed, FSDP, 混合精度, PyTorch, DDP, 统一接口, 简单易用

参考:完整的 SKILL.md 文件

:::info 以下是当触发该技能时 Hermes 会加载的完整技能定义。当技能处于激活状态时,智能体看到的指令即为此内容。
::

HuggingFace Accelerate - 统一分布式训练方案

快速入门

Accelerate 将分布式训练简化为仅 4 行代码即可完成。

安装方式:

pip install accelerate

转换 PyTorch 脚本(4 行):

import torch
+ from accelerate import Accelerator

+ accelerator = Accelerator()

  model = torch.nn.Transformer()
  optimizer = torch.optim.Adam(model.parameters())
  dataloader = torch.utils.data.DataLoader(dataset)

+ model, optimizer, dataloader = accelerator.prepare(model, optimizer, dataloader)

  for batch in dataloader:
      optimizer.zero_grad()
      loss = model(batch)
-     loss.backward()
+     accelerator.backward(loss)
      optimizer.step()

运行(单条命令):

accelerate launch train.py

常见工作流

工作流 1:从单 GPU 过渡到多 GPU

原始脚本:

# train.py
import torch

model = torch.nn.Linear(10, 2).to('cuda')
optimizer = torch.optim.Adam(model.parameters())
dataloader = torch.utils.data.DataLoader(dataset, batch_size=32)

for epoch in range(10):
    for batch in dataloader:
        batch = batch.to('cuda')
        optimizer.zero_grad()
        loss = model(batch).mean()
        loss.backward()
        optimizer.step()

启用 Accelerate 功能(新增 4 行):

# train.py
import torch
from accelerate import Accelerator  # +1

accelerator = Accelerator()  # +2

model = torch.nn.Linear(10, 2)
optimizer = torch.optim.Adam(model.parameters())
dataloader = torch.utils.data.DataLoader(dataset, batch_size=32)

model, optimizer, dataloader = accelerator.prepare(model, optimizer, dataloader)  # +3

for epoch in range(10):
    for batch in dataloader:
        # No .to('cuda') needed - automatic!
        optimizer.zero_grad()
        loss = model(batch).mean()
        accelerator.backward(loss)  # +4
        optimizer.step()

配置(交互模式):

accelerate config

问题设置:

  • 使用哪种计算设备?(单 GPU/多 GPU/TPU/CPU)
  • 需要多少台设备?(1 台)
  • 是否使用混合精度?(否/fp16/bf16/fp8)
  • 是否启用 DeepSpeed?(否/是)

启动选项(适用于所有配置环境):

# Single GPU
accelerate launch train.py

# Multi-GPU (8 GPUs)
accelerate launch --multi_gpu --num_processes 8 train.py

# Multi-node
accelerate launch --multi_gpu --num_processes 16 \
  --num_machines 2 --machine_rank 0 \
  --main_process_ip $MASTER_ADDR \
  train.py

工作流 2:混合精度训练

启用 FP16/BF16:

from accelerate import Accelerator

# FP16 (with gradient scaling)
accelerator = Accelerator(mixed_precision='fp16')

# BF16 (no scaling, more stable)
accelerator = Accelerator(mixed_precision='bf16')

# FP8 (H100+)
accelerator = Accelerator(mixed_precision='fp8')

model, optimizer, dataloader = accelerator.prepare(model, optimizer, dataloader)

# Everything else is automatic!
for batch in dataloader:
    with accelerator.autocast():  # Optional, done automatically
        loss = model(batch)
    accelerator.backward(loss)

工作流 3:DeepSpeed ZeRO 集成

启用 DeepSpeed ZeRO-2(需传入 DeepSpeedPlugin 对象,而非原始字典):

from accelerate import Accelerator, DeepSpeedPlugin

deepspeed_plugin = DeepSpeedPlugin(
    zero_stage=2,                     # ZeRO-2
    offload_optimizer_device="none",  # or "cpu" to offload
    gradient_accumulation_steps=4,
)

accelerator = Accelerator(
    mixed_precision='bf16',
    deepspeed_plugin=deepspeed_plugin,  # DeepSpeedPlugin instance (or dict[str, DeepSpeedPlugin])
)

# Same code as before!
model, optimizer, dataloader = accelerator.prepare(model, optimizer, dataloader)

或者通过插件直接指定完整的 DeepSpeed JSON 配置文件:

from accelerate import Accelerator, DeepSpeedPlugin

# hf_ds_config accepts a path to a DeepSpeed config JSON (or a dict)
deepspeed_plugin = DeepSpeedPlugin(hf_ds_config="ds_config.json")
accelerator = Accelerator(mixed_precision='bf16', deepspeed_plugin=deepspeed_plugin)

ds_config.json(原始的 DeepSpeed 配置文件——通过插件传递,而非通过 --config_file 参数传递):

{
    "fp16": {"enabled": false},
    "bf16": {"enabled": true},
    "zero_optimization": {
        "stage": 2,
        "offload_optimizer": {"device": "cpu"},
        "allgather_bucket_size": 5e8,
        "reduce_bucket_size": 5e8
    }
}

或通过交互式配置:

accelerate config
# Select: DeepSpeed → ZeRO-2
# This writes an accelerate YAML config (default: ~/.cache/huggingface/accelerate/default_config.yaml)

启动(--config_file 参数要求输入的是加速配置的 YAML 文件,而非原始的 DeepSpeed JSON 文件):

# Uses the default accelerate config written by `accelerate config`
accelerate launch train.py

# Or point at a specific accelerate YAML
accelerate launch --config_file accelerate_deepspeed.yaml train.py

工作流 4:FSDP(完全分片数据并行)

启用 FSDP:

from accelerate import Accelerator, FullyShardedDataParallelPlugin

fsdp_plugin = FullyShardedDataParallelPlugin(
    sharding_strategy="FULL_SHARD",  # ZeRO-3 equivalent
    auto_wrap_policy="transformer_based_wrap",  # valid: transformer_based_wrap | size_based_wrap | no_wrap
    cpu_offload=False
)

accelerator = Accelerator(
    mixed_precision='bf16',
    fsdp_plugin=fsdp_plugin
)

model, optimizer, dataloader = accelerator.prepare(model, optimizer, dataloader)

或通过配置文件:

accelerate config
# Select: FSDP → Full Shard → No CPU Offload

工作流 5:梯度累积

累积梯度:

from accelerate import Accelerator

accelerator = Accelerator(gradient_accumulation_steps=4)

model, optimizer, dataloader = accelerator.prepare(model, optimizer, dataloader)

for batch in dataloader:
    with accelerator.accumulate(model):  # Handles accumulation
        optimizer.zero_grad()
        loss = model(batch)
        accelerator.backward(loss)
        optimizer.step()

有效批量大小:batch_size * num_gpus * gradient_accumulation_steps

何时使用 Accelerate 及其替代方案

适合使用 Accelerate 的情况:

  • 需要最简单的分布式训练方式
  • 希望使用单个脚本适配各类硬件
  • 已在使用 HuggingFace 生态系统
  • 需要多种训练框架的灵活性(DDP/DeepSpeed/FSDP/Megatron)
  • 需要快速进行原型开发

主要优势:

  • 仅需 4 行代码:几乎无需修改现有代码
  • 统一 API:DDP、DeepSpeed、FSDP、Megatron 均可使用相同代码
  • 自动处理:设备分配、混合精度计算及数据分片等功能均由系统自动完成
  • 交互式配置:无需手动设置启动参数
  • 单次启动即可运行:在任何环境中都能正常工作

应选择替代方案的情况:

  • PyTorch Lightning:需要回调函数及高级抽象层功能
  • Ray Train:需要进行多节点任务调度及超参数调优
  • DeepSpeed:需要直接控制 API 并使用高级功能
  • 原始 DDP:需要最大程度的控制权且不希望过多抽象层

常见问题

问题:设备分配错误

请勿手动将模型移动到目标设备:

# WRONG
batch = batch.to('cuda')

# CORRECT
# Accelerate handles it automatically after prepare()

问题:梯度累积功能无法正常使用

请使用上下文管理器:

# CORRECT
with accelerator.accumulate(model):
    optimizer.zero_grad()
    accelerator.backward(loss)
    optimizer.step()

问题:分布式环境下的检查点机制

请使用加速器方法:

# Save only on main process
if accelerator.is_main_process:
    accelerator.save_state('checkpoint/')

# Load on all processes
accelerator.load_state('checkpoint/')

问题:使用 FSDP 时结果不一致

请确保随机种子相同:

from accelerate.utils import set_seed
set_seed(42)

高级主题

Megatron集成:如需了解张量并行、流水线并行及序列并行配置的相关信息,请参阅references/megatron-integration.md。

自定义插件:如需创建自定义分布式插件并进行高级配置,可参考references/custom-plugins.md。

性能调优:有关性能分析、内存优化及最佳实践的内容,请查阅references/performance.md。

硬件要求

  • CPU:可用(速度较慢)
  • 单GPU:可用
  • 多GPU:支持DDP(默认)、DeepSpeed或FSDP
  • 多节点:支持DDP、DeepSpeed、FSDP及Megatron
  • TPU:支持
  • Apple MPS:支持

启动器要求:

  • DDP:使用torch.distributed.run(内置功能)
  • DeepSpeed:需安装deepspeed(通过pip命令安装)
  • FSDP:需要PyTorch 1.12及以上版本(内置功能)
  • Megatron:需进行自定义配置

参考资源

  • 文档:https://huggingface.co/docs/accelerate
  • GitHub仓库:https://github.com/huggingface/accelerate
  • 版本:1.11.0及以上
  • 教程:“加速你的脚本”
  • 示例代码:https://github.com/huggingface/accelerate/tree/main/examples
  • 被以下工具采用:HuggingFace Transformers、TRL、PEFT以及所有HF系列库