单点Azure函数RabbitMQ触发器

Question

我正在开发一个新的XML持久函数，当一个新的C#消息发布到队列中时，它使用RabbitMQ绑定作为触发器。初学者函数根据XML消息的内容启动两个编排函数中的一个。

我希望初学者函数确保在任何时候只运行给定编排类型的一个实例。因此，一个单独的编排类型A和编排类型B的实例并发运行是可以的；但是绝对不会有两个类型A或类型B的实例。

有一个很好的文档这里描述了如何查询业务流程状态。我不确定的是，如果初学者确定相关类型的业务流程当前正在运行，那么如何处理由RabbitMQ绑定接收的新消息？

Answer 1

我用几块金块解决了这个问题。在host.json文件中，我将prefectchCount设置为1：

"extensions": {
"rabbitMQ": {
  "prefetchCount": 1 
}

在业务流程初学者代码(接收来自RabbitMQ的消息所触发的)i循环中，直到没有运行业务流程的实例，然后启动一个新的实例：

while (runningInstances.DurableOrchestrationState.Where
                    (x => x.Name == PortfolioActivationOrchestration
                    && x.RuntimeStatus == OrchestrationRuntimeStatus.Running).Count() > 0)
                {
                    _sl.LogInfo("Going to wait for PortfolioActivationOrchestration to complete");
                    Thread.Sleep(1000);
                    runningInstances = await starter.ListInstancesAsync(
                        noFilter,
                        CancellationToken.None);
                }
await starter.StartNewAsync(ClientActivationOrchestration, propBag);