我有以下为我生成数据的方法：
async def generate_url(self, video_id):
data = await self.s3.generate_presigned_url(...video_id...)
return data
def convert_to_json(self, urls):
ids = [self.generate_url(url) for url in urls]
...
如何正确地等待generate_url中convert_to_json？
您可以wait在任务列表周围使用包装器：
async def convert_to_json(self, urls):
tasks = [self.generate_url(url) for url in urls]
await asyncio.wait(tasks)
或者，如果您不能将convert_to_jsonmethod标记为async，请同步等待它：
import asyncio
def convert_to_json(self, urls):
loop = asyncio.get_event_loop()
tasks = [self.generate_url(url) for url in urls]
loop.run_until_complete(asyncio.wait(tasks))
你也可以尝试实现一个async迭代器，并使用它async for的语法，是这样的：
class Loader:
def __init__(self, urls):
self._urls = iter(urls)
async def generate_url(self, video_id):
data = await self.s3.generate_presigned_url(...video_id...)
return data
def __aiter__(self):
return self
async def __anext__(self):
try:
url = next(self._urls)
except StopIteration:
raise StopAsyncIteration
data = await self.generate_url(url)
return data
async for id in Loader(urls):
print(id)
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句