后方
介绍
Rearq是一个分布式的任务队列从ASYNCIO和Redis的,它重写和作出改善。
安装
只需从pypi安装:
> pip install rearq
快速开始
任务定义
# main.py
rearq = ReArq ()
rearq . on_shutdown
async def on_shutdown ():
# you can do some clean work here like close db and so on...
print ( "sh
需求:功能 A 需要调用第三方 API 获取数据,而第三方 API 自身是异步处理方式,在调用后会返回数据与状态 { data: “查询结果”, “status”: “正在异步处理中” } ,这样就需要间隔一段时间后再去调用第三方 API 获取数据。为了用户在使用功能 A 时不会因为第三方 API 正在异步处理中而必须等待,将用户请求加入任务队列中,返回部分数据并关闭请求。然后定时从任务队列里中取出任务调用第三方 API,若返回状态为”异步处理中“,将该任务再次加入任务队列,若返回状态为”已处理