Azure Service Bus主题批量接收消息配置后反序列化异常求助

你遇到的问题核心在于直接使用string[]作为参数类型时，函数运行时的反序列化逻辑不符合预期：当指定string[]时，运行时会尝试将接收到的所有消息内容整体反序列化为一个JSON数组，但你的每条消息是独立的字符串（而非JSON数组格式的消息体），因此触发了序列化错误。

下面是两种可行的解决方案，以及修正后的配置：

方案一：使用EventData[]接收批量消息（推荐） #

这是最稳妥的方式，EventData包含完整的消息元数据（如消息ID、属性等），你可以手动提取每条消息的Body内容：

修改后的函数代码 #

using System.Text;
using Microsoft.Azure.EventHubs;
using Microsoft.Azure.WebJobs;
using Microsoft.Azure.WebJobs.Host;

public static void Run(
    [ServiceBusTrigger("mytopic name", "MySubscription", AccessRights.Listen, Connection = TopicService.ConnectionStringName)] 
    EventData[] messages, 
    TraceWriter logger)
{
    logger.Info($"Received {messages.Length} messages in batch");
    
    foreach (var msg in messages)
    {
        // 将消息体从字节数组转换为字符串
        string messageBody = Encoding.UTF8.GetString(msg.Body);
        logger.Info($"Processing message: {messageBody}");
        
        // 在这里添加你的消息处理逻辑
    }
}

修正host.json配置 #

注意：aggregator节点并非Service Bus Trigger的批量配置项，需根据你的Functions版本调整：

• Functions v2/v3及以上版本：

  {
    "extensions": {
      "serviceBus": {
        "batchOptions": {
          "maxMessageCount": 10, // 每次批量接收的最大消息数
          "operationTimeout": "00:00:30" // 超时时间，到点即使未达最大数也会触发函数
        }
      }
    }
  }
  

• Functions v1版本：

  {
    "serviceBus": {
      "batchSize": 10,
      "flushTimeout": "00:00:30"
    }
  }
  

方案二：自定义消息体格式（不推荐，仅可控消息发送格式时使用） #

如果坚持要用string[]接收，需确保每条发送到Topic的消息体本身是JSON数组格式的字符串，但这种方式灵活性极低，仅适合特殊场景，因此不推荐。

另外，你已开启的主题订阅“Enable batched operations”是正确设置，它确保Service Bus服务端会批量推送消息到函数，无需修改。

内容的提问来源于stack exchange，提问作者Dennis