У меня есть приложение, в котором данные извлекаются из базы данных SQL и отправляются на служебную шину в качестве брокера. Эти шаги:Отправка 1000 брокерских сообщений на служебную шину с использованием метода SendBatchAsync
- данных извлекается из БД (в партиях от 1000)
- Каждая строка данных преобразуется в Brokered сообщение и добавили в список.
- Список 1000 брокерских сообщений отправляется на служебную шину с использованием метода SendBatchAsync.
На третьем этапе я столкнулся с проблемой. Это код, который:
public async Task SendMessagesAsync(List<BrokeredMessage> brokeredMessageList)
{
try
{
var topicClient = CreateTopicClient();
await topicClient.SendBatchAsync(brokeredMessageList);
}
catch(Exception ex)
{
throw ex;
}
}
когда компилятор приходит к методу SendBatchAsync, он выдает ошибку, что Ошибка при обмене данными с Service Bus. Проверьте информацию о подключении и повторите попытку. с внутренним исключением являются:
Internal Server Error: The server did not provide a meaningful reply; this might be caused by a premature session shutdown. TrackingId:some guid here
Однако при попытке отправки 100 сообщений, он отлично работает. Что я могу сделать, чтобы отправить 1000 сообщений за раз?
Примечание: каждый размер сообщения 1445 байты
Да кажется так ... Спасибо за разъяснение. – nitinvertigo