update read timeout

gateway/utils.py

@@ -370,7 +370,10 @@ def add_servers_to_server_group(alb_client, server_group_id, instance_id, weight
         server_group_id=server_group_id,
         servers=[server]
     )
-    runtime = util_models.RuntimeOptions()
+    runtime = util_models.RuntimeOptions(
+        connect_timeout=5000,
+        read_timeout=60000
+    )
     try:
         alb_client.add_servers_to_server_group_with_options(request, runtime)
         logging.info(f"Successfully added server {instance_id} to server group {server_group_id} with weight {weight}.")
@@ -397,7 +400,10 @@ def remove_servers_from_server_group(alb_client, server_group_id, instance_ids,
             server_group_id=server_group_id,
             servers=[server]
         )
-        runtime = util_models.RuntimeOptions()
+        runtime = util_models.RuntimeOptions(
+            connect_timeout=5000,
+            read_timeout=60000
+        )
         try:
             alb_client.remove_servers_from_server_group_with_options(request, runtime)
             logging.info(f"Successfully removed server {instance_id} from server group {server_group_id}.")
@@ -423,7 +429,10 @@ def list_server_group_servers(alb_client, server_group_id):
                 max_results=100,
                 next_token=next_token
             )
-            runtime = util_models.RuntimeOptions()
+            runtime = util_models.RuntimeOptions(
+                connect_timeout=5000,
+                read_timeout=60000
+            )
             response = alb_client.list_server_group_servers_with_options(list_server_group_servers_request, runtime)
             next_token = UtilClient.to_map(response.body).get('NextToken')
             sub_instance_ids = [server.server_id for server in response.body.servers]
@@ -447,7 +456,10 @@ async def list_server_group_servers_async(alb_client, server_group_id):
         server_group_id=server_group_id,
         max_results=100
     )
-    runtime = util_models.RuntimeOptions()
+    runtime = util_models.RuntimeOptions(
+        connect_timeout=5000,
+        read_timeout=60000
+    )
 
     try:
         response = await alb_client.list_server_group_servers_with_options_async(list_server_group_servers_request, runtime)
@@ -478,7 +490,10 @@ def update_server_group_server_weight(alb_client, server_group_id, instance_id,
         servers=[server],
         server_group_id=server_group_id
     )
-    runtime = util_models.RuntimeOptions()
+    runtime = util_models.RuntimeOptions(
+        connect_timeout=5000,
+        read_timeout=60000
+    )
     try:
         alb_client.update_server_group_servers_attribute_with_options(request, runtime)
         print(f"Successfully updated server {instance_id} in group {server_group_id} to weight {weight}.")
@@ -523,7 +538,10 @@ async def update_server_group_server_weight_async(alb_client, server_group_id, i
         servers=[server],
         server_group_id=server_group_id
     )
-    runtime = util_models.RuntimeOptions()
+    runtime = util_models.RuntimeOptions(
+        connect_timeout=5000,
+        read_timeout=60000
+    )
     try:
         await alb_client.update_server_group_servers_attribute_with_options_async(request, runtime)
         print(f"Successfully updated server {instance_id} in group {server_group_id} to weight {weight} asynchronously.")

longvideoapi/utils.py

@@ -415,7 +415,10 @@ def add_servers_to_server_group(alb_client, server_group_ids, instance_ids, weig
                 server_group_id=server_group_id,
                 servers=servers
             )
-            runtime = util_models.RuntimeOptions()
+            runtime = util_models.RuntimeOptions(
+                connect_timeout=5000,
+                read_timeout=60000
+            )
             try:
                 alb_client.add_servers_to_server_group_with_options(request, runtime)
                 logging.info(
@@ -448,7 +451,10 @@ def remove_servers_from_server_group(alb_client, server_group_id_list, instance_
                 server_group_id=server_group_id,
                 servers=servers
             )
-            runtime = util_models.RuntimeOptions()
+            runtime = util_models.RuntimeOptions(
+                connect_timeout=5000,
+                read_timeout=60000
+            )
             try:
                 alb_client.remove_servers_from_server_group_with_options(request, runtime)
                 logging.info(f"Successfully removed instance_ids_sub_array {instance_ids_sub_array} from server group {server_group_id}.")
@@ -474,7 +480,10 @@ def list_server_group_servers(alb_client, server_group_id):
                 max_results=50,
                 next_token=next_token
             )
-            runtime = util_models.RuntimeOptions()
+            runtime = util_models.RuntimeOptions(
+                connect_timeout=5000,
+                read_timeout=60000
+            )
             response = alb_client.list_server_group_servers_with_options(list_server_group_servers_request, runtime)
             next_token = UtilClient.to_map(response.body).get('NextToken')
             sub_instance_ids = [server.server_id for server in response.body.servers]
@@ -513,7 +522,10 @@ def update_server_group_server_weight(alb_client, server_group_id_list, instance
                 server_group_id=server_group_id
             )
             # logging.info(f"servers = {servers}")
-            runtime = util_models.RuntimeOptions()
+            runtime = util_models.RuntimeOptions(
+                connect_timeout=5000,
+                read_timeout=60000
+            )
             try:
                 # logging.info(f"instance_id_list = {instance_id_list} request = {request}")
                 alb_client.update_server_group_servers_attribute_with_options(request, runtime)
@@ -548,7 +560,10 @@ def check_server_group_status(alb_client, server_group_id_list):
         max_results=100
     )
     flag = False
-    runtime = util_models.RuntimeOptions()
+    runtime = util_models.RuntimeOptions(
+        connect_timeout=5000,
+        read_timeout=60000
+    )
     for i in range(10):
         try:
             response = alb_client.list_server_groups_with_options(list_server_groups_request, runtime)