如何设置连接友好名称 RabbitMQ --Python

Question

您好，我正在玩 RabbitMq，我有一个问题。我有许多并行节点正在运行并连接在 rabbitmq-server 上。问题是，在 conncetions 中声明为 ip:port 在 ip:port 下还有一个 ?。有没有办法为 python 3.6 设置一个友好的名称？

P.S 我试过这样的事情没有成功

                    parameters = pika.ConnectionParameters(
                        host='localhost',
                        virtual_host='/',
                        client_properties={
                            'connection_name': 'random name',
                        },
                    )
                    connection = pika.BlockingConnection(parameters)

P.S 我还发现了一个关于 golang tho 的相关问题。这里How to set connection friendly name

版本

pika = '1.1.0'
RabbitMq = '3.8.0'
Erlang = '22.1.1'
Python = ' 3.6.8'

有什么想法吗？ :)

Answer 1

This code 设置连接名称，如下所示：

import functools
import logging
import pika

LOG_FORMAT = ('%(levelname) -10s %(asctime)s %(name) -30s %(funcName) '
              '-35s %(lineno) -5d: %(message)s')
LOGGER = logging.getLogger(__name__)

logging.basicConfig(level=logging.DEBUG, format=LOG_FORMAT)


def on_message(chan, method_frame, _header_frame, body, userdata=None):
    """Called when a message is received. Log message and ack it."""
    LOGGER.info('Userdata: %s Message body: %s', userdata, body)
    chan.basic_ack(delivery_tag=method_frame.delivery_tag)


def main():
    """Main method."""
    credentials = pika.PlainCredentials('guest', 'guest')
    props = { 'connection_name' : 'https://stackoverflow.com/q/58275505/1466825' }
    parameters = pika.ConnectionParameters('localhost', credentials=credentials, client_properties=props)
    connection = pika.BlockingConnection(parameters)

    channel = connection.channel()
    channel.exchange_declare(
        exchange='test_exchange',
        exchange_type='direct',
        passive=False,
        durable=True,
        auto_delete=False)
    channel.queue_declare(queue='standard', auto_delete=True)
    channel.queue_bind(
        queue='standard', exchange='test_exchange', routing_key='standard_key')
    channel.basic_qos(prefetch_count=1)

    on_message_callback = functools.partial(
        on_message, userdata='on_message_userdata')
    channel.basic_consume('standard', on_message_callback)

    try:
        channel.start_consuming()
    except KeyboardInterrupt:
        channel.stop_consuming()

    connection.close()


if __name__ == '__main__':
    main()

---

_{注意：RabbitMQ 团队会监控 rabbitmq-users mailing list，并且有时只回答 StackOverflow 上的问题。}