update

locust_test/es_locust_answer.py

@@ -397,7 +397,7 @@ query_Str_list = list(query_list.keys())
 import random
 
 print(random.choice(query_Str_list))
-
+from locust.exception import RescheduleTask
 
 class QuickstartUser(HttpUser):
     @task
@@ -462,6 +462,8 @@ class QuickstartUser(HttpUser):
         }
         response = self.client.post('/gm-dbmw-answer-read/_search', json=data,verify=False,
                                     auth=tuple(auth.split(':', 1)),timeout=1)
+        if response.status_code != 200:
+            raise RescheduleTask()
         # response = requests.post('http://172.16.52.25/gm-dbmw-service-read/_search', json=query, verify=False,auth=("elastic","elastic:gengmei!@#"))
 
         # print(response.text)