在Azure函数.Net 5中可以使用多个输出吗？

Question

我使用.net 5天蓝色函数和ServiceBus。我想从触发器函数发送多条消息。在以前的版本中，您可以使用IAsyncCollector来做这样的事情：

[FunctionName("HttpToServiceBusQueue")]
public static async Task<IActionResult> Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "get", "post", Route = null)] HttpRequest req,
    [ServiceBus("testqueue",Connection ="connectionString")] IAsyncCollector<string> outputEvents,
    ILogger log)
{
    log.LogInformation("C# HTTP trigger function processed a request.");
    // ...
    
    await outputEvents.AddAsync("message1");
    await outputEvents.AddAsync("message2");

    // ...
    return new OkObjectResult(responseMessage);
}

但是，正如我在文档中所读到的，在新版本中不支持IAsyncCollector。有没有其他方法可以替代呢？

我的代码示例：

[Function("FileTriggerFunction")]
[ServiceBusOutput("fileupload", Connection = "ServiceBusConnectionWrite")]
public string Run(
    [BlobTrigger("file-storage/{name}", Connection = "ConnectionString")] string  myBlob, string name,
    FunctionContext context)
{
    var logger = context.GetLogger("FileTriggerFunction");
    var res = JsonConvert.SerializeObject(*List of messages*);
    logger.LogInformation(res);
    return res;
}

实际上，它将列表中的每个对象分离为单独的消息，但我不认为这样做是正确的。

Answer 1

下面是一个示例代码，说明了如何做到这一点

    [Function("MultiOutput")]
    public static DispatchedMessages Run([HttpTrigger(AuthorizationLevel.Anonymous, "get")] HttpRequestData req,
        FunctionContext context)
    {
        return new DispatchedMessages
        {
            Messages = new List<string> { "aaa", "bbb" } // todo: serialize
        };
    }

    public class DispatchedMessages
    {
        [ServiceBusOutput(queueOrTopicName: "dest", Connection = "AzureServiceBus")]
        public IEnumerable<string> Messages { get; set; }
    }
}

Answer 2

而不是IAsyncCollector，我们在.net 5中有多个输出绑定

在这个函数上，我们将给出多个输出值。

public static class MultiOutput
{
[Function("MultiOutput")]
public static MyOutputType Run([HttpTrigger(AuthorizationLevel.Anonymous, "get")] HttpRequestData req,
FunctionContext context)
{
    var response = req.CreateResponse(HttpStatusCode.OK);
    response.WriteString("Success!"); 
    string myQueueOutput = "some output";
    return new MyOutputType()
    {
        Name = myQueueOutput,
        HttpResponse = response
    };
    }
}
public class MyOutputType
{
    [QueueOutput("myQueue")]
    public string Name { get; set; }
    public HttpResponseData HttpResponse { get; set; }
}

参考Azure函数中的.NET隔离.NET 5.0过程指南

谢谢@ 斯蒂芬·克利里

我曾尝试使用SeviceBus客户端向队列发送多条消息，我能够处理它。

参考这里