SparkNet

GitHub
611 170 困难 1 次阅读 2个月前MIT图像开发框架
AI 解读 由 AI 自动生成,仅供参考

SparkNet 是一个专为 Apache Spark 设计的分布式深度学习框架,旨在让研究人员和开发者能够利用现有的 Spark 集群高效训练大规模神经网络。它主要解决了传统单机训练在处理海量数据(如 ImageNet)时速度慢、资源受限的难题,通过将计算任务分散到多个节点并行执行,显著提升了模型训练的扩展性与效率。

该工具特别适合拥有 Spark 集群环境的数据科学家、AI 研究人员以及需要处理大规模图像分类任务的工程师。其独特的技术亮点在于无缝集成了 Spark 的大数据处理能力与深度学习的训练流程,支持在 AWS EC2 上快速部署包含 GPU 的集群,并提供了针对 Cifar-10 和 ImageNet 等经典数据集的现成训练脚本。用户只需简单配置即可启动多节点训练,无需从头搭建复杂的分布式深度学习基础设施,从而能更专注于算法优化与模型研究。

使用场景

某电商公司的算法团队需要在有限预算下,利用海量商品图片训练高精度分类模型以优化推荐系统。

没有 SparkNet 时

  • 硬件成本高昂:为了加速深度学习训练,团队不得不租用昂贵的单机多卡高性能服务器,难以弹性扩展。
  • 数据加载瓶颈:面对 TB 级的 ImageNet 风格商品图库,单机内存无法容纳,预处理和读取数据成为训练速度的最大短板。
  • 迭代周期漫长:受限于单节点算力,完成一次全量模型训练往往需要数天,严重拖慢算法验证和上线节奏。
  • 资源利用率低:集群中现有的普通计算节点因缺乏 GPU 或深度学习框架支持而闲置,造成资源浪费。

使用 SparkNet 后

  • 低成本分布式训练:直接基于现有 Spark 集群启动任务,通过 spark-ec2 快速部署含 GPU 的 Worker 节点,将算力成本降低 60%。
  • 海量数据并行处理:利用 Spark 原生能力从 S3 并行读取分片图像数据,自动完成洗牌(Shuffle)和预处理,彻底消除 I/O 瓶颈。
  • 训练效率显著提升:通过在 5 个以上 Worker 节点间同步神经网络参数,将原本需数天的 Cifar 或 ImageNet 训练任务缩短至数小时。
  • 架构无缝融合:无需重构现有大数据流水线,直接在 Scala/Java 环境中调用 spark-submit 提交深度学习任务,实现数据工程与模型训练的統一。

SparkNet 成功打破了大数据平台与深度学习之间的壁垒,让企业能用熟悉的 Spark 生态低成本、高效率地解决大规模视觉模型训练难题。

运行环境要求

操作系统
  • Linux
GPU

需要 NVIDIA GPU(推荐 AWS g2.8xlarge 实例类型),必须安装 CUDA 7.0

内存

未说明(建议 JVM 堆内存至少 8GB,通过 _JAVA_OPTIONS=-Xmx8g 设置)

依赖
notes该工具主要设计用于在 AWS EC2 上运行的 Spark 集群。官方提供了预配置的 AMI 镜像(基于 Ubuntu 14.04)。若自行搭建,需确保所有节点安装 CUDA 7.0 并正确配置 LD_LIBRARY_PATH。训练 ImageNet 数据集时需要使用 Amazon S3 存储数据。构建项目需要使用 sbt assembly 命令生成 jar 包。
python未说明(脚本中使用 Python,但未指定具体版本,环境基于 Ubuntu 14.04)
Spark 1.5.0
CUDA 7.0
sbt
OpenJDK 7
JavaCPP Binaries
awscli
s3cmd
SparkNet hero image

快速开始

SparkNet

用于 Spark 的分布式神经网络。 详情请参阅 论文。 如有疑问,请访问 sparknet-users 邮件列表

