FastChat
FastChat copied to clipboard
worker_name 和 worker_address混淆了吗
我用fastapi+transformers 启动了一个服务,在注册controller时,感觉是注册成功了,但获取worker状态报错
#worker_address:http://221.231.13.120:56908
worker_name = "worker-221.231.13.120-56908"
log: 2025-03-13 08:19:18 | INFO | controller | Register a new worker: worker-221.231.13.120-56908 2025-03-13 08:19:18 | ERROR | controller | Get status fails: worker-221.231.13.120-56908, Invalid URL 'worker-221.231.13.120-56908/worker_get_status': No scheme supplied. Perhaps you meant https://worker-221.231.13.120-56908/worker_get_status? 2025-03-13 08:19:18 | INFO | stdout | INFO: 221.231.13.120:52030 - "POST /register_worker HTTP/1.1" 200 OK 2025-03-13 08:32:41 | INFO | stdout | INFO: 121.237.36.31:54134 - "GET / HTTP/1.1" 404 Not Found
我的注册代码: def register_to_controller(controller_url, worker_url): try: worker_ip = worker_url.replace("http://", "").replace("https://", "").replace(":", "-") worker_name = f"worker-{worker_ip}" # worker_name = "worker-221.231.13.120-56908"
requests.post(f"{controller_url}/register_worker", json={
"model_names": [MODEL_NAME],
"worker_address": worker_url,
"worker_name": worker_url, # 生成一个 worker_name
"check_heart_beat": True # ✅ 添加这个字段
})
logger.info(f"✅ Worker 注册成功: {worker_url} -> {controller_url}")
except Exception as e:
print(f"❌ 注册失败: {e}")