如何拥有一个写入服务总线队列的异步函数？

使用 Azure WebJobs SDK，我想创建一个异步函数，该函数将接收 ServiceBus 队列输入并写入 ServiceBus 队列输出。异步方法不能有 out 参数，例如在 BlobStorage 上，似乎可以通过使用 Streams 和 TextWriter 来解决。但是，当我尝试对 ServiceBus 参数执行相同操作时，我收到异常。

public static async void Transform(
    [ServiceBusTrigger("%InputQueue%")] String input,
    [ServiceBus("%OutputQueue%")] TextWriter output,
    TextWriter log)

索引方法“FilterCurrentCpesToNewCpes”出错

无法将 ServiceBus 绑定到类型“System.IO.TextWriter”。

我收到一条类似的 Stream 消息。

由于异步函数不能有 out 参数，因此您可以绑定到ICollector<T> or IAsyncCollector<T>并执行Add()操作发送消息。 ICollector 在 WebJobs SDK 中定义。

以下示例演示了这一点。

 public static async void Transform(
[ServiceBusTrigger("%InputQueue%")] string input,
[ServiceBus("%OutputQueue%")] IAsyncCollector<string> output,
TextWriter log)
    {            
        await output.AddAsync(input);
    }