Azure函数QueueTrigger和int消息

Question

我希望将int值保存到队列消息中，然后在Azure函数QueueTrigger上获取它。

我通过以下方式保存：

        int deviceId = -1;
        await queue.AddMessageAsync(new CloudQueueMessage(deviceId.ToString()));

然后监听队列：

    public async Task Run(
        [QueueTrigger("verizon-suspend-device", Connection = "StorageConnectionString")] string queueMessage, 
        ILogger log)
    {
        int deviceId = int.Parse(queueMessage);

但所有消息都将被移动到verizon-suspend-device-poison队列中。怎么啦？

Answer 1

这是一个不幸的限制，Azure Function Queue Triggers currently require Base64-encoded messages。如果在存储仿真器上运行代码，应该会看到触发器中出现异常，如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.

至少现在(即在触发器可以处理二进制/utf8消息之前)，队列代码必须将消息作为Base64字符串放在队列中。string消息的队列触发器代码以here和AsString assumes a Base64 encoding结尾。

对于该(old) version of the storage SDK，您可以发送整数的base64编码的UTF-8字符串表示：

var bytes = Encoding.UTF8.GetBytes(deviceId.ToString());
await queue.AddMessageAsync(new CloudQueueMessage(Convert.ToBase64String(bytes), isBase64Encoded: true));

使用new storage SDK，您将set MessageEncoding on your QueueClient to QueueMessageEncoding.Base64，然后只发送整数的字符串表示(新的storage SDK将为您进行UTF-8编码，然后进行base64编码)。