0

我正在使用 Microsoft Azure 通过主题将消息发送到云中的订阅。但是遇到了 Microsoft 的 python sdk 的问题，特别是在反序列化来自云的消息时出现 ValueError。

这是我的代码

bus_service = ServiceBusService(
    service_namespace='"<namegoeshere>"',
    shared_access_key_name='"<nameofkeygoeshere>"',
    shared_access_key_value='"<keyvaluegoeshere>"')

bus_service.create_topic('topic')
bus_service.create_subscription('topic', 'AllMessages')
msg = Message("HelloWorld")
bus_service.send_topic_message('topic', msg)

// at this point I can see the message arrive in my Azure portal

// then it crashes when I try to retrieve the message I just sent
msg = bus_service.receive_subscription_message('topic', 'AllMessages', peek_lock=False)
print(msg.body)

这是错误：

Traceback (most recent call last):
  File "C:/Users/user/PycharmProjects/test/helloworld.py", line 59, in <module>
msg = bus_service.receive_subscription_message('topic', 'AllMessages', peek_lock=False)
  File "D:\Program Files\Anaconda2\lib\site-packages\azure\servicebus\servicebusservice.py", line 976, in receive_subscription_message
timeout)
  File "D:\Program Files\Anaconda2\lib\site-packages\azure\servicebus\servicebusservice.py", line 764, in read_delete_subscription_message
return _create_message(response, self)
  File "D:\Program Files\Anaconda2\lib\site-packages\azure\servicebus\_serialization.py", line 101, in _create_message
elif str(int(float(value))) == value:
ValueError: could not convert string to float: max-age=31536000

Process finished with exit code 1

我走进教室看了看：

def _create_message(response, service_instance):
    ''' Create message from response.

    response:
        response from service bus cloud server.
    service_instance:
        the service bus client.
'''
respbody = response.body
custom_properties = {}
broker_properties = None
message_type = None
message_location = None

# gets all information from respheaders.
for name, value in response.headers:
    if name.lower() == 'brokerproperties':
        broker_properties = json.loads(value)
    elif name.lower() == 'content-type':
        message_type = value
    elif name.lower() == 'location':
        message_location = value
    elif name.lower() not in ['content-type',
                              'brokerproperties',
                              'transfer-encoding',
                              'server',
                              'location',
                              'date']:

        if '"' in value:
            value = value[1:-1]
            try:
                custom_properties[name] = datetime.strptime(
                    value, '%a, %d %b %Y %H:%M:%S GMT')
            except ValueError:
                custom_properties[name] = value
        else:  # only int, float or boolean
            if value.lower() == 'true':
                custom_properties[name] = True
            elif value.lower() == 'false':
                custom_properties[name] = False
            # int('3.1') doesn't work so need to get float('3.14') first
            elif str(int(float(value))) == value:    # <---- Exception !
                custom_properties[name] = int(value)
            else:
                custom_properties[name] = float(value)

有什么想法可以解决这个问题吗？

4

2 回答 2

1

这是 0.20.1 版本的错误，请参阅 Pypi 中的更改日志。从 2016-06-28 发布的 0.20.2 开始，该错误已修复。https://pypi.python.org/pypi/azure-servicebus

参考问题：https ://github.com/Azure/azure-sdk-for-python/issues/669

谢谢，

于 2016-12-05T17:10:59.390 回答
0

我必须更改 Microsoft 的 _serialization.py 文件才能使其正常工作。将有问题的块包装在 try/except 块中：

if '"' in value:
    value = value[1:-1]
    try:
        custom_properties[name] = datetime.strptime(
            value, '%a, %d %b %Y %H:%M:%S GMT')
    except ValueError:
        custom_properties[name] = value
else:  # only int, float or boolean
    try:
        if value.lower() == 'true':
            custom_properties[name] = True
        elif value.lower() == 'false':
            custom_properties[name] = False
        # int('3.1') doesn't work so need to get float('3.14') first
        elif str(int(float(value))) == value:
            custom_properties[name] = int(value)
        else:
            custom_properties[name] = float(value)
    except ValueError:
        custom_properties[name] = value

到目前为止似乎工作..

那么，微软...有工作机会吗？...

于 2016-12-03T01:27:19.087 回答