使用 celery +rabbirmq 发送异步任务 每个任务有独立队列
如何统计每分钟任务发送量和最大峰值极限发送量各是多少?
如果队列突然进入大批量任务,如何能快速处理大批量任务?
任务执行不成功如何以可控时间间隔来重复执行失败任务?
等大佬赐教!!
1
yuoboo OP 等大佬上线
|
2
di94sh 2019-03-27 04:49:19 +08:00 via Android
1.直接监控 rabbitmq
2.celery 是分布式任务队列,那么加机器。机器不够就通过监控 rabbit mq 弹性扩容。 3.执行异步任务时都把入参,任务的 key,任务执行状态写到数据库。任务完成后更改数据库里状态。再搞一个定时任务,去数据库把失败的任务放到队列。 |