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

Question

使用 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)

Error indexing method 'FilterCurrentCpesToNewCpes'

Can't bind ServiceBus to type 'System.IO.TextWriter'.

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

Answer 1

由于异步函数不能有 out 参数，因此您可以绑定(bind)到 ICollector<T>或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);
    }