Проблема с пинтовым сервером шины Azure

Я использую шину служебной шины azure в первый раз для передачи сообщения между источником C # и клиентом python.

Я создаю объект ServiceBusService и использую его. Я получаю сообщение из функции receive_subscription_message .

  • Аутентификация с помощью Azure Active Directory - как программно использовать учетные данные пользователя
  • Получение ImportError: нет модуля с именем azure.storage.blob при выполнении python manage.py syncdb
  • Запуск .exe на Azure
  • API диаграмм аутентифицируется как пользователь программно
  • Ошибка HTTP Azure Flask 500.0 - ОШИБКА ВНУТРЕННЕГО СЕРВЕРА
  • Как запустить команду django manage.py в службе Azure App
  • Полезная нагрузка, которую я получаю, не так ожидаема.

    Мой код – это что-то вроде ниже.

    bus_service = ServiceBusService(service_namespace="service_namespace", shared_access_key_name="All", shared_access_key_value="password") msg = bus_service.receive_subscription_message('test', 'test', peek_lock=True) print(msg.body) msg.delete() 

    msg.body дает байтовую строку, как показано ниже: b'@\x06string\x083http://schemas.microsoft.com/2003/10/Serialization/\x9ae\x0c{"PUID":"3NFLzV3cjCp8f5JLh3KSnkXDgSw1FWgM","HardDelete":null}\x01'

    Изначально в него толкнул json. Есть ли способ избежать дополнительных параметров и получить только оригинальный json?

  • python, запрашивающий все строки azure table
  • Внутренняя ошибка сервера веб-приложений Azure Python
  • API диаграмм аутентифицируется как пользователь программно
  • Получение ImportError: нет модуля с именем azure.storage.blob при выполнении python manage.py syncdb
  • Azure Machine Learning Request Ответная латентность
  • Как импортировать Azure BlobService в python?
  • One Solution collect form web for “Проблема с пинтовым сервером шины Azure”

    Проблема была вызвана различным протоколом, используемым на другой стороне: отправитель в C # с использованием AMQP или поведения и приемника сериализации по умолчанию .NET на Python с использованием REST API через HTTP. Вы можете обратиться к документу, Using Service Bus from .NET with AMQP 1.0 и исходный код SDK Azure Python Service Bus SDK, чтобы узнать об этом, и я объяснил аналогичную проблему в других сообщениях очереди сообщений о взаимодействии с информационной службой SOUR .

    Чтобы избежать дополнительных параметров и получить только оригинальный json, есть два способа, которые вы можете попробовать, как показано ниже.

    1. Использование REST API через HTTP в C # для отправки оригинального json без какого-либо дополнительного контента из AMQP или стандартного поведения сериализации .NET.
    2. Использование пакета python-qpid-proton в Python для сообщения получателя с AMQP для десериализации и получения оригинального json.
    3. В текущем случае просто удалите добавочный контент из сообщений, чтобы извлечь исходный код json, из-за того, что на одно сообщение добавляется контент.

    Надеюсь, поможет.

    Python - лучший язык программирования в мире.