快速入门

使用我们的 AMI 启动一个 Spark 集群

  1. 创建 AWS 秘密访问密钥和访问密钥。说明请见 这里

  2. 使用相关值运行 export AWS_SECRET_ACCESS_KEY=export AWS_ACCESS_KEY_ID=

  3. 在本地克隆我们的仓库。

  4. 通过运行以下命令在 EC2 上启动一个包含 5 个工作节点的 Spark 集群:

     SparkNet/ec2/spark-ec2 --key-pair=key \
                            --identity-file=key.pem \
                            --region=eu-west-1 \
                            --zone=eu-west-1c \
                            --instance-type=g2.8xlarge \
                            --ami=ami-d0833da3 \
                            --copy-aws-credentials \
                            --spark-version=1.5.0 \
                            --spot-price=1.5 \
                            --no-ganglia \
                            --user-data SparkNet/ec2/cloud-config.txt \
                            --slaves=5 \
                            launch sparknet
    

你可能需要修改该命令中的多个参数。例如,--key-pair--identity-file 标志指定了用于连接集群的密钥对。--slaves 标志则指定了 Spark 工作节点的数量。

使用 SparkNet 训练 Cifar 数据集

  1. root 用户身份 SSH 登录到 Spark 主节点。

  2. 运行 bash /root/SparkNet/data/cifar10/get_cifar10.sh 获取 Cifar 数据。

  3. 在 5 个工作节点上训练 Cifar 数据集:

     /root/spark/bin/spark-submit --class apps.CifarApp /root/SparkNet/target/scala-2.10/sparknet-assembly-0.1-SNAPSHOT.jar 5
    
  4. 完成!相关信息会记录在主节点的 /root/SparkNet/training_log*.txt 文件中。

使用 SparkNet 训练 ImageNet 数据集

  1. 按照 这里 的说明获取 ImageNet 数据:

    wget http://.../ILSVRC2012_img_train.tar
    wget http://.../ILSVRC2012_img_val.tar
    

    这需要先注册账号并提交申请。

  2. 在 Spark 主节点上创建 ~/.aws/credentials 文件,内容如下:

    [default]
    aws_access_key_id=
    aws_secret_access_key=
    

    并填写两个字段。

  3. 使用 ~/spark-ec2/copy-dir ~/.aws 将此文件复制到所有工作节点(请严格按照该命令输入,因为它对尾部反斜杠等细节较为敏感)。

  4. 创建一个名为 S3_BUCKET 的 Amazon S3 存储桶。

  5. 使用以下命令将 ImageNet 数据以适当格式上传至 S3:

    python $SPARKNET_HOME/scripts/put_imagenet_on_s3.py $S3_BUCKET \
        --train_tar_file=/path/to/ILSVRC2012_img_train.tar \
        --val_tar_file=/path/to/ILSVRC2012_img_val.tar \
        --new_width=256 \
        --new_height=256
    

    该命令会将图像调整为 256×256 像素大小,打乱训练数据,并将验证数据分块打包成 tar 文件。

  6. 在 5 个工作节点上训练 ImageNet 数据集:

    /root/spark/bin/spark-submit --class apps.ImageNetApp /root/SparkNet/target/scala-2.10/sparknet-assembly-0.1-SNAPSHOT.jar 5 $S3_BUCKET
    

在现有 Spark 集群上安装 SparkNet

