c# - WebJob 控制台应用程序中的 ProcessQueueMessage 函数

Question

我正在创建一个新的控制台应用程序，它将作为 Azure 上的 WebJob 运行。当我在 Visual Studio 中创建新应用程序时，它已经创建了一个 Function.cs 类，其中包含以下方法，该方法自动从我的队列中获取消息并对其进行处理。

public static void ProcessQueueMessage([QueueTrigger("queue")] string message, TextWriter log)
{
   log.WriteLine(message);
}

我的问题是如何更好地控制队列消息的处理。例如，我想确保消息已被处理并删除。此方法似乎为我完成了所有这些操作，但我如何知道消息是否已正确处理？如果失败怎么办，如何告诉它不要删除消息？

Answer 1

是的，所有这些都为您处理。仅当您的函数成功完成时才会删除队列消息。在此之前，当您的函数运行时，队列消息将保持不可见，因此没有其他人会拾取它进行处理。如果您的函数失败，消息将在短时间内变得可见，以便可以对其进行处理。如果队列消息在处理可配置次数(默认为 5)时失败，则消息将移至 poison queue .

如果您有高级要求并且需要深入插入 SDK 队列处理管道，您可以实现并注册您自己的自定义 QueueProcessor 实例来覆盖/自定义消息处理的各个部分。请参阅this sample了解更多详情。