So fügen Sie einen Header-Schlüssel: Wert-Paar beim Veröffentlichen einer Nachricht mit Pika

Question

Ich schreibe einen automatisierten Test, um einen Verbraucher zu testen. Bisher musste ich beim Veröffentlichen von Nachrichten keinen Header hinzufügen, aber jetzt tue ich es. Und es scheint wie seine fehlende Dokumentation.

Das ist mein Verleger:

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) 

ich smtn wie zu tun:

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

Was ist der richtige Weg, um hinzuzufügen Header dieser Nachricht?

Answer 1

Sie pika.BasicProperties Header hinzufügen verwenden würde.

Die offizielle Dokumentation für Pika deckt dieses Szenario zwar nicht genau ab, aber die Dokumentation enthält die Spezifikationen. Ich würde dringend empfehlen, dass Sie this Seite bookmarken, wenn Sie pika weiter verwenden werden.

Answer 2

kann nicht sagen, wo ich diese bekommen, aber ich mag es:

props = pika.BasicProperties({'headers': {'key': 'value'}}) 
channel.basic_publish(exchange=self.exchange, 
          routing_key=self.routing_key, 
          body=message, properties = props)