本章节以一种较为简单的方式访问RayCluster,并执行Ray 作业。
部署EMR on VKE产品中Ray服务,并添加RayCluster组件。
RayCluster组件运行正常。
提交作业到RayCluster,可以通过kubectl命令或者Ray的Client SDK提交:
kubectl方式提交:需要安装kubectl工具,且配置火山引擎VKE集群的连接信息。
采用Ray SDK方式提交:需要部署Ray环境。
为了快速入门,本章节是登录RayCluster的Head控制台,提交Ray job。
import ray ray.init() print(ray.cluster_resources()) ds = ray.data.range(100) ds.show(limit=10)
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