我正在尝试同时向服务器发送请求,然后使用以下代码记录平均延迟:
import Queue
import time
import threading
import urllib2
data = "{"image_1":"abc/xyz.jpg"}"
headers = {.....}
def get_url(q, url):
num = 1
sum = 0
while num <= 200:
start = time.time()
req = urllib2.Request(url, data, headers)
response = urllib2.urlopen(req)
end = time.time()
print end - start
num = num + 1
q.put(response.read())
sum = sum + (end - start)
print sum
theurls = ["http://example.com/example"]
q = Queue.Queue()
for u in theurls:
t = threading.Thread(target = get_url, args = (q, u))
t.daemon = True
t.start()
while True:
s = q.get()
print s
这段代码工作得很好,但现在我打算每秒发送超过 1000 个请求。我遇到了这个答案,但我不确定如何grequests
用于我的案例。一些见解将非常有帮助。
谢谢