如何使用Kombu指定AMQP correlationId？

Question

文档建议按照AMQP规范将额外的AMQP属性作为关键字参数传递给publish，但是correlationId="foo"似乎没有达到预期的效果。

Answer 1

如果您grep源，您可以看到一点kombu.common.send_reply

producer.publish(
    msg, exchange=exchange,
    retry=retry, retry_policy=retry_policy,
    **dict({'routing_key': req.properties['reply_to'],
            'correlation_id': req.properties.get('correlation_id'),
            'serializer': serializers.type_to_name[req.content_type],
            'content_encoding': req.content_encoding}, **props)
)

correlation_id是使用的kwarg的名称。