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

Posted 2023-03-31

【中文标题】我如何拥有一个写入服务总线队列的异步函数？

【英文标题】：How do I have an Async function that writes out to a service bus queue?

【发布时间】：2014-12-23 12:18:27

【问题描述】：

使用 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 的类似消息。

【参考方案1】：

由于Async函数不能有out参数，你可以绑定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);