как вы пишете в очереди и ожидаете вашего ответа на другой с помощью служебной шины Azure

Question

Я использую sdk служебной шины для отправки в очередь и прислушиваюсь к ответу в другой, но я не могу найти действительные примеры того, как создать этот поток. Моя самая большая трудность - это возможность установить reply_to и reply_to_group_id, как я делал это в старых версиях непосредственно в MessageProperties, теперь в классе Message я сомневаюсь, что сообщить в индексе «message» для достижения этой цели

Answer 1

Класс Message имеет свойство с именем properties, которое является экземпляром uamqp.message.MessageProperties, которое имеет свойство reply_to (и reply_to_group_id), которое вы ищем.

from azure.servicebus import Message

message = Message(
    body="Hello World!"
)
message.properties.reply_to="replyTo"
message.properties.reply_to_group_id="replyGroupId"

Подробнее о Операциях запроса-ответа AMQP с служебной шиной можно прочитать в документации.