我正在写一个自动化测试来测试一个消费者。到目前为止,我不需要在发布消息时包含一个头,但现在我需要了。而且看起来它缺少文档。
这是我的出版商:
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"})
在此邮件中添加标题的正确方法是什么?
3条答案
按热度按时间kyks70gy1#
您可以使用pika.BasicProperties来添加标头。
pika的官方文档确实没有完全涵盖这种情况,但文档中确实列出了规范。如果您打算继续使用pika,我强烈建议您将this页面加入书签。
kyks70gy2#
不能说我从哪里得到这个,但我这样做:
q1qsirdb3#
正式文件中提到: