Запросы одновременной публикации Google PubSub - PullRequest
Новая
       11

Запросы одновременной публикации Google PubSub

0 голосов
/ 30 мая 2018

В Google PubSub вызов публикации от клиента может вызываться асинхронно.Из-за этого я думаю, что было бы возможно, чтобы несколько запросов на публикацию запускались и отправлялись на сервер одновременно, особенно если пороговые значения слишком малы.

Если это так, как клиент pubsub контролирует количество одновременных запросов на публикацию, которые могут быть созданы?Существует ли жесткое ограничение или ошибка, которая может возникнуть, если создано слишком много запросов?Является ли это предполагаемым использованием асинхронного издателя или просто для разрешения других неопубликованных действий?

Хотя этот вопрос относится к любому из клиентов, у нас, в частности, есть проблема с C #клиент, и периодически получаю следующую ошибку: 

 Grpc.Core.RpcException: Status(StatusCode=DeadlineExceeded, Detail="Deadline Exceeded")
 at System.Runtime.CompilerServices.TaskAwaiter.ThrowForNonSuccess(Task task)
 at System.Runtime.CompilerServices.TaskAwaiter.HandleNonSuccessAndDebuggerNotification(Task task)
 at Google.Api.Gax.Grpc.ApiCallRetryExtensions.<>c__DisplayClass0_0`2.<<WithRetry>b__0>d.MoveNext()
--- End of stack trace from previous location where exception was thrown ---

Я думаю, что мы отправляем слишком много запросов на публикацию ..., но я не уверен.

1 Ответ

0 голосов
/ 01 июня 2018

Я бы посоветовал использовать необработанный код gRPC, но используйте клиентскую библиотеку с очень тонкой оболочкой.

Просмотр исходного кода клиента всегда мне помогает, вы можете найти код на c # здесь PublisherClient.cs (тонкая оболочка)

Если вы используете PublishAsync, он все равно ставит в очередь / пакетирует сообщения, поведение управляется настройками, которые вы задаете клиенту (см. PublisherServiceApiClient, чтобы узнать, как его настроить).Вы также можете контролировать количество клиентских подключений, которые используются для отправки очередей на клиенте.Я советую сначала поиграть с размером пакета, а затем с количеством соединений, пока вы не найдете подходящее место для своей пропускной способности.

...