当前位置: 首页 > 知识库问答 >
问题:

Azure Logic应用程序-服务总线触发器仅在轮询循环时触发

戚修雅
2023-03-14
"When_a_message_is_received_in_a_topic_subscription_(auto-complete)": {
            "conditions": [],
            "inputs": {
                "host": {
                    "connection": {
                        "name": "@parameters('$connections')['servicebus']['connectionId']"
                    }
                },
                "method": "get",
                "path": "/@{encodeURIComponent(encodeURIComponent('exampletopic'))}/subscriptions/@{encodeURIComponent('examplesubscription')}/messages/head",
                "queries": {
                    "subscriptionType": "Main"
                }
            },
            "recurrence": {
                "frequency": "Minute",
                "interval": 30,
                "startTime": "2021-01-27T00:00:00.000Z",
                "timeZone": "UTC"
            },
            "runtimeConfiguration": {
                "concurrency": {
                    "runs": 25
                }
            },
            "type": "ApiConnection"
        }

如果有人感兴趣,服务总线设置也在下面:

Topic:
"properties": {
            "defaultMessageTimeToLive": "P5D",
            "maxSizeInMegabytes": 1024,
            "requiresDuplicateDetection": true,
            "duplicateDetectionHistoryTimeWindow": "PT1H",
            "enableBatchedOperations": true,
            "status": "Active",
            "supportOrdering": true,
            "autoDeleteOnIdle": "P10675199DT2H48M5.4775807S",
            "enablePartitioning": false,
            "enableExpress": false
        }
Subscription:
"properties": {
            "lockDuration": "PT5M",
            "requiresSession": false,
            "defaultMessageTimeToLive": "P5D",
            "deadLetteringOnMessageExpiration": true,
            "deadLetteringOnFilterEvaluationExceptions": true,
            "maxDeliveryCount": 1,
            "status": "Active",
            "enableBatchedOperations": true,
            "autoDeleteOnIdle": "P5D"
        }

提前致谢

共有1个答案

陶飞鸿
2023-03-14

这是故意的还是我设置错了?

服务总线触发器是这样设计的,因为它是轮询触发器并且将以您指定的间隔运行,请参阅触发器概述:

每个工作流都包含一个触发器,该触发器定义实例化和启动工作流的调用。以下是一般触发器类别:

    null

是否尝试关闭并发控制。根据说明,关闭并发控制可以运行尽可能多的并行实例,但并发控制的设置一旦打开,就不能关闭。您可能需要重新创建Azure logic App,或者将并发控制设置为可能的最大值,最大值为50。

1.

2.

 类似资料:
  • 我已经创建了一个Azure webwork,它将向服务总线队列发送强类型消息,并成功发送。 我想创建另一个webjob,只要servicebus队列中有消息,就会触发该webjob。请在下面找到我正在尝试的代码。出于某种原因,尽管servicebus队列中有消息,但当我在本地运行webjob时,webjob未被触发并出现错误。 错误: 代码: 有谁能帮我解决这个问题吗? 谢谢

  • 我试图从使用逻辑应用程序的服务总线队列读取消息。我没有找到任何关于逻辑应用程序如何根据队列中的消息数量进行缩放的留档。任何帮助或指针非常感谢。

  • 我目前正在评估使用一个服务总线和azure函数来触发一些需要通过下游api调用来完成的工作。这都是相当标准的,只是我没有很好地处理当下游系统过载和/或返回header到trottle时会发生什么(即每分钟最大调用数/等)。对于队列触发器的强制节流,我们似乎没有任何动态控制。 我知道我们可以手动设置最大并发,但这并不一定解决问题,因为我们无法控制下游系统,需要考虑它随时可能脱机或变慢。 假设消费计划

  • 我使用服务总线触发器创建了一个azure函数,当我尝试运行该函数时,我得到了这个错误: 我为开发存储设置了local.settings.json文件 我在使用AzureWebJobsStorage的函数中有连接字符串 我不知道是什么问题。如果有任何帮助,将不胜感激。

  • 我知道Azure Functions3.0正在预览中,但我们最好尽快赶上bug。 大多数时候没有问题,但我每天大约有2次会出现这样的错误: Microsoft.azure.ServiceBus.MessageLockLostException:at Microsoft.azure.ServiceBus.core.MessageReceiver+D__99.MoveNext(Microsoft.az

  • 在.NET core 2.0中使用创建时,我遇到了一个问题。 在体系结构中,当在用于创建用户的队列中创建新消息时,服务必须接收该消息并根据其中的信息在数据库中创建用户。 在Visual Studio2017中,我在下创建了一个新项目。 这种的正确实现是什么?在GitHub上有什么例子吗?提前道谢。