c# - 从 Azure 函数将批量消息发送到服务总线主题

Question

在Azure函数中，我使用服务总线触发器从队列中读取消息并在处理消息后将其发送到主题。我正在使用 return 输出绑定(bind)选项来发送消息。这按预期工作。

[FunctionName("Function1")]
    [return: ServiceBus("mytopic", EntityType.Topic, Connection = "topicConnection")]
    public static async Task<Message> Run([ServiceBusTrigger("myqueue", Connection = "queueconnection")] Message myQueueItem, MessageReceiver messageReceiver, ILogger log)

但现在我计划从队列中批量读取消息。因此，为了实现这一目标，我使用了有效的 Message[] myQueueItem 。

[FunctionName("Function1")]
    [return: ServiceBus("mytopic", EntityType.Topic, Connection = "topicConnection")]
    public static async Task<Message> Run([ServiceBusTrigger("myqueue", Connection = "queueconnection")] Message[] myQueueItem, MessageReceiver messageReceiver, ILogger log)

但我没有找到任何使用 return 选项将消息作为批量或消息数组发送到主题的选项。另一种选择是使用 TopicClient 对象并调用 SendBatchAsync。我想了解是否可以使用 return 选项轻松完成此操作。

Answer 1

使用函数发送多条消息时，根据您使用的 SDK，实现会有所不同。对于 In-Process SDK，您使用收集器。对于独立工作人员 SDK，您使用自定义返回类型。我有一个blog post这将详细介绍这两个 SDK。