您将使用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,我强烈建议您将此页面添加为书签。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)