Как добавить ключ заголовка: пара значений при публикации сообщения с помощью pika

Question

Я пишу автоматизированный тест для тестирования потребителя. До сих пор мне не нужно было включать заголовок при публикации сообщений, но теперь я делаю. И кажется, что в ней отсутствует документация.

Это мой издатель:

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"})

Как правильно добавить заголовки к этому сообщению?

Answer 1

Вы бы использовали 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.

Answer 2

Не могу сказать, где я могу получить это, но я делаю это так:

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

Answer 3

Официальный документ был упомянут следующим образом:

hdrs = {u'': u' ',
    u'': u'',
    u'': u''}
properties = pika.BasicProperties(app_id='example-publisher',
    content_type='application/json',  
    headers=hdrs)