有两件事需要做:托管网站和发送notification.So我使用以下方法来解决这个问题:
from aiohttp import web
import asyncio
async def _send_proactive_message():
...
async def pre_init():
await asyncio.sleep(20)
await _send_proactive_message()
APP = web.Application()
APP.router.add_post("/api/messages", messages)
APP.router.add_get("/api/notify", notify)
if __name__ == '__main__':
event_loop = asyncio.get_event_loop()
try:
event_loop.create_task(pre_init())
web.run_app(APP, host="localhost", port=CONFIG.PORT)
finally:
event_loop.close()因为web.run_app中只有一个event_loop,所以我不知道哪个先运行,以及如何控制每个event_loop。
发布于 2020-03-04 15:21:39
在启动事件循环之前创建任务的方法是可行的,但前提是run_app不会设置和使用另一个事件循环。
更好的方法是在事件循环启动后创建任务或其他异步对象。这样,您将确保创建的对象附加到活动的正在运行的事件循环。
在您的情况下,最好的方法是使用on_startup钩子:
async def pre_init(app):
await _send_proactive_message()
async def make_app():
app = web.Application()
app.router.add_post("/api/messages", messages)
app.router.add_get("/api/notify", notify)
app.on_startup.append(pre_init)
return app
web.run_app(make_app())https://stackoverflow.com/questions/60520695
复制相似问题