rabbitmq 如何在使用pika发布消息时添加标头键:值对

0mkxixxg  于 2022-11-08  发布在  RabbitMQ
关注(0)|答案(3)|浏览(206)

我正在写一个自动化测试来测试一个消费者。到目前为止,我不需要在发布消息时包含一个头,但现在我需要了。而且看起来它缺少文档。
这是我的出版商:

class RMQProducer(object):

    def __init__(self, host, exchange, routing_key):
        self.host = host
        self.exchange = exchange
        self.routing_key = routing_key

    def publish_message(self, message):
        connection = pika.BlockingConnection(pika.ConnectionParameters(self.host))
        channel = connection.channel()
        message = json.dumps(message)
        channel.basic_publish(exchange=self.exchange,
                              routing_key=self.routing_key,
                              body=message)

我想做的事情是:

channel.basic_publish(exchange=self.exchange,
                      routing_key=self.routing_key,
                      body=message,
                      headers={"key": "value"})

在此邮件中添加标题的正确方法是什么?

kyks70gy

kyks70gy1#

您可以使用pika.BasicProperties来添加标头。

channel.basic_publish(exchange=self.exchange,
                      routing_key=self.routing_key,
                      properties=pika.BasicProperties(
                          headers={'key': 'value'} # Add a key/value header
                      ),
                      body=message)

pika的官方文档确实没有完全涵盖这种情况,但文档中确实列出了规范。如果您打算继续使用pika,我强烈建议您将this页面加入书签。

kyks70gy

kyks70gy2#

不能说我从哪里得到这个,但我这样做:

props = pika.BasicProperties({'headers': {'key': 'value'}})
channel.basic_publish(exchange=self.exchange,
                          routing_key=self.routing_key,
                          body=message, properties = props)
q1qsirdb

q1qsirdb3#

正式文件中提到:

hdrs = {u'': u' ',
    u'': u'',
    u'': u''}
properties = pika.BasicProperties(app_id='example-publisher',
    content_type='application/json',  
    headers=hdrs)

相关问题