liqian 2 vuotta sitten
vanhempi
commit
07fe0e909a
3 muutettua tiedostoa jossa 7 lisäystä ja 6 poistoa
  1. 3 2
      longvideo_quick_restart_with_ess.py
  2. 2 2
      rov_server_quick_restart_with_ess.py
  3. 2 2
      utils.py

+ 3 - 2
longvideo_quick_restart_with_ess.py

@@ -4,6 +4,7 @@ import time
 import docker
 import asyncio
 import sys
+import os
 
 import longvideo_config
 import utils
@@ -232,8 +233,8 @@ def main():
 
         # 3. 重启线上原有服务器
         image_name = 'longvideoapi'
-        asyncio.run(server_restart_all(slb_client=slb_client, instance_id_list=online_instance_ids,
-                                       image_name=image_name, max_workers=online_instance_count))
+        # asyncio.run(server_restart_all(slb_client=slb_client, instance_id_list=online_instance_ids,
+        #                                image_name=image_name, max_workers=online_instance_count))
         logging.info(f"server restart finished!")
 
         # 4. 停止并释放扩容机器

+ 2 - 2
rov_server_quick_restart_with_ess.py

@@ -229,8 +229,8 @@ def main():
 
         # 3. 重启线上原有服务器
         image_name = 'rov-server'
-        # asyncio.run(server_restart_all(slb_client=slb_client, instance_id_list=online_instance_ids,
-        #                                image_name=image_name, max_workers=online_instance_count))
+        asyncio.run(server_restart_all(slb_client=slb_client, instance_id_list=online_instance_ids,
+                                       image_name=image_name, max_workers=online_instance_count))
         logging.info(f"server restart finished!")
 
         # 4. 停止并释放扩容机器

+ 2 - 2
utils.py

@@ -330,7 +330,7 @@ def set_instance_weight_process(client, slb_id, instance_id_list, weight_list):
         flag = True
         while flag:
             try:
-                # set_weight_for_instances(client=client, slb_id=slb_id, instance_id_list=instance_id_list, weight=weight)
+                set_weight_for_instances(client=client, slb_id=slb_id, instance_id_list=instance_id_list, weight=weight)
                 time.sleep(sleep_time)
                 flag = False
             except Exception as e:
@@ -411,7 +411,7 @@ def set_instance_weight_process_with_slbs(client, slb_id_list, instance_id_list,
                         instances_list = instance_id_list[i * 40:(i + 1) * 40]
                         if len(instances_list) == 0:
                             break
-                        set_weight_for_instances(client=client, slb_id=slb_id, instance_id_list=instances_list, weight=weight)
+                        # set_weight_for_instances(client=client, slb_id=slb_id, instance_id_list=instances_list, weight=weight)
                     logging.info(f"slb: {slb_id} finished!")
                     flag = False
                 except Exception as e: