如何在Azure函数中动态绑定服务总线BrokeredMessage

Question

我正在使用带天蓝色功能的服务总线。该函数由队列触发，然后输入BrokeredMessage上的BrokeredMessage属性将用作响应队列。如何动态地绑定到输出队列？我试过下面的代码，但得到：

无法将'Microsoft.ServiceBus.Messaging.BrokeredMessage'.绑定到ServiceBus

public static async Task Run(BrokeredMessage msg, Binder binder, TraceWriter log)
{
    log.Info($"C# ServiceBus queue trigger function processed message");
    var msgout = await binder.BindAsync<BrokeredMessage>(new ServiceBusAttribute(msg.ReplyTo));
}

function.json

{
  "disabled": false,
  "bindings": [
    {
      "name": "msg",
      "type": "serviceBusTrigger",
      "direction": "in",
      "queueName": "myInputQueue",
      "connection": "AzureWebJobsServiceBus",
      "accessRights": "Manage"
    }
  ]
}

Answer 1

对于输出场景，需要绑定到IAsyncCollector类型

public static async Task Run(
    BrokeredMessage msg, Binder binder, TraceWriter log)
{
    log.Info($"C# ServiceBus queue trigger function processed message");
    var collector = await binder.BindAsync<IAsyncCollector<BrokeredMessage>>(
                        new ServiceBusAttribute(msg.ReplyTo));

    var message = ...
    await collector.AddAsync(message);
}