update

locust_test/es_locust_answer.py

@@ -457,13 +457,13 @@ class QuickstartUser(FastHttpUser):
                                "highlight_query": {"bool": {"must": {"terms": {"keynote_sentence": [query]}}}}}},
                 "fragment_size": 10000, "pre_tags": ["<ems>"], "post_tags": ["</ems>"]},
                 "_source": {"include": ["id", "question_id", "keynote_sentence", "highlight"]}}
-        heasers = {
-            "Content-Type": "application/x-www-form-urlencoded"
-        }
-        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()
+        # heasers = {
+        #     "Content-Type": "application/x-www-form-urlencoded"
+        # }
+        with self.client.post('/gm-dbmw-answer-read/_search', json=data,verify=False,
+                                    auth=tuple(auth.split(':', 1)),timeout=1) as response:
+            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)