我想在启动服务器时添加一个长时间运行的作业,请参阅下面的我当前的实现。
async def start_job():
await long_job()
async def long_job():
await task()
await asyncio.sleep(settings.SLEEP)
app = Starlette(
debug=settings.DEBUG, on_startup=[start_job]
)
它目前正在工作,但我不确定它是否是正确/正确的方法,有什么建议吗?