到目前为止,我解决这个问题的方法是避免服务总线触发器,因为它涉及到函数每条消息执行一个实例。我每10秒执行一次time触发器,并且使用来自订阅客户端的方法Receive。
实际上,在这种情况下,您需要手动带来Azure服务总线库,创建所需的类,并调用Receive方法,这样您就可以知道需要多少项。请遵循最佳实践,将ASB类(TopicClient和SubscriptionClient)设置为单例,因为它们是昂贵的对象。
我还必须积累消息,对它们进行排序和重复数据删除,所以这就是我解决问题的方法。但是,如果能够从Azure功能扩展中获得这种开箱即用的功能,那将是非常酷的。
我正在使用Azure服务总线队列。但是我不能使用“获取所有队列消息(peek Lock):微软内置于api”从队列中获取所有消息。 有没有办法获取所有队列消息? {"$连接":{"值":{"servicebus_1":{"连接ID":"/订阅/c776fex3-6aec-4722-b099-b054c267b240/资源组/Plugin-Resources/提供者/Microsoft.网络/连接/
我目前正在评估使用一个服务总线和azure函数来触发一些需要通过下游api调用来完成的工作。这都是相当标准的,只是我没有很好地处理当下游系统过载和/或返回header到trottle时会发生什么(即每分钟最大调用数/等)。对于队列触发器的强制节流,我们似乎没有任何动态控制。 我知道我们可以手动设置最大并发,但这并不一定解决问题,因为我们无法控制下游系统,需要考虑它随时可能脱机或变慢。 假设消费计划
在.NET core 2.0中使用创建时,我遇到了一个问题。 在体系结构中,当在用于创建用户的队列中创建新消息时,服务必须接收该消息并根据其中的信息在数据库中创建用户。 在Visual Studio2017中,我在下创建了一个新项目。 这种的正确实现是什么?在GitHub上有什么例子吗?提前道谢。
我已经创建了一个Azure webwork,它将向服务总线队列发送强类型消息,并成功发送。 我想创建另一个webjob,只要servicebus队列中有消息,就会触发该webjob。请在下面找到我正在尝试的代码。出于某种原因,尽管servicebus队列中有消息,但当我在本地运行webjob时,webjob未被触发并出现错误。 错误: 代码: 有谁能帮我解决这个问题吗? 谢谢
我一直在尝试为Azure函数实现DI,其中函数由ServiceBus触发(本例中为主题/订阅): 我在以下网站上阅读了有关Azure Functions和DI的信息: https://mcguirev10.com/2018/04/03/service-locator-azure-functions-v2.html https://blog.wille-zone.de/post/azure-func
我有一个服务总线主题,它有40万条消息从一个Azure函数推送到它。我有第二个Azure函数接收消息作为触发器。第2个函数运行时,成功处理了98%的消息。它给我留下了大约8000条失败的消息。由于异常或我的代码,消息被放弃了。我现在有8,000条消息坐在一个主题的订阅者中,我不能让函数重新尝试处理。 订阅服务器最初被设置为只允许1邮件传递。我之所以这么做,是因为在调试时,我看到同一条消息被多次处理