Я пытаюсь (безуспешно) использовать gRPC ( grpc.io ) с потоками. Что я хочу, чтобы после получения запроса масштабировать его до потока и отвечать через этот поток без «возвратной» части gRPC. Вот мой метод: def CriaItem(self, request,...

Я пытаюсь запустить Flask REST API и gRPC API внутри одного приложения и контейнера, и по какой-то причине сервер gRPC закрывается сразу после запуска. Итак, у меня есть простое приложение Flask, обслуживающее несколько конечных точек REST. У него...

Я пытаюсь написать клиент Python для прослушивания потока gRPC (пожарный шланг). Он постоянно продолжает течь. Нет никакого "по завершению". Прото: rpc Start (StartParameters) returns (stream Progress) {} В клиенте я попытался написать...

Я пытаюсь использовать gRPC для доступа к api домашнего графика Google . в этом руководстве я нашел пример того, как скомпилировать прототип файл, чтобы получить код Python, который может использоваться клиентом. Приведенный пример генерирует...

Я пытаюсь использовать следующий код на своем рабочем сервере (который я хочу масштабировать до более чем 500 TPS). Я столкнулся со следующей проблемой, когда завалил сервер множеством запросов. По крайней мере, в 1 запросе из 1000 запросов вызов...

Я использую gRPC в конечных точках Google CLoud . Я использую быстрый пример для Python для конечной точки Я добавляю одну функцию для SayHelloRepeated , но не знаю, как перекодировать повторяющееся поле. helloworld.proto service...

Предположим, у вас есть приложение, такое как книжный магазин, и вы разбили его на два простых микросервиса в серверной части - › Микросервис 1: Покупатели книг (с аккаунтами) Микросервис 2: Список книг. Допустим, вы делаете запрос из внешнего...

Как указать размер очереди rpc при использовании wait_for_ready в grpc-python

У меня есть экземпляр Debian GCP, на котором я пытаюсь запустить сервер Python gRPC. У моего экземпляра статический IP-адрес, и я пытаюсь установить безопасный канал между моим удаленным экземпляром (сервером) и локальным клиентом. Я создал...

Мы запускаем сервер модели Tensorflow на нашем собственном предприятии (он работает на Kubernetes за сервером Nginx и Kong API Gateway), и мне удалось запросить сервер для прогнозирования модели. Чтобы сделать запрос, я должен включить в заголовок...

Я разрабатываю некоторые тесты с датчиком и python, но при выполнении спецификаций я получаю ошибку соединения, я проверил ошибку датчика и обнаружил, что grpc открывает соединение на 65271, и выдается ошибка для порта 65268. Я что-то пропустил (это...

Есть ли способ запретить клиентам gRPC переключать используемый сетевой интерфейс? Я хочу, чтобы мой канал подключался через eth0 и сохранял это соединение, однако он пытается подключить канал через MACsec в тот момент, когда появляется новый...

Как ответ на вопрос: how-do-i-handle -streaming-messages-with-python-grpc , @Nathaniel предоставляет решение для обработки запросов и ответов. Но когда я хочу подсчитать время обработки каждого ответа, это выглядит неправильно. Например, я сплю...