关于RabbitMQ的芹菜任务优先级的解决方法?

Dav*_*eat 9 rabbitmq celery

我在RabbitMQ上运行带有Celery的Django作为处理一些数据处理任务的队列.当用户第一次注册时,我正在开始芹菜任务,并定期更新他们的数据.但是,我当然要优先考虑运行当前在线用户的任务.我注意到芹菜中的任务有一个优先级设置,但似乎rabbitmq不支持这个.这个帖子http://groups.google.com/group/celery-users/browse_thread/thread/ac3b6123d63421e5/b7740def1389e87e?lnk=gst&q=priority#b7740def1389e87e建议使用两个不同的队列,一个是高优先级队列,另一个是低优先级队列,或者设置一个优先级较低的任务的速率限制.

有没有人有一个很好的解决方法来实现优先级?提前致谢!