azure - 如何在自定义异常上对代理消息发送死信

Question

如果我遇到自定义异常，我需要将 BrokeredMessage 强制移动到死信队列。这是我使用过的代码:

public static async Task Run([ServiceBusTrigger("myqueue", Connection = "myservicebus:cs")]BrokeredMessage myQueueItem, TraceWriter log)
{
    try
    {   
        // process message logic.. 
    }
    catch(CustomException ex)
    {
        //forcefully dead letter if custom exception occurs
        await myQueueItem.DeadLetterAsync();
    }           
}

但是，有时，如果我在代码中显式调用 DeadLetterAsync、AbandonAsync() 等，我会遇到 MessageLockLost, 异常即使锁实际上并没有丢失。任何人都可以建议我，将代理消息移动到死信队列以处理自定义异常的最佳方法是什么。谢谢。

Answer 1

不完全是您想要的，但有创意的解决方法:

将输出服务总线绑定(bind)添加到您的函数。将新消息添加到输出中，以代替死信消息:

public static async Task Run(
    [ServiceBusTrigger("myqueue", Connection = "mysb")] BrokeredMessage myQueueItem, 
    [ServiceBus("mydlq", Connection = "mysb")] IAsyncCollector<BrokeredMessage> dlq, 
    TraceWriter log)
{
    try
    {   
        // process message logic.. 
    }
    catch(CustomException ex)
    {
        // forward to "DLQ" when exception occurs
        var dlqMessage = ...; // you need to create a new message here
        await dlq.AddAsync(dlqMessage);
    }           
}

原始消息将成功完成。

请注意，您需要创建一个新的 BrokeredMessage并仔细复制原始消息中的所有数据和元数据。如果您没有元数据，也许最好将收集器的类型更改为简单的类型，例如 IAsyncCollector<string> .