python - 如何在 RabbitMQ/pika 中实现优先级队列

Question

我想用 RabbitMQ 实现一个优先级队列。邮件列表recommends使用多个队列，每个队列代表不同的优先级。

我的问题是，如何使用 pika(或可能是其他 python 库)以某种优先顺序轮询多个队列？

Answer 1

接受的答案已过时。从 rabbitmq 3.5.0 有 native support对于优先队列:

RabbitMQ has priority queue implementation in the core as of version 3.5.0. Any queue can be turned into a priority one using client-provided optional arguments

也是available从 pika 1.1.0

开始

class pika.spec.BasicProperties(content_type=None, content_encoding=None, headers=None, delivery_mode=None, priority=None, correlation_id=None, reply_to=None, expiration=None, message_id=None, timestamp=None, type=None, user_id=None, app_id=None, cluster_id=None)

使用此功能的代码可能如下所示:

channel.basic_publish(properties=pika.BasicProperties(priority=your_priority),
                      exchange=...,
                      routing_key=...,
                      body=...)