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

Question

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

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

错误索引方法“FilterCurrentCpesToNewCpes”

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

我收到了 Stream 的类似消息。

Answer 1

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