Azure WebJobs - 基于用户的单例 WebJob

Question

我需要在预定的时间段为不同的用户运行一项作业（例如 CRM 同步）。此同步由 ServiceBus 队列上的另一个函数放置的消息触发，该函数由 TimerTrigger 每 30 分钟触发一次。

现在我需要的是避免每个用户作业并行运行多次，即如果前一个作业未完成，我需要阻止同一用户处理同一作业。

让我们这样想象：

• 早上09:00，TimerTrigger函数被执行。该函数决定用户A和用户B必须同步。对于每个用户，ServiceBus 队列上都会放置一条消息。
• 一旦将消息放入 ServiceBus 队列，就会触发不同的 Azure WebJob。作业已生成并正在运行。
• 09:10 用户 A 的同步作业完成，而用户 B 的同步作业仍在运行。假设它在 09:30 仍在运行。
• 09:30，TimeTrigger函数再次执行。该函数再次确定用户A和B必须同步。队列上的消息又被放入了。
• 由于这两条消息，函数再次被触发两次，但当前有两个并发函数在为用户 B 运行。

如何避免这种情况？

我是否必须手动实现 Azure 租赁 Blob 的逻辑？

谢谢。

Answer 1

使用 WebJob 的

[Singleton]

属性。这就像分布式锁。在底层，它是通过 blob 租赁来实现的。这是一个方法级属性。你可以提供一个“范围”来决定锁的粒度；并且范围可以基于绑定数据。

请参阅 https://github.com/Azure/azure-webjobs-sdk/wiki/Singleton 了解更多详细信息。