Webjobs 会自动续订 Azure 队列消息的租约吗?

Do Webjobs automatically renew leases on Azure Queue messages?

当 Webjobs 通过 QueueTrigger 从 Azure 存储上的队列获取消息时,它会租用该消息(使其不可见)。如果(webjob的)触发函数需要很长时间来处理消息,这个租约是否会自动延长?或者我应该在函数中处理它?

关于这个 link Windows Azure Queues: Improved Leases, Progress Tracking, and Scheduling of Future Work,作者声明“消息的租约可以由进行原始出队的工作人员延长,以便它可以继续处理消息"

注意:我尝试了一个等待 20 分钟的网络作业(使用 QueueTrigger)。

//Write Log
Thread.Sleep(1200000);
//Write Log

成功完成。并且在此期间没有其他 webjob 实例尝试尝试相同的队列项目(它没有变得可见)。因此,似乎存在租约的自动续订机制。无论如何,我正在等待 Microsoft 员工或官方 link (msdn, azure, ...) 的答复。

你可以使用方法(Java代码):

queue.retrieveMessage()

从 Azure 存储队列中获取消息。默认情况下,它将在 30 秒后显示。

如果您想延长租约,可以使用以下代码:

CloudQueueMessage updateMessage = queue.retrieveMessage();
EnumSet<MessageUpdateFields> updateFields = EnumSet.of(MessageUpdateFields.CONTENT, MessageUpdateFields.VISIBILITY);
queue.updateMessage(updateMessage, 60, updateFields, null, null);

这意味着您的消息将能够再处理 60 秒。

是的,您的租约自动延长。每次10分钟。

在此处 [1] 处查看 Microsoft 员工的回答,参考 azure.microsoft.com [2] 上的文档和评论。

编辑(长答案)

此外,检查源代码,从 QueueListener class at https://github.com/Azure/azure-webjobs-sdk/blob/cfc875a7f00e595410c0603e6ca65537025490a9/src/Microsoft.Azure.WebJobs.Host/Queues/Listeners/QueueListener.cs 开始表明相同。

QueueListener中的代码在第138行有相关部分,其中定义了10分钟visibilityTimeout变量:

TimeSpan visibilityTimeout = TimeSpan.FromMinutes(10); // long enough to process the job

然后将该变量传递给 ProcessMessageAsync,后者使用相同的值启动方法 CreateUpdateMessageVisibilityTimer 中定义的计时器。 10 分钟值用于确定第一次和下一次更新可见性超时的时间(通过将其减半并创建 LinearSpeedupStrategy class 的实例)。

最终,在 class UpdateQueueMessageVisibilityCommand [3] 中,您会发现队列上的 UpdateMessageAsync 方法以相同的 10 分钟更新被调用。

LinearSpeedupStrategy 将在 5 分钟后再次更新,除非更新失败,在这种情况下它将在 1 分钟后重试(如 QueueListener 中所定义)。

[1] Azure Storage Queue and multiple WebJobs instances: will QueueTrigger set the message lease time on triggered?

[2] https://azure.microsoft.com/en-us/documentation/articles/websites-dotnet-webjobs-sdk-get-started/

[3]https://github.com/Azure/azure-webjobs-sdk/blob/cfc875a7f00e595410c0603e6ca65537025490a9/src/Microsoft.Azure.WebJobs.Host/Queues/Listeners/UpdateQueueMessageVisibilityCommand.cs