You need to enable JavaScript to run this app.
导航
RayCluster快速入门
最近更新时间:2024.05.20 11:13:22首次发布时间:2024.05.20 11:13:22

本章节以一种较为简单的方式访问RayCluster,并执行Ray 作业。

1 准备条件

  1. 部署EMR on VKE产品中Ray服务,并添加RayCluster组件。

  2. RayCluster组件运行正常。

  3. 提交作业到RayCluster,可以通过kubectl命令或者Ray的Client SDK提交:

    1. kubectl方式提交:需要安装kubectl工具,且配置火山引擎VKE集群的连接信息。

    2. 采用Ray SDK方式提交:需要部署Ray环境。

    为了快速入门,本章节是登录RayCluster的Head控制台,提交Ray job。

2 使用指导

  1. 通过EMR on VKE控制台,找到RayCluster所在的VKE集群,并找到Head所在的Pod,通过控制台方式访问

  1. 属于python命令,以交互式方式执行:
import ray

ray.init()
print(ray.cluster_resources())

ds = ray.data.range(100)
ds.show(limit=10)
  1. 将上述代码封装到python脚本demo.py中,采用ray job cli工具提交
mkdir -p /tmp/ray-working-dir
cd /tmp/ray-working-dir
echo "
import ray

ray.init()
print(ray.cluster_resources())

ds = ray.data.range(100)
ds.show(limit=10)
" > demo.py
ray job submit --working-dir . -- python demo.py
  1. 参考访问Ray Dashboard UI,查看集群和作业信息