Azure函数:已释放Servicebustrigger -> BrokeredMessage

Question

我写了很多具有类似功能的Webjobs，其中类似的代码工作得很好。但是用Azure函数代替，我有时会出错。

[FunctionName("Alert")]
public static async void Alert([ServiceBusTrigger(Topic.Alert, Subscription.Sql, AccessRights.Listen, Connection = "servicebusconnectionstring")] BrokeredMessage message, TraceWriter log)
{
    using (var stream = message.GetBody<Stream>())
    {
        using (var memoryStream = new MemoryStream())
        {
            stream.CopyTo(memoryStream);
            var json = Encoding.UTF8.GetString(memoryStream.ToArray());

            try
            {
                throw new Exception("Test-Exception");
            }
            catch (Exception e)
            {
                EventLogger.LoggException("Function.Sql.Alert", e, new Dictionary<string, string>() { { "Messsage", json } });
                if (message.DeliveryCount >= 5)
                {
                    EventLogger.LoggEvent("DeadLetterQueue", new Dictionary<string, string>() { { "Function", "Function.Sql.Alert" }, { "Messsage", json } });
                    await QueueService.SendAsync(Queue.Deadletter, JsonConvert.DeserializeObject<CloudAlert>(json));
                    await message.CompleteAsync();
                }
                else
                    await message.AbandonAsync();
            }
        }
    }
    await message.CompleteAsync();
}

问题是，当我调用message.AbandonAsync()或message.CompleteAsync时，有时会抛出

System.ObjectDisposedException: BrokeredMessage已经被处理了。

如果在结束时不调用message.CompleteAsync()，则消息仍被标记为已完成。我可以接受这一点，但我也希望能够放弃这个信息，而且这个函数也并不总是起作用。

有人做了类似的事情并找到了解决方案？使用.NET标准2.0并遵循ServiceBus的NuGet包: Microsoft.Azure.ServiceBus v2.0.0

Answer 1

您不应该手动完成或放弃消息。Azure函数运行库将根据您的函数执行的失败(异常)的成功来执行它。

所以，如果你想放弃，就抛出一个异常。这将是自动重试，直到最大交付计数限制。