加快发送消息

Question

我有一个 azure 函数，可以将大约 20k 条消息发送到服务总线。首先，我开始做 await 操作，但意识到那太慢了。接下来我尝试没有等待并且加快了速度。但是，在发送所有消息之前，我不能仅从我的 azyre 函数 return，因为这会终止进程。然后我尝试了以下操作：

     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());

这里的问题是它似乎在等待所有消息被处理而不是仅仅被传递。向服务总线发送大量消息并等待所有消息传递（未处理）的正确方法是什么？

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);
    });
}

加快发送消息

Speed up sending messages

azureservicebus

azure-servicebus-queues