liqian 2 vuotta sitten
vanhempi
commit
6b7992462a
2 muutettua tiedostoa jossa 3 lisäystä ja 1 poistoa
  1. 2 1
      ess_instance_rov_server.py
  2. 1 0
      utils.py

+ 2 - 1
ess_instance_rov_server.py

@@ -91,9 +91,10 @@ async def ess_instance(create_client, slb_client, ess_count, max_workers):
         # 所有机器探活成功
         time.sleep(60)
         add_weight_list = [(10, 30), (20, 20), (40, 10), (60, 10), (80, 10), (100, 10)]
+        health_instance_ids = [instance_id for instance_id, _ in health_instances]
         utils.set_instance_weight_process(client=slb_client,
                                           slb_id=rov_server_config.slb_id,
-                                          instance_id_list=ess_instance_ids,
+                                          instance_id_list=health_instance_ids,
                                           weight_list=add_weight_list)
         global ess_instances
         ess_instances.extend(ess_instance_ids)

+ 1 - 0
utils.py

@@ -328,6 +328,7 @@ def set_instance_weight_process(client, slb_id, instance_id_list, weight_list):
         while flag:
             try:
                 set_weight_for_instances(client=client, slb_id=slb_id, instance_id_list=instance_id_list, weight=weight)
+                logging.info(f"weight = {weight}")
                 time.sleep(sleep_time)
                 flag = False
             except Exception as e: