Prefect 工作流中修改ray的地址

时间: 2024-11-10 admin IT培训

Prefect 工作流中修改ray的地址

Prefect 工作流中修改ray的地址

事情的起因

prefect 默认创建ray在127.0.0.1 上,我想在外网访问,想修改为0.0.0.0

尝试解决思路1(可行)

  1. 自己本地安装一个ray,但是连接不了redis
  2. 重新安装redis,使用docker安装的
  3. docker 安装需要将redis.conf进行改变并且复制到redis的docker里
  4. 这次能启动了,将要运行的python脚本改一下
 @flow(task_runner=RayTaskRunner())def my_flow():...
Connecting to an existing ray instance:  RayTaskRunner(address="ray://192.0.2.255:8786")

尝试解决思路2(尚不可行)

  1. 由于要安装redis太麻烦了,安装了ray-docker
  2. 但是prefect这边一直连不上,端口映射没问题
  3. 这次尝试失败

尝试解决思路3(可行)

  1. 直接打开prefect-ray的源码,在/usr/local/lib/python3.8/site-packages/prefect_ray
  2. 在task_runner.py 的_start 里修改context = ray.init(dashboard_host=“0.0.0.0”)