Требуется qpid-proton publish / subscribe образец программы amqp для python для доступа к теме Azure

Я использую шину облачной службы Azure для отправки и получения сообщений по протоколу AMQP. Я установил библиотеки proton-c в свой debian-linux. Я попробовал следующую программу для отправки и получения сообщения из очереди. Мое требование - вместо очереди использовать темы. Пожалуйста, дайте мне образец программы для использования тем в облаке Azure.

import sys, optparse
from proton import *

messenger = Messenger()
message = Message()
message.address = "amqps://owner:<<key>>@namespace.servicebus.windows.net/queuename"
message.body = "sending message to the queue"
messenger.put(message)
messenger.send()

Вместо queuename в приведенном выше URL-адресе, если я укажу имя темы, программа будет работать вечно. Пожалуйста, помогите мне. Я новичок в программировании на Python.


azure python-2.7 azureservicebus amqp qpid
person Raj    schedule 13.10.2014    source источник
comment
Может ли кто-нибудь быстро сказать, я могу использовать протокол AMQP для отправки сообщений в темы в Azure с помощью python? Нет доступных образцов. Я искал в Интернете последнюю неделю, но не смог найти образцы.   -  person Raj    schedule 14.10.2014

Ответы (1)


arrow_upward
2
arrow_downward

Я нашел себе решение этой проблемы. Думаю, в Azure Cloud работает очень мало людей, поэтому я не получил никаких ответов.

Вот решение:

Если мы создаем темы в служебной шине Azure, она всегда ставит флажок «Включить разбиение на разделы». Протокол AMQP не поддерживает разделение тем / очередей, поэтому я столкнулся с указанной выше проблемой. Как только я удалил тему и воссоздаю ту же тему, не установив флажок «Разрешить разбиение». Его работа нормально. :)

person Raj    schedule 20.10.2014