Cannot Read Base64 Encoded Message with Queue Trigger

[raahmed]

Investigative information

Please provide the following:

• Timestamp: 12:30p, 12/12/2018
• Function App version (1.0 or 2.0): 2.0 (Public Preview)
• Function App name: QueueTrigger (unpublished), ReadFromStorage(unpublished)
• Function name(s) (as appropriate): init.py

Please note: The functions are not published yet.

Repro steps

Provide the steps required to reproduce the problem:

1. Create a function to insert a json string into Functions in Python. The code for the insertion should look like this:

queue_name = "example"

queue_service = QueueService(account_name = "sample", account_key = "sample")

datapoint = json.dumps({"date": "123", "location" : "somewhere"})

datapoint = base64.b64encode(bytes(datapoint, 'utf-8'))

queue_service.put_message(queue_name, str(datapoint))

2. Execute the function successfully.

3. Create another function for queue triggers.

def main(msg: func.QueueMessage) -> None:
    logging.info(msg.get_body.decode('utf-8')

Expected behavior

The function in 3) executes, showing all the queue messages.

Actual behavior

The function in 3) fails with the following error:

Known workarounds

None

Related information

Provide any related information

• Programming language used: Python
• Bindings used: Queues for the second function. Blobs for the first. Both are input bindings.

[mawah]

Hi @raahmed,

I think this problem can be handled by changing the default encode_message function for the QueueService to one designed for base64 encoding. Fortunately there's an appropriate encode_message function available in the azure-storage-queue package that you're using to submit a message to the queue:

from azure.storage.queue.models import QueueMessageFormat

queue_name = "example"
queue_service = QueueService(account_name = "sample", account_key = "sample")
queue_service.encode_function = QueueMessageFormat.text_base64encode

datapoint = json.dumps({"date": "123", "location" : "somewhere"})
queue_service.put_message(queue_name, datapoint)

Hope this does the trick!