加快发送消息

Question

我有一个azure函数，可以向服务总线发送大约20k条消息。首先，我开始做等待操作，但意识到这很慢。以下我试着没有等待，加快了速度。但是我不能在发送所有消息之前从我的azyre函数返回，因为这会终止进程。然后我试着跟随：

     string queuePath = "xx";
     var queueClient = new QueueClient(_serviceBusConnectionString, queuePath);

     foreach(var tenantSite in tenatSites)
     {
        var jsonStr = JsonConvert.SerializeObject(tenantSite);

        string messageBody = jsonStr;
        var message = new Microsoft.Azure.ServiceBus.Message(Encoding.UTF8.GetBytes(messageBody));
        var task = queueClient.SendAsync(message);
        tasks.Add(task);
     }
     Task.WaitAll(tasks.ToArray());

这里的问题是它似乎等待所有消息被处理而不是刚刚交付。向服务总线发送大量消息的正确方法是什么，等待所有交付（不是proccessed）？

Answer 1

看看Bindings可以为您做些什么。在你的情况下具体：Azure Service Bus bindings for Azure Functions。 更具体一点：使用ICollector<T>或IAsyncCollector<T>可以创建多条消息。调用Add方法时会创建一条消息。

示例实现看起来像这样：

[FunctionName("FunctionName")]
public static void Run(
    [HttpTrigger(AuthorizationLevel.Anonymous, "post", Route = "some-route")] HttpRequest req,
    [ServiceBus("some-queue-name", Connection = "ServiceBusConnectionSend", EntityType = EntityType.Queue)] ICollector<string> queueCollector,
    string name, ILogger log)
{
    Parallel.ForEach(tenantSites, (tenantSite) =>
    {
        var jsonStr = JsonConvert.SerializeObject(tenantSite);

        queueCollector.Add(tenantSite);
    });
}