c# - Azure 服务总线 Azure Function 触发并获取所有消息

Question

我有一个队列，其中放入了大量高频数据。我有一个azure 函数，当新消息写入其中时会触发该函数并将消息写入Azure sql 数据库。我的问题是要写入的消息太多，所以我想做的是“累积”消息，然后将它们一次性写入数据库。我在 Azure 函数服务总线集成中没有看到任何类型的功能来获取所有(或 x)消息并处理它们。

这样的事情可能吗？

感谢任何帮助。

Answer 1

到目前为止，我解决这个问题的方法是避免服务总线触发，因为它涉及到该函数对每条消息执行一个实例。我每 10 秒执行一次时间触发器，并使用从订阅客户端接收的方法。

事实上，在这种情况下，您需要手动引入 Azure 服务总线库，创建所需的类并调用 Receive 方法，您可以通过该方法知道您想要多少个项目。请遵循最佳实践，即 ASB 类(TopicClient 和 SubscriptionClient)应设置为单例，因为它们是昂贵的对象。

我还必须积累消息来对它们进行排序并消除重复，所以这就是我解决它的方法。但是，如果能够从 Azure Functions 扩展中获得这种开箱即用的功能，那就太酷了。