Python Azure 队列，出现错误

Question

我正在努力解决编码问题。我仍在尝试找出 Python3 编码方案。我正在尝试将 json 对象从 Python 上传到 Azure 队列中。我正在使用 Python3

我制作 json 对象

response = {"UserImageId": 636667744866847370, "OutputImageName": "car-1807177_with_blue-2467336_size_1020_u38fa38.png"} 
queue_service.put_message(response_queue, json.dumps(response))

当它进入队列时，我收到错误

{"imgResponse":"The input is not a valid Base-64 string as it contains a non-base 64 character, more than two padding characters, or an illegal character among the padding characters. ","log":null,"$return":""}

所以我必须做其他事情，因为显然我需要对我的字符串进行 base64 编码。所以我尝试

queue_service.put_message(response_queue, base64.b64encode(json.dumps(response).encode('utf-8')))

我得到

TypeError: message should be of type str

来自 Azure 存储队列包。如果我检查上面语句的类型，它是 bytes 类型（有意义）。所以我的问题是，如何将 json 对象编码成队列服务可以理解的内容。我真的很想能够保留 _ 和 - 和。图片名称中的字符。

Answer 1

这是我必须在我的代码中做的事情：

queue_service = QueueService(account_name=os.getenv('storageAccount'), account_key=os.getenv('storageKey'))
queue_service.encode_function = QueueMessageFormat.text_base64encode

之后我就可以发信息了：

queue_service.put_message('bbbb', message) # 'bbbb' is a queue name

Answer 2

如果有人希望使用 QueueClient 而不是 QueueService 来解决这个问题，以下是对我有用的方法：

import json
from azure.storage.queue import QueueServiceClient, QueueClient, QueueMessage, TextBase64EncodePolicy

conn_string = '[YOUR_CONNECTION_STRING_HERE]'
queue_client = QueueClient.from_connection_string(
    conn_string,
    '[QUEUE_NAME_HERE]',
    message_encode_policy=TextBase64EncodePolicy()
)
queue_client.send_message(json.dumps({'a':'b'}))

Python Azure 队列，出现错误

Python Azure Queue, getting error

python

base64

azure

python-3.x

azure-storage-queues