如何在C#版隔离式Azure Functions V4队列触发器中获取消息元数据

问题原因 #

隔离进程模式下，Azure Functions存储队列触发器默认将消息内容序列化为字符串或JSON对象，不再兼容旧的Microsoft.WindowsAzure.Storage.Queue.CloudQueueMessage类型，这是你遇到转换错误的核心原因。

解决方案 #

有两种可靠方式获取消息元数据（如MessageId、DequeueCount）：

方式一：直接绑定单个元数据属性 #

通过绑定表达式，在函数参数中声明对应元数据的参数，参数名需匹配触发器支持的元数据键：

[Function("TestApp")]
public void Run(
    [QueueTrigger("sample-queue", Connection = "StorageConnectionString")] string messageContent,
    string id, // 对应MessageId
    int dequeueCount, // 对应DequeueCount
    DateTimeOffset expirationTime, // 消息过期时间
    DateTimeOffset insertionTime, // 消息插入时间
    FunctionContext context)
{
    var logger = context.GetLogger("TestApp");
    logger.LogInformation($"Message ID: {id}, Dequeue Count: {dequeueCount}");
    logger.LogInformation($"Message Content: {messageContent}");
}

支持的元数据参数包括：

• id: 消息唯一标识（MessageId）
• dequeueCount: 消息被取出的次数
• expirationTime: 消息过期时间
• insertionTime: 消息被插入队列的时间
• nextVisibleTime: 消息下次可见的时间
• popReceipt: 消息的弹出收据字符串

方式二：绑定到QueueMessage类型（推荐） #

使用Azure.Storage.Queues.Models.QueueMessage类型（属于新的Azure存储SDK），一次性获取所有消息元数据和内容：

1. 确保安装兼容的NuGet包：Azure.Storage.Queues（版本12.x及以上）
2. 修改函数代码：

using Azure.Storage.Queues.Models;

[Function("TestApp")]
public void Run(
    [QueueTrigger("sample-queue", Connection = "StorageConnectionString")] QueueMessage queueMessage,
    FunctionContext context)
{
    var logger = context.GetLogger("TestApp");
    logger.LogInformation($"Message ID: {queueMessage.MessageId}, Dequeue Count: {queueMessage.DequeueCount}");
    logger.LogInformation($"Message Content: {queueMessage.Body.ToString()}");
    // 可访问其他属性：queueMessage.ExpirationTime、queueMessage.InsertionTime等
}

注意：不要使用旧的CloudQueueMessage，QueueMessage是隔离进程模式原生支持的类型，与Functions V4完全兼容。

内容的提问来源于stack exchange，提问作者Gautam Kumar Samal