pika无法创建仲裁队列
pika无法创建仲裁队列
提问于 2020-11-22 22:43:19
我用RabbitMQ设置了amazonMQ，并尝试使用Pika连接和发布消息：
credentials = pika.PlainCredentials(MQUSER, MQPW)
amqs_str='amqps://'+MQUSER+':'+MQPW + '@'+MQURL+':'+str(MQPORT)+'/%2F'
parameters= pika.URLParameters(amqs_str)
connection = pika.BlockingConnection(parameters)
channel= connection.channel()
channel.queue_declare(queue=MQ_QUEUE_NAME,durable=True)这是可行的，但是创建的队列是经典的，而且我知道quorum在多节点rabbitmq服务器中要好得多。我在pika文档https://pika.readthedocs.io/en/0.10.0/modules/channel.html中搜索，但找不到设置仲裁类型队列的任何设置。有人能给点建议吗？
回答 1
Stack Overflow用户
回答已采纳
发布于 2021-01-13 17:35:37
我只是尝试了一下-通过在调用queue_declare时传递队列类型quorum来工作。
最小的工作示例。我使用rabbitMQ docker镜像进行了测试：docker run -d --name rabbitMQ -p 5672:5672 -p 8080:15672 rabbitmq:3-management
import pika
con = pika.BlockingConnection(pika.ConnectionParameters("localhost"))
channel = con.channel()
channel.queue_declare(queue="test",durable=True,arguments={"x-queue-type": "quorum"})页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/64955484
复制相关文章
相似问题
腾讯云开发者
