Azure Function死信处理报错与重复重试问题的最佳实践

问题描述 #

在Azure Function中，未设置Autocomplete = false时调用DeadLetterAsync会抛出“Message processing error(Action=Complete)”错误；但设置Autocomplete=false后，即使消息处理成功仍会不断重试。请问接收消息并在异常时执行死信操作的最佳方式是什么？

用户提供的代码示例：

public async Task Test(
        [ServiceBusTrigger(
            topicName: "testTopic",
            subscriptionName: "testSubsription",
            Connection = "testConnectionString",Autocomplete = false)]
        Message message,
        MessageReceiver messageReceiver,
        [ServiceBus("SendTopic", EntityType.Topic, Connection = "SendConnection")]
        IAsyncCollector<Message> output,
        CancellationToken cancellationToken)
     {
        try
        { 

            var result = JsonConvert.DeserializeObject<TestObject>(Encoding.UTF8.GetString(message.Body));
            foreach (var data in result.Data)
            {
               var convertedData= JsonConvert.SerializeObject(data);
               var byteArray = Encoding.UTF8.GetBytes(convertedData);
               Message outputMessages = new(byteArray);
               await output.AddAsync(outputMessages, cancellationToken);
               await messageReceiver.CompleteAsync(lockToken);
            }
        }
        catch (Exception ex)
        {
          await messageReceiver.DeadLetterAsync(lockToken);
        }
    }

最佳处理方案 #

核心问题分析 #

• 当Autocomplete=true（默认值）时，Function运行时会自动在函数执行完成后调用CompleteAsync，如果手动调用DeadLetterAsync，会和运行时的自动操作冲突，触发报错。
• 设置Autocomplete=false后，必须手动调用CompleteAsync确认消息处理完成，否则消息锁到期后会重回队列，引发重复重试。原代码在循环内调用CompleteAsync是错误的——一个消息只能被完成一次，多次调用会导致操作失效，且消息未被正确标记为完成，进而触发重试。

修正后的代码实现 #

public async Task Test(
    [ServiceBusTrigger(
        topicName: "testTopic",
        subscriptionName: "testSubsription",
        Connection = "testConnectionString",
        Autocomplete = false)]
    Message message,
    MessageReceiver messageReceiver,
    [ServiceBus("SendTopic", EntityType.Topic, Connection = "SendConnection")]
    IAsyncCollector<Message> output,
    CancellationToken cancellationToken)
{
    var lockToken = message.SystemProperties.LockToken;
    try
    { 
        var result = JsonConvert.DeserializeObject<TestObject>(Encoding.UTF8.GetString(message.Body));
        foreach (var data in result.Data)
        {
            var convertedData = JsonConvert.SerializeObject(data);
            var byteArray = Encoding.UTF8.GetBytes(convertedData);
            Message outputMessages = new(byteArray);
            await output.AddAsync(outputMessages, cancellationToken);
        }
        // 所有业务逻辑执行完成后，统一调用一次CompleteAsync
        await messageReceiver.CompleteAsync(lockToken);
    }
    catch (Exception ex)
    {
        // 异常时调用死信，仅调用一次
        await messageReceiver.DeadLetterAsync(lockToken, "处理失败", ex.Message);
    }
}

关键修正点 #

• 移除循环内的CompleteAsync：一个Service Bus消息只能被完成一次，必须在所有子数据处理完成后，统一调用一次CompleteAsync，确保消息状态被正确标记。
• 显式获取锁令牌：直接从message.SystemProperties.LockToken获取锁令牌，避免未定义变量的问题。
• 手动管理消息生命周期：设置Autocomplete=false后，成功时调用CompleteAsync，异常时调用DeadLetterAsync，二者二选一且仅调用一次，避免运行时重复处理消息。

额外注意事项 #

• 如果业务逻辑耗时较长，可调用RenewLockAsync延长消息锁的有效期，避免锁到期后消息重回队列。
• 死信操作可添加备注信息，方便后续排查问题（如示例中的错误原因描述）。

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