Azure Function V2 服务总线消息延迟

本文介绍了Azure Function V2 服务总线消息延迟的处理方法，对大家解决问题具有一定的参考价值，需要的朋友们下面随着小编来一起学习吧！ 问题描述

我正在尝试将我的 v1 函数转换为 v2 函数，但我找不到延迟消息的替代方法.

I am attempting to convert my v1 function to a v2 function, but I cannot find a replacement for deferring a message.

在 Azure Functions V1 中，它是 BrokeredMesage 上的一个方法，称为 .DeferAsync().在 V2 中不再有 BrokeredMessage 而是只有一个 Microsoft.Azure.ServiceBus.Message 并且不包含 .DeferAsync().

In V1 of Azure Functions it was a method on the BrokeredMesage called .DeferAsync(). In V2 there is no longer a BrokeredMessage but just a Microsoft.Azure.ServiceBus.Message and this does not contain the method of .DeferAsync().

根据 docs:

API 在 .NET Framework 客户端中为 BrokeredMessage.Defer 或 BrokeredMessage.DeferAsync，在 .NET Standard 客户端中为 MessageReceiver.DeferAsync，在 Java 客户端中为 messageReceiver.defer 或 messageReceiver.deferSync.

The API is BrokeredMessage.Defer or BrokeredMessage.DeferAsync in the .NET Framework client, MessageReceiver.DeferAsync in the .NET Standard client, and mesageReceiver.defer or messageReceiver.deferSync in the Java client.

但是我怎样才能访问 MessageReciever?这是我的函数的一个示例:

But how can I get access to the MessageReciever? Here is an example of my function:

[FunctionName("MyFunction")] public static void Run([ServiceBusTrigger("topic", "subscription", Connection = "AzureServiceBusPrimary")]Message message, ILogger log) { //Code }

那么有谁知道如何推迟从 Azure 服务总线触发的 V2 Message?

So does anyone know how to defer a V2 Message that is triggered from the Azure Service Bus?

推荐答案

正如您所提到的，新的消息接收器提供了一个异步延迟方法，您可以使用以下代码将其添加到您的函数中:

As you mention, the new message receiver offers an async defer method and you can add this to your function by using the following code:

[FunctionName("MyFunction")] public static async Task Run([ServiceBusTrigger("topic", "subscription", Connection = "AzureServiceBusPrimary")]Message message, string lockToken, MessageReceiver messageReceiver, ILogger log) { //Your function logic await messageReceiver.DeferAsync(lockToken); }