我在aiohttp应用程序中有控制器操作。
async def handler_message(request):
try:
content = await request.json()
perform_message(x,y,z)
except (RuntimeError):
print("error in perform fb message")
finally:
return web.Response(text="Done")
perform_message
是异步功能。现在,当我调用动作时,我希望动作尽快返回并perform_message
置于事件循环中。
这样,perform_message
不执行
一种方法是使用create_task
功能:
import asyncio
async def handler_message(request):
...
loop = asyncio.get_event_loop()
loop.create_task(perform_message(x,y,z))
...
本文收集自互联网,转载请注明来源。
如有侵权,请联系 [email protected] 删除。
我来说两句