azure-functions - 如何获取 Azure 服务总线触发的 Azure Function V3 背后的底层 MessageReceiver 引用

Question

我已将 Azure Function 配置为在触发 Azure Function 时不显示“自动完成”消息。我的问题是我需要自己将消息标记为完整，并在事务的上下文中执行此操作(如下)。使用“via”路由的此事务在控制台应用程序中有效，但在 Azure 中失败，因为缺少对使消息出队的原始接收者的引用。

如何获取底层接收者引用，以便我可以原子地完成和发送？在 Azure Functions 中似乎无法执行此操作。

using (var ts = new TransactionScope(TransactionScopeAsyncFlowOption.Enabled))
{
      try
      {
         await receiver.CompleteAsync(completeMessage.SystemProperties.LockToken);

         for (var i = 0; i <= sendMessages.Length - 1; i++)
            await sender.SendAsync(sendMessages[i]);

         ts.Complete();
      }
      catch (Exception ex)
      {
         // This rolls back send and complete in case an exception happens
      }
}

如果没有原始接收者引用(以及您自己新创建的引用)，您会得到以下异常:

ERROR: Microsoft.Azure.ServiceBus.MessageLockLostException: The lock supplied is invalid. Either the lock expired, or the message has already been removed from the queue, or was received by a different receiver instance.

Answer 1

您需要注入(inject)函数使用的消息接收器来接收传入消息。注入(inject)是通过函数参数完成的。 This post进入细节。