|
|
@@ -111,15 +111,15 @@ def setInstanceWeightProcess(instance_id):
|
|
|
# 直接加载100会出现502。权重值每次增加20，每5s修改一次
|
|
|
# for i in range(1, 6):
|
|
|
# weight = i * 20
|
|
|
- for weight in [10, 20, 40, 60, 80, 100]:
|
|
|
+ for weight, sleep_time in [(10, 30), (20, 20), (40, 10), (60, 10), (80, 10), (100, 10)]:
|
|
|
flag = True
|
|
|
while flag:
|
|
|
try:
|
|
|
setWeight(slb_id_1, instance_id, weight)
|
|
|
- time.sleep(5)
|
|
|
+ time.sleep(sleep_time)
|
|
|
flag = False
|
|
|
except Exception as e:
|
|
|
- time.sleep(5)
|
|
|
+ time.sleep(10)
|
|
|
continue
|
|
|
|
|
|
|
|
|
@@ -252,7 +252,8 @@ if __name__ == '__main__':
|
|
|
q2 = queue.Queue()
|
|
|
# 获取slb下所有服务器的 instance_id
|
|
|
if res["BackendServers"]["BackendServer"]:
|
|
|
- for i in range((len(res["BackendServers"]["BackendServer"]))):
|
|
|
+ # for i in range((len(res["BackendServers"]["BackendServer"]))):
|
|
|
+ for i in range(2):
|
|
|
instance_id = res["BackendServers"]["BackendServer"][i]["ServerId"]
|
|
|
q1.put(instance_id)
|
|
|
|
|
|
@@ -276,6 +277,7 @@ if __name__ == '__main__':
|
|
|
threads.append(thread)
|
|
|
for thread in threads:
|
|
|
thread.join()
|
|
|
+
|
|
|
# 权重补充（一秒内同时请求两个服务器修改权重，可能会有一个失败）
|
|
|
print(finished_instance_id_list)
|
|
|
set_weight_for_more(slb_id=slb_id_1, instance_id_list=finished_instance_id_list, weight=100)
|
