限制并发逻辑应用程序（标准）工作流程实例

Question

我有一个场景，我从服务总线接收消息来触发工作流程。该工作流程进行了一些处理，但最终将一些数据插入SQL DB中。当100,000个消息立即出现时，数据库就会不知所措。

有没有一种方法可以限制并发实例的数量？

这是我的测试

这会收到一条非会话消息，有2分钟的延迟，然后A组成只是为了进行最终活动。

如果我提交10条消息，请启用工作流程，立即使所有10条消息都会导致10个工作流激活。

这是我的host.json文件

Answer 1

逻辑应用标准在Azure函数上运行，因此您应该能够使用 host.json 设置：

{
    "version": "2.0",
    "extensions": {
        "serviceBus": {
            "clientRetryOptions":{
                "mode": "exponential",
                "tryTimeout": "00:01:00",
                "delay": "00:00:00.80",
                "maxDelay": "00:01:00",
                "maxRetries": 3
            },
            "prefetchCount": 0,
            "transportType": "amqpWebSockets",
            "webProxy": "https://proxyserver:8080",
            "autoCompleteMessages": true,
            "maxAutoLockRenewalDuration": "00:05:00",
            "maxConcurrentCalls": 16,
            "maxConcurrentSessions": 8,
            "maxMessageBatchSize": 1000,
            "sessionIdleTimeout": "00:01:00",
            "enableCrossEntityTransactions": false
        }
    }
}

您还可以使用AppSettings设置此设置（请参见现有答案）：

AzureFunctionsJobHost__extensions__serviceBus__maxConcurrentCalls

Answer 2

您可以在应用程序级别应用并发控制（与托马斯建议的类似概念相似，但是逻辑应用程序有特定的切换）。下面的链接指向这些值：

https://learn.microsoft.com/en-us/azure/logic-apps/edit-app-settings-host-settings?tabs=visual-studio-code#trigger-conconcorrency

值您正在寻找的是runtime.trigger.maximumrunco​​ncurrency（这在hosts.json中应用）。文档中有一些有关如何设置主机的指导（滚动一点）。

另一个选项是删除拆分，因此您会收到一个带有所有消息的数组，并使用for-each循环，在该循环中，您可以在循环并发上获得更多控制。

我希望这会有所帮助。

欢呼，瓦格纳。