关于 grequests

众所周知，requests 出于 K神 之手，但它是串行的，在并发场景下效率会受到阻塞的影响而变得低下。他一度认为程序是为人设计的，这不，当人们需要异步发送请求，提高请求效率的时候，他又推出了全新的 grequests 库（仅 100 多行代码）。

grequests 是基于 gevent 和 requests 开发的，效果和你单独使用 gevent 去发送 requests 请求基本一致，但是用 grequests 会简单上不少，何乐而不为呢？该说不说，K神 牛掰！

走进 grequests

用过 requests 的兄弟对 grequests 不会陌生，因为你会发现用法极其相似。

安装

pip install grequests

例子

使用 grequests 异步请求百度

import grequests,time

url = 'https://www.baidu.com'
req_list = [
    grequests.get(url),
    grequests.get(url),
    grequests.get(url),
]

start_time=time.time()
res_list = grequests.map(req_list)
end_time=time.time()
print(res_list,end_time-start_time)

使用 requests 串行请求百度

import  requests,time

url = 'https://www.baidu.com'
start_time=time.time()
res1 = requests.get(url)
res2 = requests.get(url)
res3 = requests.get(url)
end_time=time.time()

print([res1,res2,res3],end_time-start_time)

对比分析

根据结果，你会发现，grequests 和 requests 的功能完全一致，但是粗略估计 grequests 比 requests 的性能提升 186% 不止。并发量越大，提升越大。

关于 grequests.map()

grequests.map()接收一个 AsyncRequest 列表对象，map 方法中会将这个列表转化为任务队列，然后交给 gevent 去异步执行。任务全部结束后返回一个 response 列表。

高级用法

自定义异常处理

import grequests,time

# 自定义错误处理程序，接收两个参数分别为request和exception
def err_handler(request,exception):
    print('发生异常，具体信息为：',exception)

url = 'https://www.not-ok.com'
req_list = [
    grequests.get(url),
    grequests.get(url),
    grequests.get(url),
]

start_time=time.time()

# 注意，err_handler在这里
res_list = grequests.map(req_list,exception_handler=err_handler)
end_time=time.time()
print(res_list,end_time-start_time)

其他用法

通过源码我们了解到：

参数	解释
stream	为 True 时，可以处理流文件（不会立即下载）。
size	流控参数，（指定并发量），如果不指定则不做限制。
exception_handler	自定义异常处理方法。
gtimeout	gevent 的任务超时时间（所有任务）。

以上就是今天的全部内容了，感谢您的阅读，我们下节再会。