我正在编写一个自动化测试来测试消费者。到目前为止,我在发布消息时不需要包含标头,但现在我需要了。而且似乎缺乏文档。
这是我的出版商:
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"})
向该邮件添加标头的正确方法是什么?
你会使用鼠兔.基本属性添加标题。
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 的官方文档确实没有完全涵盖这种情况,但文档确实列出了规范。我强烈建议您添加书签this页面,如果您要继续使用鼠兔。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)