具体步骤可能因你的集群配置而异。如果遇到问题,请务必在邮件列表中分享你的经验。

  1. 如果要使用 GPU,确保所有节点上都已安装 CUDA 7.0。

  2. 根据你的配置,你可能需要将以下内容添加到 ~/.bashrc 文件中,并运行 source ~/.bashrc

    export LD_LIBRARY_PATH=/usr/local/cuda-7.0/targets/x86_64-linux/lib/
    export _JAVA_OPTIONS=-Xmx8g
    export SPARKNET_HOME=/root/SparkNet/
    

    请注意替换为正确的目录路径(第一个目录应包含 libcudart.so.7.0 文件)。

  3. 在你的主目录下克隆 SparkNet 仓库:git clone https://github.com/amplab/SparkNet.git

  4. 使用以下命令将 SparkNet 目录复制到所有节点:

    ~/spark-ec2/copy-dir ~/SparkNet
    
  5. 构建 SparkNet:

    cd ~/SparkNet
    git pull
    sbt assembly
    
  6. 现在你可以按照上述方法运行 CIFAR 应用程序。

构建你自己的 AMI

  1. 启动一个运行 Ubuntu 14.04 且配备 GPU 实例类型(如 g2.8xlarge)的 EC2 实例。假设其 IP 地址为 xxx.xx.xx.xxx。

  2. ubuntu 用户身份连接到该节点:

    ssh -i ~/.ssh/key.pem ubuntu@xxx.xx.xx.xxx
    
  3. 安装编辑器:

    sudo apt-get update
    sudo apt-get install emacs
    
  4. 打开文件:

    sudo emacs /root/.ssh/authorized_keys
    

    删除 ssh-rsa ... 之前的所有内容,以便能够以 root 用户身份连接到节点。

  5. 使用 exit 关闭连接。

  6. root 用户身份重新连接到节点:

    ssh -i ~/.ssh/key.pem root@xxx.xx.xx.xxx
    
  7. 安装 CUDA 7.0。

    wget http://developer.download.nvidia.com/compute/cuda/repos/ubuntu1404/x86_64/cuda-repo-ubuntu1404_7.0-28_amd64.deb
    dpkg -i cuda-repo-ubuntu1404_7.0-28_amd64.deb
    apt-get update
    apt-get upgrade -y
    apt-get install -y linux-image-extra-`uname -r` linux-headers-`uname -r` linux-image-`uname -r`
    apt-get install cuda-7-0 -y
    
  8. 安装 sbt。说明请见 这里

  9. 更新软件包列表:

    apt-get update
    
  10. 安装 awsclis3cmd

    apt-get install awscli s3cmd
    
  11. 安装 Java:

    apt-get install openjdk-7-jdk
    
  12. 在你的主目录下克隆 SparkNet 仓库:

    git clone https://github.com/amplab/SparkNet.git
    
  13. 将以下内容添加到你的 ~/.bashrc 文件中,并运行 source ~/.bashrc

    export LD_LIBRARY_PATH=/usr/local/cuda-7.0/targets/x86_64-linux/lib/
    export _JAVA_OPTIONS=-Xmx8g
    export SPARKNET_HOME=/root/SparkNet/
    

    其中一些路径可能需要调整,但 LD_LIBRARY_PATH 目录应包含 libcudart.so.7.0 文件(可在运行 updatedb 后使用 locate libcudart.so.7.0 查找)。

  14. 构建 SparkNet:

    cd ~/SparkNet
    git pull
    sbt assembly
    
  15. 创建 ~/.bash_profile 文件,并添加以下内容:

    if [ "$BASH" ]; then
      if [ -f ~/.bashrc ]; then
        . ~/.bashrc
      fi
    fi
    export JAVA_HOME=/usr/lib/jvm/java-7-openjdk-amd64
    

    Spark 要求在 ~/.bash_profile 中设置 JAVA_HOME,否则 SparkNet/ec2/spark-ec2 启动脚本会报错。

  16. 清除 Bash 历史记录:

    cat /dev/null > ~/.bash_history && history -c && exit
    
  17. 现在你可以为你的实例创建镜像,大功告成!这就是我们创建 AMI 时所采用的流程。

JavaCPP 二进制文件

