отправка событий в eventhub не удается каждое раннее утро с сообщением ниже. Я замаскировал номер, так как не уверен, что это за номер, и из соображений безопасности. (Код и ошибка ниже)
- Я постоянно отправляю ~ 240 событий в минуту очень маленького размера, так что это не должно быть проблемой.
- У меня есть 2 раздела и 2 потребителя для моего хаба событий. Сообщите мне, знает ли кто-нибудь из вас решение или ему нужна дополнительная информация. Спасибо!
Ошибка: сообщение: произошла ошибка во время связи с «XXXXX06f186e4bb89aea2d8959bXXXXX_GXX». Проверьте информацию о соединении, затем повторите попытку.
StackTrace: в Microsoft.ServiceBus.Common.AsyncResult.End [TAsyncResult] (результат IAsyncResult), в Microsoft.ServiceBus.Common.AsyncResult1.End (IAsyncResult asyncResult), в Microsoft.ServiceBus.Messaging.MessagingResult, asyncResult, в Microsoft.ServiceBus.MessagingInjectResult Microsoft.ServiceBus.Messaging.SingletonManager1.EndGetInstance (IAsyncResult asyncResult) в Microsoft.ServiceBus.Messaging.Amqp.AmqpMessageSender.OnEndOpen (результат IAsyncResult) в Microsoft.ServiceBus.MessagingEndOpen. OpenOnceManager.OnEndCreateInstance (IAsyncResult AsyncResult) при Microsoft.ServiceBus.Messaging.SingletonManager1.EndGetInstance (IAsyncResult AsyncResult) при Microsoft.ServiceBus.Messaging.OpenOnceManager.OpenOnceManagerAsyncResult1.OpenComplete (IAsyncResult результат) в Microsoft.ServiceBus.Common.AsyncResult.SyncContinue (IAsyncResult результат ) в Microsoft.ServiceBus.Messaging.OpenOnceManager.OpenOnceManagerAsyncResult1..ctor (OpenOn ceManager openOnceManager, TimeSpan openTimeout, обратный вызов AsyncCallback, состояние объекта, Func3 beginOperation, EndOperation1 endOperation) в Microsoft.ServiceBus.Messaging.OpenOnceManager.Begin (обратный вызов AsyncCallback, состояние объекта, Func3 beginOperation, Action1 endOperation. BeginSendEventData (TrackingContext trackingContext, IEnumerable1 eventDatas, тайм-аут TimeSpan, обратный вызов AsyncCallback, состояние объекта) в Microsoft.ServiceBus.Messaging.EventHubSender.> C__DisplayClass23_0.b__0 (AsyncCallback ‹‹MesplayClass23_0. beginMethod, Func2 endFunction, Action1 endAction, Состояние объекта, TaskCreationOptions creationOptions) в Microsoft.ServiceBus.Common.Parallel.TaskHelpers.CreateTask (Func3 begin, Action`1 end, Object state) --- Конец трассировки стека из предыдущего места, где исключение был брошен --- в System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess (задача задачи) в System.Runtime.Comp ilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification (задача задачи) в System.Runtime.CompilerServices.TaskAwaiter.GetResult () Дата: 4/12/2017 2:48:17 AM
Код: EventHubClient deveventHubClient = EventHubClient.CreateFromConnectionString (connectionString, «EventHubName»);
private async Task SendInBatch(IList<byte[]> source, Guid UUID)
{
List events = new List(source.Select(b => new EventData(b)));
EventHubSender Partition0;
EventHubSender Partition1;
Partition0 = deveventHubClient.CreatePartitionedSender("0");
Partition1 = deveventHubClient.CreatePartitionedSender("1");
if (UUID.GetHashCode() % 2 == 0)
{
await Partition0.SendBatchAsync(events);
}
else
{
await Partition1.SendBatchAsync(events);
}
return Unit.Default;
}