如何解决如何使用aiomultiprocess?
我发现这个软件包aiomultiprocess
似乎可以同时进行多处理和异步处理。
from aiohttp import request
from aiomultiprocess import Pool
async def get(url):
async with request("GET",url) as response:
return await response.text("utf-8")
async def main():
urls = ["https://jreese.sh","https://www.google.com",]
async with Pool() as pool:
async for result in pool.map(get,urls):
print(result)
但是,尝试运行示例代码绝对没有任何作用。
尝试致电main()
给我一个错误RuntimeWarning: coroutine 'main' was never awaited
。我找不到如何触发代码的实际示例。
关于此的唯一其他question未得到回答。
解决方法
<Button @attributes="@Attributes" Color="Colors.Primary">
文档示例未涵盖如何调用循环。该功能需要通过asyncio调用。
aiomultiprocess
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。