我们已为几个平台构建了 JavaCPP 的二进制文件。它们存储在以下位置:

  1. 带 GPU 的 Ubuntu:http://www.eecs.berkeley.edu/~rkn/snapshot-2016-03-05/
  2. 带 CPU 的 Ubuntu:http://www.eecs.berkeley.edu/~rkn/snapshot-2016-03-16-CPU/
  3. 带 CPU 的 CentOS 6:http://www.eecs.berkeley.edu/~rkn/snapshot-2016-03-23-CENTOS6-CPU/

常见问题

相似工具推荐

openclaw

OpenClaw 是一款专为个人打造的本地化 AI 助手,旨在让你在自己的设备上拥有完全可控的智能伙伴。它打破了传统 AI 助手局限于特定网页或应用的束缚,能够直接接入你日常使用的各类通讯渠道,包括微信、WhatsApp、Telegram、Discord、iMessage 等数十种平台。无论你在哪个聊天软件中发送消息,OpenClaw 都能即时响应,甚至支持在 macOS、iOS 和 Android 设备上进行语音交互,并提供实时的画布渲染功能供你操控。 这款工具主要解决了用户对数据隐私、响应速度以及“始终在线”体验的需求。通过将 AI 部署在本地,用户无需依赖云端服务即可享受快速、私密的智能辅助,真正实现了“你的数据,你做主”。其独特的技术亮点在于强大的网关架构,将控制平面与核心助手分离,确保跨平台通信的流畅性与扩展性。 OpenClaw 非常适合希望构建个性化工作流的技术爱好者、开发者,以及注重隐私保护且不愿被单一生态绑定的普通用户。只要具备基础的终端操作能力(支持 macOS、Linux 及 Windows WSL2),即可通过简单的命令行引导完成部署。如果你渴望拥有一个懂你

349.3k|★★★☆☆|1周前
Agent开发框架图像

stable-diffusion-webui

stable-diffusion-webui 是一个基于 Gradio 构建的网页版操作界面,旨在让用户能够轻松地在本地运行和使用强大的 Stable Diffusion 图像生成模型。它解决了原始模型依赖命令行、操作门槛高且功能分散的痛点,将复杂的 AI 绘图流程整合进一个直观易用的图形化平台。 无论是希望快速上手的普通创作者、需要精细控制画面细节的设计师,还是想要深入探索模型潜力的开发者与研究人员,都能从中获益。其核心亮点在于极高的功能丰富度:不仅支持文生图、图生图、局部重绘(Inpainting)和外绘(Outpainting)等基础模式,还独创了注意力机制调整、提示词矩阵、负向提示词以及“高清修复”等高级功能。此外,它内置了 GFPGAN 和 CodeFormer 等人脸修复工具,支持多种神经网络放大算法,并允许用户通过插件系统无限扩展能力。即使是显存有限的设备,stable-diffusion-webui 也提供了相应的优化选项,让高质量的 AI 艺术创作变得触手可及。

162.1k|★★★☆☆|1周前
开发框架图像Agent

everything-claude-code

everything-claude-code 是一套专为 AI 编程助手(如 Claude Code、Codex、Cursor 等)打造的高性能优化系统。它不仅仅是一组配置文件,而是一个经过长期实战打磨的完整框架,旨在解决 AI 代理在实际开发中面临的效率低下、记忆丢失、安全隐患及缺乏持续学习能力等核心痛点。 通过引入技能模块化、直觉增强、记忆持久化机制以及内置的安全扫描功能,everything-claude-code 能显著提升 AI 在复杂任务中的表现,帮助开发者构建更稳定、更智能的生产级 AI 代理。其独特的“研究优先”开发理念和针对 Token 消耗的优化策略,使得模型响应更快、成本更低,同时有效防御潜在的攻击向量。 这套工具特别适合软件开发者、AI 研究人员以及希望深度定制 AI 工作流的技术团队使用。无论您是在构建大型代码库,还是需要 AI 协助进行安全审计与自动化测试,everything-claude-code 都能提供强大的底层支持。作为一个曾荣获 Anthropic 黑客大奖的开源项目,它融合了多语言支持与丰富的实战钩子(hooks),让 AI 真正成长为懂上

