如何加快向 AzureEventHub 发送事件的速度？

Question

我正在使用这个简单的 foreach 循环将事件发送到 Azure EventHub，问题是它看起来很慢并且只发送 1-2 个事件/秒，所以我觉得我一定错过了一些东西，我怎样才能加快速度？我是异步发送它们还是我做错了什么？

 if (!apiInputPutCalendarService.TimeSlotIdsToClose.Any())
                {
                    return new BadRequestObjectResult(new
                    {
                        Status = "NOK",
                        Error = "There are no timeslots to close",
                        Result = ""
                    });
                }
                else
                {
                    foreach (String calendarTimeSlotId in apiInputPutCalendarService.TimeSlotIdsToClose)
                    {
                        EventHubCDSSoftDeleteTriggerModel scanMsg = new EventHubCDSSoftDeleteTriggerModel
                        {
                            TimeSlotId = calendarTimeSlotId
                        };

                        var scanMessageJsonString = JsonConvert.SerializeObject(scanMsg);

                        await EventHubHelper.SendEventToEventHubAsync(_eventHubClient, scanMessageJsonString);

                        log.LogInformation($"Message: {scanMessageJsonString} sent!");
                    }
                }

这是一条如此简单的小消息，我预计每秒至少要发送 100 条消息

我在这里错过了什么？

Answer 1

那么，您是否测量了日志记录和序列化以及对TimeSlotIdsToClose 的调用的影响？另外，我不会一一发送消息，而是分批发送消息：

await using (var producerClient = new EventHubProducerClient(connectionString, eventHubName))
        {
            // Create a batch of events 
            using EventDataBatch eventBatch = await producerClient.CreateBatchAsync();

            // Add events to the batch. An event is a represented by a collection of bytes and metadata. 
            eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes("First event")));
            eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes("Second event")));
            eventBatch.TryAdd(new EventData(Encoding.UTF8.GetBytes("Third event")));

            // Use the producer client to send the batch of events to the event hub
            await producerClient.SendAsync(eventBatch);
            Console.WriteLine("A batch of 3 events has been published.");
        }

(source)

请注意，上面的代码不会重用EventHubProducerClient，这是推荐的，您不应忽略TryAdd 的结果，因为它会告诉您是否可以将消息添加到批处理中（有每个批次的基于大小的限制）。

另外，因为我不知道你的代码：

在应用程序的整个生命周期内，每种事件中心客户端类型都可以安全地缓存和用作单例，这是定期发布或读取事件时的最佳实践。

(Source)