|
|
@@ -209,6 +209,7 @@ async def update_instance(create_client, slb_client, instance_ids, max_workers,
|
|
|
instance_ids_group = [instance_ids[:media_index], instance_ids[media_index:]]
|
|
|
update_finished_count = 0
|
|
|
for instance_id_list in instance_ids_group:
|
|
|
+ logging.info(f"update instances: {instance_id_list}")
|
|
|
# 1. 摘流量
|
|
|
set_instance_weight_process(client=slb_client, instance_id_list=instance_id_list, weight_list=[(0, 60)])
|
|
|
logging.info(f"set weight with 0 finished, instances: {instance_id_list}")
|
|
|
@@ -334,11 +335,11 @@ def main():
|
|
|
asyncio.run(update_instance(create_client=create_client, slb_client=slb_client,
|
|
|
instance_ids=online_instance_ids, max_workers=2, version=version))
|
|
|
logging.info(f"update online instances end!")
|
|
|
- #
|
|
|
- # # 4. 停止并释放扩容机器
|
|
|
- # logging.info(f"stop & release instances start ...")
|
|
|
- # remove_instances(create_client=create_client, slb_client=slb_client, instance_ids=ess_instances)
|
|
|
- # logging.info(f"stop & release instances end!")
|
|
|
+
|
|
|
+ # 4. 停止并释放扩容机器
|
|
|
+ logging.info(f"stop & release instances start ...")
|
|
|
+ remove_instances(create_client=create_client, slb_client=slb_client, instance_ids=ess_instances)
|
|
|
+ logging.info(f"stop & release instances end!")
|
|
|
except Exception as e:
|
|
|
logging.error(e)
|
|
|
sys.exit()
|