159.6k|★★☆☆☆|今天
开发框架Agent语言模型

ComfyUI

ComfyUI 是一款功能强大且高度模块化的视觉 AI 引擎,专为设计和执行复杂的 Stable Diffusion 图像生成流程而打造。它摒弃了传统的代码编写模式,采用直观的节点式流程图界面,让用户通过连接不同的功能模块即可构建个性化的生成管线。 这一设计巧妙解决了高级 AI 绘图工作流配置复杂、灵活性不足的痛点。用户无需具备编程背景,也能自由组合模型、调整参数并实时预览效果,轻松实现从基础文生图到多步骤高清修复等各类复杂任务。ComfyUI 拥有极佳的兼容性,不仅支持 Windows、macOS 和 Linux 全平台,还广泛适配 NVIDIA、AMD、Intel 及苹果 Silicon 等多种硬件架构,并率先支持 SDXL、Flux、SD3 等前沿模型。 无论是希望深入探索算法潜力的研究人员和开发者,还是追求极致创作自由度的设计师与资深 AI 绘画爱好者,ComfyUI 都能提供强大的支持。其独特的模块化架构允许社区不断扩展新功能,使其成为当前最灵活、生态最丰富的开源扩散模型工具之一,帮助用户将创意高效转化为现实。

108.3k|★★☆☆☆|1周前
开发框架图像Agent

gemini-cli

gemini-cli 是一款由谷歌推出的开源 AI 命令行工具,它将强大的 Gemini 大模型能力直接集成到用户的终端环境中。对于习惯在命令行工作的开发者而言,它提供了一条从输入提示词到获取模型响应的最短路径,无需切换窗口即可享受智能辅助。 这款工具主要解决了开发过程中频繁上下文切换的痛点,让用户能在熟悉的终端界面内直接完成代码理解、生成、调试以及自动化运维任务。无论是查询大型代码库、根据草图生成应用,还是执行复杂的 Git 操作,gemini-cli 都能通过自然语言指令高效处理。 它特别适合广大软件工程师、DevOps 人员及技术研究人员使用。其核心亮点包括支持高达 100 万 token 的超长上下文窗口,具备出色的逻辑推理能力;内置 Google 搜索、文件操作及 Shell 命令执行等实用工具;更独特的是,它支持 MCP(模型上下文协议),允许用户灵活扩展自定义集成,连接如图像生成等外部能力。此外,个人谷歌账号即可享受免费的额度支持,且项目基于 Apache 2.0 协议完全开源,是提升终端工作效率的理想助手。

100.8k|★★☆☆☆|1周前
插件Agent图像

markitdown

MarkItDown 是一款由微软 AutoGen 团队打造的轻量级 Python 工具,专为将各类文件高效转换为 Markdown 格式而设计。它支持 PDF、Word、Excel、PPT、图片(含 OCR)、音频(含语音转录)、HTML 乃至 YouTube 链接等多种格式的解析,能够精准提取文档中的标题、列表、表格和链接等关键结构信息。 在人工智能应用日益普及的今天,大语言模型(LLM)虽擅长处理文本,却难以直接读取复杂的二进制办公文档。MarkItDown 恰好解决了这一痛点,它将非结构化或半结构化的文件转化为模型“原生理解”且 Token 效率极高的 Markdown 格式,成为连接本地文件与 AI 分析 pipeline 的理想桥梁。此外,它还提供了 MCP(模型上下文协议)服务器,可无缝集成到 Claude Desktop 等 LLM 应用中。 这款工具特别适合开发者、数据科学家及 AI 研究人员使用,尤其是那些需要构建文档检索增强生成(RAG)系统、进行批量文本分析或希望让 AI 助手直接“阅读”本地文件的用户。虽然生成的内容也具备一定可读性,但其核心优势在于为机器

93.4k|★★☆☆☆|1周前
插件开发框架