|
|
@@ -71,15 +71,17 @@ async def ess_instance(ecs_client, alb_client, ess_count, max_workers, port):
|
|
|
server_start_sh = os.path.join(longvideoapi_config.start_sh['target_dir'], longvideoapi_config.start_sh['name'])
|
|
|
server_start_commend = f"sh {server_start_sh} {start_sh_param}"
|
|
|
utils.run_command(ecs_client=ecs_client, instance_ids=ess_instance_ids, command=server_start_commend)
|
|
|
+ print(44444444444444444444)
|
|
|
# 4. 异步探活
|
|
|
global health_instances
|
|
|
health_instances = []
|
|
|
max_wait_time = 180
|
|
|
loop = asyncio.get_running_loop()
|
|
|
executor = ThreadPoolExecutor(max_workers=max_workers)
|
|
|
+ print(55555555555555555555)
|
|
|
tasks = [
|
|
|
loop.run_in_executor(executor, longvideoapi_health_check, *args) for args in
|
|
|
- [(alb_client, instance_id, max_wait_time) for instance_id in ess_instance_ids]
|
|
|
+ [(ecs_client, instance_id, max_wait_time) for instance_id in ess_instance_ids]
|
|
|
]
|
|
|
await asyncio.wait(tasks)
|
|
|
logging.info(f"health instances count: {len(health_instances)}, {health_instances}")
|
