c# - 是否可以在 Azure Functions .Net 5 中使用多个输出？

Question

我正在使用 .net 5 azure 函数和 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);
}

但正如我在 documentation 中读到的那样新版本不支持 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; }
    }
}