我们的想法是收集一百万个查询的响应并将它们存储在一个字典中。我希望它是异步的,因为requests.post对每个查询需要1秒,我希望在等待响应的过程中保持循环。经过一些研究,我得到了这样的结果。
async def get_response(id):
query_json = id2json_dict[id]
response = requests.post('some_url', json = query_json, verify=false)
return eval(response.text)
async def main(id_list):
for unique_id in id_list:
id2response_dict[unique_id] = get_response(unique_id)
我知道这不是异步的,我如何在其中使用“await”使它真正异步?
1条答案
按热度按时间dzjeubhm1#
requests-async
包为requests
... https://github.com/encode/requests-async提供异步支持或者使用
aiohttp
。