1. 制造300个并发请求模拟qps=300的压测环境
import threadpool
import requests
import time
def main(temp_params):
response = requests.post('http://127.0.0.1:8099/search/', json=temp_params)
# print(str(response.json()))
if __name__ == "__main__":
pool = threadpool.ThreadPool(300)
params_list = [params1, params2, params300] # make some request params
t0 = time.time()
tasks = threadpool.makeRequests(main, params_list)
[pool.putRequest(task) for task in tasks]
pool.wait()
t1 = time.time()
print(t1-t0)
暑期编程PK赛
得CSDN机械键盘等精美礼品!


