SpróbujRpc

Wykonuj partie żądań RPC.

Ta operacja asynchronicznie wykonuje pojedyncze żądanie RPC lub grupę żądań. Żądania RPC są definiowane przez trzy główne parametry:

- `adres` (host+port lub adres BNS żądania) - `method` (nazwa metody dla żądania) - `request` (serializowany ciąg proto lub wektor ciągów argumentu żądania RPC).

Na przykład, jeśli masz usługę RPC działającą na porcie localhost:2345, a jej interfejs jest skonfigurowany z następującą deklaracją proto:

service MyService {
   rpc MyMethod(MyRequestProto) returns (MyResponseProto) {
   
 };
 }

wywołaj tę operację z argumentami:

address = "localhost:2345"
 method = "MyService/MyMethod"
 

Tensor `żądania` jest tensorem łańcucha reprezentującym serializowane ciągi znaków `MyRequestProto`; a wynikowy tensor ciągu „odpowiedź” będzie miał ten sam kształt i będzie zawierał (po pomyślnym zakończeniu) odpowiednie serializowane ciągi „MyResponseProto”.

Na przykład, aby wysłać pojedyncze, puste `MyRequestProto`, wywołaj tę operację z `request = ""`. Aby wysłać 5 równoległych pustych żądań, wywołaj tę operację z `request = ["", "", "", "", ""]`.

Mówiąc bardziej ogólnie, można utworzyć partię serializowanych protosów `MyRequestProto` ze zwykłych tensorów wsadowych przy użyciu operacji `encode_proto` i przekonwertować serializowane proto odpowiedzi `MyResponseProto` na tensory wsadowe przy użyciu operacji `decode_proto`.

UWAGA Praca z serializowanymi ciągami proto jest szybsza niż tworzenie instancji rzeczywistych obiektów proto w pamięci, więc nie oczekuje się pogorszenia wydajności w porównaniu z pisaniem niestandardowych jąder dla tego przepływu pracy.

W przeciwieństwie do standardowej operacji `Rpc`, jeśli połączenie nie powiedzie się lub zdalny pracownik zwróci status błędu, ta operacja nie powoduje ponownego zgłoszenia wyjątku. Zamiast tego wpisy „kod_statusu” i „komunikat_statusu” dla odpowiedniego wywołania RPC są ustawiane z błędem zwracanym przez wywołanie RPC. Tensor „odpowiedzi” będzie zawierał prawidłowe wartości odpowiedzi dla tych wpisów minipartii, których wywołania RPC nie zawiodły; pozostałe wpisy będą miały puste ciągi.