如何解决如何异步映射/过滤异步可迭代对象?
一个最近公布的PEP草案(PEP 525),其支持定为Python 3.6,建议允许异步发电机与你想出了相同的语法。
同时,如果您不想处理异步迭代器样板,还可以使用CryingCyclops在其注释中asyncio_extras
提到的库。
从文档:
@async_generator
async def mygenerator(websites):
for website in websites:
page = await http_fetch(website)
await yield_async(page)
async def fetch_pages():
websites = ('http://foo.bar', 'http://example.org')
async for sanitized_page in mygenerator(websites):
print(sanitized_page)
还有一个支持构造的async_generator库yield
from
。
解决方法
假设我有一个异步可迭代对象,可以使用来传递它async
for
,然后又如何将其映射并过滤到新的异步迭代器上?以下代码是对我如何使用同步可迭代方法执行相同操作的适应,因此不起作用,因为syield
内部不允许这样做async
def
。
async def mapfilter(aiterable,p,func):
async for payload in aiterable:
if p(payload):
# This part isn't allowed,but hopefully it should be clear
# what I'm trying to accomplish.
yield func(payload)
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。