超出了 Azure 服务总线 SDK 的 SendBatch() 方法上的链接异常当前允许的限制（262144 字节）

Question

我们使用 Azure 服务总线 SDK 3.1.7 的 SendBatch() 方法将数据发送到 Azure 事件中心。以下是代码片段：

foreach (var packet in transformedPackets)
        {
            EventData eventData = new EventData(Encoding.UTF8.GetBytes(JsonConvert.SerializeObject(packet, settings)));;
            try
            {
                eventData.Properties.Add(AppConstants.TenantDeploymentUniqueIdKey, tenantDeploymentUniqueId);
                eventData.Properties.Add(AppConstants.DataTypeKey, DataTypeKey);
                byteCount += eventData.SerializedSizeInBytes;                   
                if (byteCount > MaxBatchSize)
                {
                    sender.SendBatch(transformedMessages);
                    transformedMessages.Clear();
                    byteCount = eventData.SerializedSizeInBytes;
                }
                transformedMessages.Add(eventData);
            }
            catch (System.Exception)
            {
                eventData.Dispose();
                throw;
            }

        }

在将事件数据添加到批处理之前检查 SerializedSizeInBytes 属性后的事件（最大允许限制：256 KB），我们收到以下异常：

接收到的消息（delivery-id:0，大小：262279 字节）超过了当前链路上允许的限制（262144 字节）。在 Microsoft.ServiceBus.Common.ExceptionDispatcher.Throw(Exception exception) 在 Microsoft.ServiceBus.Common.AsyncResult.End[TAsyncResult](IAsyncResult result) 在 Microsoft.ServiceBus.Common.AsyncResult 1.End(IAsyncResult asyncResult) at Microsoft.ServiceBus.Messaging.MessageSender.RetrySenderEventDataAsyncResult.End(IAsyncResult r) at Microsoft.ServiceBus.Messaging.MessageSender.EndSendEventData(IAsyncResult result) at Microsoft.ServiceBus.Messaging.EventHubSender.SendBatch(IEnumerable1 eventDataList)

Answer 1

当事件被翻译成一个单一的AmqpMessage一些额外的信息被添加到批处理头。

确保所有的聚合大小都EventData低于 250k。

您可以在此处找到有关此问题的详细信息：如何在发送到 Microsoft Azure EventHub 时使用客户端事件批处理功能