您将使用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,我强烈建议您将此页面添加为书签。



