如何动态绑定服务总线BrokeredMessage在Azure的功能

Question

我使用的服务总线与蔚蓝的功能。功能由一个队列触发，则对输入的BrokeredMessage的ReplyTo属性是被用作队列响应上。我如何动态绑定到输出队列？我试着下面的代码，但得到：

无法绑定ServiceBus键入 “Microsoft.ServiceBus.Messaging.BrokeredMessage”。

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); 
}