मैं RabbitMQ के साथ amazonMQ सेटअप करता हूं और संदेश को जोड़ने और प्रकाशित करने के लिए पिका का उपयोग करने का प्रयास करता हूं:

        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)

यह काम करेगा, लेकिन बनाई गई कतार क्लासिक है, और मैं समझता हूं कि बहु-नोड खरगोश सर्वर में कोरम बहुत बेहतर है। मैं पिका प्रलेखन के माध्यम से खोजता हूं https://pika.readthedocs.io/en /0.10.0/modules/channel.html लेकिन कोरम प्रकार की कतार सेट करने के लिए कोई सेटिंग नहीं मिली। क्या कोई सलाह दे सकता है?

1
desmond 22 नवम्बर 2020, 17:43

1 उत्तर

सबसे बढ़िया उत्तर

बस इसे आजमाया - कतार प्रकार कोरम पास करके काम करता है जब कॉल queue_declare.

न्यूनतम कामकाजी उदाहरण। मैंने खरगोश एमक्यू डॉकर छवि के साथ परीक्षण किया: 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"})
1
Bierbarbar 13 जिंदा 2021, 09:35