update workers

longvideo_restart.py

@@ -31,7 +31,7 @@ def server_restart(slb_client, instance_id, image_name):
         time.sleep(30)
         logging.info(f"health check finished.")
         # 5. 挂流量
-        add_weight_list = [(10, 30), (20, 20), (40, 10), (60, 10), (80, 10), (100, 10)]
+        add_weight_list = [(10, 10), (20, 10), (40, 10), (60, 10), (80, 10), (100, 10)]
         utils.set_instance_weight_process(client=slb_client,
                                           slb_id=rov_server_config.slb_id,
                                           instance_id_list=[instance_id],
@@ -50,6 +50,9 @@ def main():
 
         # 1. 获取slb下所有机器
         online_instance_ids = utils.get_instance_ids(client=slb_client, slb_id=longvideo_config.slb_id_list[0])
+
+        online_instance_ids = online_instance_ids[:1]
+
         online_instance_count = len(online_instance_ids)
         logging.info(f"online instance count: {online_instance_count}.")
         logging.info(f"online instance ids: {online_instance_ids}")

longvideo_update.py

@@ -309,7 +309,7 @@ def main():
         # 3. 原有机器进行更新
         logging.info(f"update online instances start ...")
         asyncio.run(update_instance(create_client=create_client, slb_client=slb_client,
-                                    instance_ids=online_instance_ids, max_workers=2, version=version))
+                                    instance_ids=online_instance_ids, max_workers=8, version=version))
         logging.info(f"update online instances end!")
 
         # 4. 停止并释放扩容机器