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

问题描述

我正在编写一个自动化测试来测试消费者.到目前为止，我不需要在发布消息时包含标题，但现在我需要.而且似乎缺少文档.

I am writing an automated test to test a consumer. So far I did not need to include a header when publishing messages but now I do. And it seems like its lacking documentation.

这是我的发布商:

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)

我想做 smtn:

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

向此消息添加标题的正确方法是什么?

Whats the correct way to add headers to this message?

推荐答案

您可以使用 pika.BasicProperties 添加标题.

You would use pika.BasicProperties to add headers.

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 的官方文档确实没有完全涵盖这种情况，但文档确实列出了规范.如果您打算继续使用，我强烈建议您将此页面加入书签鼠兔.

The official documentation for pika does indeed not cover this scenario exactly, but the documentation does have the specifications listed. I would would strongly recommend that you bookmark this page, if you are going to continue using pika.

这篇关于使用 pika 发布消息时如何添加标题键:值对的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持！