|
|
@@ -175,22 +175,22 @@ async def ess_instance(create_client, slb_client, ess_count, max_workers):
|
|
|
]
|
|
|
await asyncio.wait(tasks)
|
|
|
logging.info(f"health instances count: {len(health_instances)}, {health_instances}")
|
|
|
- # # 5. 挂载流量
|
|
|
- # if len(health_instances) == len(ess_instance_ids):
|
|
|
- # # 所有机器探活成功
|
|
|
- # time.sleep(60)
|
|
|
- # add_weight_list = [(10, 30), (20, 20), (40, 10), (60, 10), (80, 10), (100, 10)]
|
|
|
- # set_instance_weight_process(client=slb_client, instance_id_list=ess_instance_ids, weight_list=add_weight_list)
|
|
|
- # global ess_instances
|
|
|
- # ess_instances.extend(ess_instance_ids)
|
|
|
- # logging.info(f"ess count: {ess_count}, "
|
|
|
- # f"create count: {len(ess_instance_ids)}, "
|
|
|
- # f"finished count: {len(health_instances)}")
|
|
|
- # else:
|
|
|
- # logging.info(f"ess count: {ess_count}, "
|
|
|
- # f"create count: {len(ess_instance_ids)}, "
|
|
|
- # f"health count: {len(health_instances)}")
|
|
|
- # sys.exit()
|
|
|
+ # 5. 挂载流量
|
|
|
+ if len(health_instances) == len(ess_instance_ids):
|
|
|
+ # 所有机器探活成功
|
|
|
+ time.sleep(60)
|
|
|
+ add_weight_list = [(10, 30), (20, 20), (40, 10), (60, 10), (80, 10), (100, 10)]
|
|
|
+ # set_instance_weight_process(client=slb_client, instance_id_list=ess_instance_ids, weight_list=add_weight_list)
|
|
|
+ global ess_instances
|
|
|
+ ess_instances.extend(ess_instance_ids)
|
|
|
+ logging.info(f"ess count: {ess_count}, "
|
|
|
+ f"create count: {len(ess_instance_ids)}, "
|
|
|
+ f"finished count: {len(health_instances)}")
|
|
|
+ else:
|
|
|
+ logging.info(f"ess count: {ess_count}, "
|
|
|
+ f"create count: {len(ess_instance_ids)}, "
|
|
|
+ f"health count: {len(health_instances)}")
|
|
|
+ sys.exit()
|
|
|
|
|
|
|
|
|
def remove_container_image(client, instance_id, container_name):
|
|
|
@@ -294,7 +294,7 @@ def remove_instances(create_client, slb_client, instance_ids):
|
|
|
:return: None
|
|
|
"""
|
|
|
# 1. 摘流量
|
|
|
- # set_instance_weight_process(client=slb_client, instance_id_list=instance_ids, weight_list=[(0, 60)])
|
|
|
+ set_instance_weight_process(client=slb_client, instance_id_list=instance_ids, weight_list=[(0, 60)])
|
|
|
logging.info(f"set weight = 0 finished, instances: {instance_ids}")
|
|
|
time.sleep(10)
|
|
|
# 2. 停止机器
|
