如何使用python在rabbitmq中的标头挖掘方法中传递标头

Question

#!/usr/bin/env python import pika，sys，os def main(): connection = pika。BlockingConnection(pika。connection parameters(host = ' localhost '))channel = connection . channel()

channel.exchange_declare(exchange='headers_logs', exchange_type='headers')

channel.queue_declare(queue='', exclusive=True)
queue_name = "HeadersQueue1"

channel.queue_bind(exchange='headers_logs', queue=queue_name)

def callback(ch, method, properties, body):
    print(" [x] %r" % body.decode())

print(' [*] Waiting for logs. To exit press CTRL+C')
channel.basic_consume(
    queue=queue_name, on_message_callback=callback, auto_ack=True)

channel.start_consuming()

if name=='main'：try:main（）除了键盘中断：打印（'中断'）try:sys。退出（0），SystemExit:os._exit（0）除外

#！/usr/bin/env python import pika import sys connection = pika.阻塞连接（pika.ConnectionParameters（host='localhost'）） channel = connection.channel（）

channel . exchange _ declare(exchange = ' headers _ logs '，exchange_type='headers ')

消息=“”。加入（sys.argv[1:]）或“你好！”

频道basic_publish（exchange='headers_logs'，headers={“name”：“ram”}，body=message）print（“[x]发送%r”%message”）connection.close（）

在这里我写了像上面这样的消费者和发布程序。有人能指导一下如何使用python在RabbitMq中编写简单的头交换程序吗

Answer 1

要使用标头交换，您需要将交换类型声明为标头，而不是问题文本中的扇出。

exchangeName = 'headers_logs'
channel.exchange_declare(exchangeName, exchange_type='headers', durable=True)

然后创建队列并使用标头将其绑定到交换。请注意，这里的“x-匹配”可以设置为匹配任何或所有标头。路由键设置为空字符串，因为它不会用于路由消息。

qName = 'queue_logs'
channel.queue_declare(queue=qNameI, durable=True)
channel.queue_bind(qName, exchangeName, routing_key='',  arguments={'x-match': 'any', 'key1': 'one', 'key2': 'two'})

现在我们可以使用一组标头向交易所发布消息：

channel.basic_publish(
    exchange=exchangeName, 
    routing_key='', 
    body='test message body',
    properties=pika.BasicProperties(
        delivery_mode = 2, # make message persistent
        headers = {'key1':'one', 'key2': 'three'}
    )
)

我只匹配了此消息中的“key1”，以证明“x-match”已设置为“任何”。