启动head节点

ray start --head --port=6379 --include-dashboard=true --dashboard-host=0.0.0.0 --dashboard-port=8265

启动Master节点并将dashboard设置为任何ip都可以访问。

其它节点连接ray集群：

ray start --address='xx.244.15.63:6379'

python程序连接到集群：

import ray
ray.init(redis_address="xx.244.15.63:6379")

查看ray的状态

ray status

终止ray

ray stop

示例程序：

import ray
import time

ray.init(redis_address="xx.244.15.63:6379")

@ray.remote
def f1():
    time.sleep(1)
    return 0

res = ray.get([ f1.remote() for _ in range(50)])