add gateway_restart

gateway/gateway_restart.py

@@ -1,24 +1,51 @@
 import logging
+import sys
 import time
 import docker
-import longvideoapi_config
-import utils
-from longvideoapi_update_k import server_health_check
+import gateway_config
+import alb_utils
+import requests
 
 logging.basicConfig(level=logging.INFO,
                     format='%(asctime)s %(filename)s[line:%(lineno)d] %(levelname)s %(message)s',
                     datefmt='%a, %d %b %Y %H:%M:%S')
 
+health_instances = []
+
+def server_health_check(ecs_client, instance_id):
+    """
+    服务健康检查
+    :param ecs_client: 客户端连接
+    :param instance_id: instanceId
+    :return:
+    """
+    global health_instances
+    ip_address = alb_utils.get_ip_address(ecs_client=ecs_client, instance_id=instance_id)
+    while True:
+        health_check_url = f"http://{ip_address}:9000/healthcheck"
+        try:
+            http_code = requests.get(health_check_url).status_code
+        except:
+            logging.info(f"images is downloading ip：{ip_address}")
+            http_code = 0
+
+        if http_code == 200:
+            health_instances.append((instance_id, ip_address))
+            logging.info(f"health check success, instance: {instance_id}/{ip_address}")
+            break
+        else:
+            time.sleep(10)
+
 def server_restart(alb_client, ecs_client, instance_id, image_name, port):
     try:
         logging.info(f"Restarting instance: {instance_id}")
         # 获取ip
-        ip_address = utils.get_ip_address(ecs_client=ecs_client, instance_id=instance_id)
+        ip_address = alb_utils.get_ip_address(ecs_client=ecs_client, instance_id=instance_id)
         logging.info(f"IP address: {instance_id}/{ip_address}")
 
         # 摘流量
-        utils.update_server_group_servers_attribute(alb_client=alb_client,
-                                                    server_group_id_list=longvideoapi_config.server_group_id_list,
+        alb_utils.update_server_group_servers_attribute(alb_client=alb_client,
+                                                    server_group_id_list=gateway_config.server_group_id_list,
                                                     instance_id_list=[instance_id],
                                                     weight_list=[(0, 20)],
                                                     port=port)
@@ -37,9 +64,8 @@ def server_restart(alb_client, ecs_client, instance_id, image_name, port):
 
         # 设置权重
         add_weight_list = [(10, 5), (20, 5), (40, 5), (60, 5), (80, 5), (100, 5)]
-        # add_weight_list = [(10, 10), (20, 10), (40, 10), (60, 10), (80, 10), (100, 10)]
-        utils.update_server_group_servers_attribute(alb_client=alb_client,
-                                                    server_group_id_list=longvideoapi_config.server_group_id_list,
+        alb_utils.update_server_group_servers_attribute(alb_client=alb_client,
+                                                    server_group_id_list=gateway_config.server_group_id_list,
                                                     instance_id_list=[instance_id],
                                                     weight_list=add_weight_list,
                                                     port=port)
@@ -51,27 +77,27 @@ def server_restart(alb_client, ecs_client, instance_id, image_name, port):
 
 def main():
     try:
-        ecs_client = utils.connect_client(access_key_id=longvideoapi_config.ecs_client_params['access_key_id'],
-                                          access_key_secret=longvideoapi_config.ecs_client_params['access_key_secret'],
-                                          region_id=longvideoapi_config.ecs_client_params['region_id'])
-
-        alb_client = utils.connect_alb_client(
-            access_key_id=longvideoapi_config.alb_client_params['access_key_id'],
-            access_key_secret=longvideoapi_config.alb_client_params['access_key_secret'],
-            endpoint=longvideoapi_config.alb_client_params['endpoint']
+        ecs_client = alb_utils.connect_client(access_key_id=gateway_config.ecs_client_params['access_key_id'],
+                                          access_key_secret=gateway_config.ecs_client_params['access_key_secret'],
+                                          region_id=gateway_config.ecs_client_params['region_id'])
+
+        alb_client = alb_utils.connect_alb_client(
+            access_key_id=gateway_config.alb_client_params['access_key_id'],
+            access_key_secret=gateway_config.alb_client_params['access_key_secret'],
+            endpoint=gateway_config.alb_client_params['endpoint']
         )
 
         # 获取 ALB 下所有机器
-        online_instance_ids = utils.list_server_group_servers(alb_client=alb_client,
-                                                              server_group_id=longvideoapi_config.server_group_id_list[0])
+        online_instance_ids = alb_utils.list_server_group_servers(alb_client=alb_client,
+                                                              server_group_id=gateway_config.server_group_id_list[0])
         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}")
 
         # 逐台重启
-        image_name = 'longvideoapi'
+        image_name = 'piaoquan-gateway'
         for i, instance_id in enumerate(online_instance_ids):
-            server_restart(alb_client=alb_client, ecs_client=ecs_client, instance_id=instance_id, image_name=image_name, port=longvideoapi_config.port)
+            server_restart(alb_client=alb_client, ecs_client=ecs_client, instance_id=instance_id, image_name=image_name, port=gateway_config.port)
             logging.info(f"Restart progress: {i + 1}/{online_instance_count}")
         logging.info("All servers restarted successfully!")
     except Exception as e: