Python异步请求

问题描述

所以我有一个图像url列表，我希望使用请求库迭代该列表，并将所有图像下载到一个目录中。

def get_image(url, image_name):
    path = pathlib.Path('/path/to/some/directory')
    response = requests.get(url, stream=True)
    with open('{}/{}.png'.format(path, image_name), 'wb') as file:
        for block in response.iter_content(1024):
            file.write(block)

for url in urls:
    get_image(url, image_name)

现在，我有没有办法创建一个修饰符，使函数成为一个回调函数，以便在为特定的异步请求返回响应后运行？

---

解决方案

如果您想要多个并发的requests+回调，可以使用类似grequests的模块。它与asyncio无关。

asyncio-将避免使用回调(以避免callback hell)，并使异步代码的编写与同步代码的编写一样简单。

如果您决定尝试asyncio，您应该使用aiohttpclient而不是requests(这是首选方式)，或者在由asyncio管理的线程池中运行requests。这两种方法的示例都可以找到here。