Azure WebJobs - 基于用户的单例 WebJob

Question

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

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

让我们这样想象:

• 早上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 租赁来实现的。这是方法级别的属性。你可以提供一个“范围”来决定锁的粒度；并且范围可以基于绑定(bind)数据请参阅https://github.com/Azure/azure-webjobs-sdk/wiki/Singleton更多细节。