RPC

публичный финальный класс Rpc

Выполнение пакетов запросов RPC.

Эта операция асинхронно выполняет либо один запрос RPC, либо пакет запросов. Запросы RPC определяются тремя основными параметрами:

- "адрес" (хост+порт или адрес BNS запроса) - "метод" (имя метода RPC для запроса) - "запрос" (сериализованная прото-строка или вектор строк аргумента запроса RPC) .

Например, если у вас есть служба RPC, работающая на порту localhost:2345, и ее интерфейс настроен со следующим объявлением прототипа:

service MyService {
   rpc MyMethod(MyRequestProto) returns (MyResponseProto) {
   
 };
 }
, тогда вызовите эту операцию с аргументами:
address = "localhost:2345"
 method = "MyService/MyMethod"
 
Тензор `request` — это строковый тензор, представляющий сериализованные строки MyRequestProto; и тензор выходной строки `response` будет иметь ту же форму и содержать (после успешного завершения) соответствующие сериализованные строки `MyResponseProto`.

Например, чтобы отправить один пустой `MyRequestProto`, вызовите эту операцию с `request = ""`. Чтобы отправить 5 параллельных пустых запросов, вызовите эту операцию с `request = ["", "", "", "", ""]`.

В более общем смысле, можно создать пакет сериализованных прототипов MyRequestProto из обычных пакетных тензоров с помощью операции encode_proto и преобразовать сериализованные прототипы ответа MyResponseProto в пакетные тензоры с помощью операции decode_proto.

ПРИМЕЧАНИЕ. Работа с сериализованными строками прототипов выполняется быстрее, чем создание экземпляров реальных объектов прототипов в памяти, поэтому не ожидается снижения производительности по сравнению с написанием собственных ядер для этого рабочего процесса.

Если соединение не удается или удаленный работник возвращает статус ошибки, операция повторно вызывает это исключение локально.

См. операцию TryRpc, если вы предпочитаете обрабатывать сбои RPC вручную на графике.

Вложенные классы

сорт Rpc.Параметры Дополнительные атрибуты для Rpc

Публичные методы

Вывод <Строка>
какВывод ()
Возвращает символический дескриптор тензора.
статический RPC
create ( Область действия , адрес операнда <String>, метод операнда <String>, запрос операнда <String>, параметры... параметры)
Фабричный метод для создания класса, обертывающего новую операцию Rpc.
статический Rpc.Options
FailFast (логическое значение FailFast)
статический Rpc.Options
протокол (строковый протокол)
Вывод <Строка>
ответ ()
Та же форма, что и «запрос».
статический Rpc.Options
timeoutInMs (Длинный таймаутInMs)

Унаследованные методы

Публичные методы

общедоступный вывод <String> asOutput ()

Возвращает символический дескриптор тензора.

Входные данные для операций TensorFlow являются выходными данными другой операции TensorFlow. Этот метод используется для получения символического дескриптора, который представляет собой вычисление входных данных.

public static Rpc create (область действия , адрес операнда <String>, метод операнда <String>, запрос операнда <String>, параметры... параметры)

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

Параметры
объем текущий объем
адрес `0-D` или `1-D`. Адрес (т. е. имя_хоста:порт) сервера RPC. Если этот тензор имеет более 1 элемента, то отправляется несколько параллельных запросов RPC. Этот аргумент передается с помощью `method` и `request`.
метод `0-D` или `1-D`. Адрес метода на сервере RPC. Если этот тензор имеет более 1 элемента, то отправляется несколько параллельных запросов RPC. Этот аргумент передается с адресом и запросом.
запрос `0-D` или `1-D`. Сериализованные строки прототипа: аргумент запроса rpc. Если этот тензор имеет более 1 элемента, то отправляется несколько параллельных запросов RPC. Этот аргумент передается с адресом и методом.
параметры содержит значения необязательных атрибутов
Возврат
  • новый экземпляр Rpc

общедоступный статический Rpc.Options FailFast (логическое значение FailFast)

Параметры
неудачный быстрый `логическое`. Если true (по умолчанию), то сбои подключения (т. е. сервер не отвечает немедленно) приводят к сбою RPC.

общедоступный статический протокол Rpc.Options (строковый протокол)

Параметры
протокол Используемый протокол RPC. Пустая строка означает использование протокола по умолчанию. Опции включают «grpc».

ответ public Output <String> ()

Та же форма, что и «запрос». Сериализованные прото-строки: ответы RPC.

общедоступный статический Rpc.Options timeoutInMs (Long timeoutInMs)

Параметры
таймаутИнМс `инт`. Если `0` (по умолчанию), ядро ​​выполнит запрос RPC и истечет по времени только в том случае, если истекает крайний срок RPC или истекает время сеанса. Если это значение больше «0», то операция вызовет исключение, если RPC займет больше времени, чем «timeout_in_ms».