Questions tagged [grpc]

0

votes
0

answer
4

Views

Build grpc in qT for iOS / Android Targets from Mac

I am having undefined errors when attempting to build qt app in Xcode for iOS target. Errors are lib issues with arm64 and undfined grpc methods. I added the protobuf 3.7.1 lib root project folder and referenced in pro file. Also, added grpc 1.20 cpp libs. Now I am not sure if my cross platform com...
Jon
1

votes
2

answer
100

Views

Rust protobuf serialization is all messed up

I am using rust-protobuf version 2.4 I have following code let mut msg = vec![]; let mut str = protobuf::CodedOutputStream::vec(&mut msg); let mut rmsg = user_manager::user::user_data::new(); rmsg.set_id('1234'.into()); rmsg.set_nick('test'.into()); str.write_message(1, &rmsg).unwrap(); str.flush()....
nikoss
0

votes
0

answer
4

Views

Container always reach same backend on replicated services

I'm deploying a 3 tier application using docker swarm, similar to: --> BACK01-01 -- --> BACK02-01 | | | FRONTEND-01 ----------------> BACK01-02 --------> BACK02-02 | | | --> BACK01-03 -- --> BACK02-03 Frontend Back Service 01 Back Service 0...
Jose Truyol
1

votes
0

answer
216

Views

Integrate GRPC server with Rails codebase

When the Google::Protobuf::DescriptorPool.generated_pool.build is called twice with the same message types, the error is being thrown saying that DescriptorPool has already registered message with the same name. Unable to add defs to DescriptorPool: Symtab already has a def named I see that as expec...
Marko Bogdanović
1

votes
0

answer
344

Views

Grpc channel not closing cleanly with ShutdownAsync

I'd like to close my form app cleanly while a grpc call may be ongoing. I figured ShutdownAsync would close any ongoing calls but it seems like I'm either not putting it in the right place or it is not responsible for closing channels. What's the easiest way to do a catch-all, end all streams with C...
Nils Guillermin
1

votes
1

answer
237

Views

Tensorflow Serving Client Script Hangs At stub.predict.future()

This is my first time asking a question here so I will try to be descriptive. I am relatively new to python and tensorflow, and have been learning it specifically for a project. I am currently working to deploy a tensorflow model using tensorflow serving and flask with wsgi. I have been following th...
RTri
1

votes
0

answer
313

Views

Always get UNKNOWN status code for failed gRPCs to python server

my data.proto likes this: syntax = 'proto3'; package rpc; service Performer { rpc carryOut(Image) returns (Objects){} } message Objects{ repeated Object objects=1; } message Object{ string type=1; } and implementation like this: class Performer(data_pb2_grpc.PerformerServicer): def __init__(self): p...
Alex Luya
1

votes
0

answer
287

Views

How can GRPC interceptors extract data from message and pass to each other?

I have 2 GRPC interceptors: #1 extracts some data from the message #2 validates the data and closes call with error if invalid How can interceptor #1 extract some data from the message, put it into Context and call interceptor #2 (using Contexts.interceptCall(context, call, headers, next) with modif...
4ntoine
1

votes
1

answer
51

Views

Inferencing with Tensorflow Serving using Java

We are transitioning an existing Java production code to use Tensorflow Serving (TFS) for inferencing. We have already retrained our models and saved them using the new SavedModel format (no more frozen graphs!!). From the documentation that I have read, TFS does not directly support Java. However...
Hephaestus
1

votes
0

answer
558

Views

Python protobuf gRPC generate all dependencies

I'm trying to create gRPC binding for my python code via: python -m grpc_tools.protoc -I $(pwd)/protos --python_out=./fino/pb2 --grpc_python_out=./fino/pb2 -I=$GOPATH/src -I=$GOPATH/src/github.com/gogo/protobuf/protobuf $(pwd)/protos/* But the generated file has unexistent dependency: from github.co...
lpp
1

votes
0

answer
627

Views

How to set up server side TLS in gRPC java

I have gone through https://github.com/grpc/grpc-java/blob/master/SECURITY.md, this PR https://github.com/grpc/grpc-java/pull/3992 and TlsTest in gRPC java. However, I am getting Feb 13, 2018 8:44:53 AM io.grpc.netty.NettyServerTransport notifyTerminated INFO: Transport failed io.netty.handler.code...
user2237511
1

votes
0

answer
231

Views

golang gRPC update image in docker swarm having to reconnect clients each time

I have a docker swarm on three nodes plus an external mysql service (outside of the swarm). I am programming micro-services with an API Gateway in golang and gRPC. I have two problems. The first problem is when I push an update a service with docker swarm update --image ... myservice I get the erro...
Varcorb
1

votes
0

answer
86

Views

How do I verify send/recv op tensor values?

I'm using a parameter server and a worker. I would like to see tensor exchanges between the parameter server and the worker. I'd like to view the tensor values in send/recv nodes. Is there any logging that I can enable to view send/recv tensor values? If not, where in TensorFlow should I make modifi...
sfv
1

votes
0

answer
138

Views

Chatbot customizing a reply message by gRPC

I am creating chatbots with DialogFlow, in the enterprise version a new form of communication between my server and the DialogFlow server, gRPC (grpc.io) was added, thus eliminating HTTP / Restful. However as far as I understand the documentation, I still need to use HTTP / Restful to receive the us...
Luís De Marchi
1

votes
0

answer
208

Views

GRPC Java tutorial. Unable to generate source code within one package using protobuf-maven-plugin

I am new to GRPC, I am following this guide https://grpc.io/docs/tutorials/basic/java.html I have cloned the project from GITHUB And I am trying to build the project by running mvn clean install The build file succeeds: I can see it build all source files, the artifact is being produced and even so...
Ihor M.
1

votes
0

answer
902

Views

Tensorflow with verbs support

When TensorFlow is built with verbs support, I believe there are only two ways to exercise distributed learning: gRPC + verbs protocol Horovod Do we always need to use IPoIB when exercising gRPC + verbs protocol? Or can TF somehow understand the IB adapter on the system and route the traffic accordi...
antoajayraj
1

votes
1

answer
204

Views

Building protobuf for Linux using VS2017

I have configured VS2017 to build Linux C++ by remote building on a Linux Mint VM. I tried a simple C++ program and it compiles and executes fine, the thing is that now I need to add a generated protobuf source and the linking fails constantly. On the Linux VM the protobuf generated files are buildi...
SGarofalo808
1

votes
1

answer
450

Views

How are the requests handled in GRPC?

Lets say that my given GRPC endpoint has the following implementation type HandlerFunc func(ctx context.Context, in *pb.Request) (*pb.Response, error) func newHandler() HandlerFunc { func (s *Server) Process(ctx context.Context, in *pb.Request) (*pb.Response, error) { //do processing } } type Server...
rajan sthapit
1

votes
1

answer
379

Views

Tensorboard Interactive Debugger Not Connecting

I am running the latest version of tensorflow (1.7.0) in Windows. It added a new feature for debugging in tensorboard. However, I am not able to get it to connect. I was previously using the LocalCLIDebugWrapperSession debugger. However, I wanted to play with the new features in TensorBoardDebugWrap...
user768600
1

votes
0

answer
177

Views

how to setup nginx not to crash if grpc server`s hostname in upstream is not found

nginx version: 1.13.10 Config looks like this: events { multi_accept on; worker_connections 16384; use epoll; } http { log_format main '$remote_addr - $remote_user [$time_local] '$request' ' '$status $body_bytes_sent '$http_referer' ' ''$http_user_agent''; server { listen 8...
RODNEY ZHANG
1

votes
1

answer
1.2k

Views

Unmarshal custom types with jsonpb

What's the best way to convert this json object to protobuf? JSON: { 'name': 'test', '_list': { 'some1': { 'value': 1 }, 'some2': [ { 'value': 2 }, { 'value': 3 }, ] } } Proto: message Something { string name = 1; message ListType { repeated string = 1; } map _list = 2; } Without having the _list in...
user2502761
1

votes
0

answer
57

Views

How to structure a key-based search gRPC call with protobuf

a question about gRPC with protobuf. I'm essentially building a set of microservices and we use gRPC and protocol buffer version 3, language used is Go. Everything works well in most of the cases, however we have some rpc functions planned which should perform a search based on a set of keys. The is...
Delio
1

votes
1

answer
160

Views

gRPC with Node.js, retry mechanism?

I am building a gRPC client in Node.js. I want my failing calls to be executed a few more times before giving up. I cannot find anything about this in the documentation, although there seems to be something similar but for the Go package. Do you have any idea how to achieve this? If not possible wit...
lucavallin
1

votes
0

answer
229

Views

tensorflow serving client does not work(grpc.framework.interfaces.face.face.AbortionError: AbortionError)

I'm deploying a text matching tensorflow program on docker referring to the official website, the installation steps and the test steps are all OK, including the server running status as well as OK, but client has a problem. Let me explain it in detail. This is my model graph with four inputs: T...
YJ. Yang
1

votes
1

answer
608

Views

Multiple stubs on a managed channel in grpc?

While reading through the Java documentation on the grpc website, I found the newBlockingStub and newStub generated methods being referenced. My main interest in grpc is to use a single connection to handle multiple rpcs in parallel. By making multiple calls to newBlockingStub/newStub, do I get all...
RajP
1

votes
0

answer
219

Views

Python: google-cloud-datastore in AWS Lambda

Because Google Functions does not support Python, I was hoping to use google-cloud-datastore in AWS Lambda but hit the same error as AWS Lambda to Firestore error: cannot import name 'cygrpc' google-cloud-storage works just fine in Lambda so core packaging is not the issue but could pip'ing datasto...
1

votes
1

answer
860

Views

Represent a protobuf map as a json

I'm using grpcc, which is based on protobuf.js, to test my grpc service APIs. My .proto file: message MyRequest { string userId = 1; map params = 2; } I tried the following json body to send a request: {userId : 'my_user_id' , params: { name: 'my_name'}} {userId : 'my_user_id' , params: [{'name':'my...
Maddy
1

votes
1

answer
253

Views

Can Google App Engine Standard environment connect to a GRPC service?

I have an application with a front-end running in App Engine Standard written in python. I want it to connect to a GRPC middleware service. In other words, this is what I want to do: [ Client ] --(http)--> [ App Engine Std ] --(grpc)--> [ Middleware ] I know App Engine has a lot of restrictions for...
Xocoatzin
1

votes
1

answer
331

Views

Strategies for calling grpc service from a webapi in .net Core

I have a rest/web API in .Net Core that I am using as an aggregation service to call some underlying gRPC services also in .Net core. For the WEB API client, I am creating the channel once as a singleton on startup and injecting it where I need it using dependency injection. I am also thinking of...
evhfla
1

votes
1

answer
136

Views

npm install failing with node-pre-grp and node-grp

Problem: whenever I run npm install firebase or realm --save I get this error : log more log then, after this, when I try to run the project with react-native run-android I get this : when I run react-native run-android I've tried reinstalling the node modules with npm install, I've cleared my npm...
1

votes
0

answer
1.3k

Views

Getting Unimplemented desc = unknown service error gRPC

In one of my services that happens to be my loadbalancer, I am getting the following error when calling the server method in one of my deployed services: rpc error: code = Unimplemented desc = unknown service fooService.FooService I have a few other services set up with gRPC and they work fine. It j...
MATT SHALLOW
1

votes
0

answer
165

Views

How implament fieldMask in python grpc updating request?

I have not understood completely how protobuf FieldMask works in grpc request, I've created this message from client, but I do not know how to receive and show the values in the server site. Client.py fm = FieldMask( paths=[ 'f.a', 'f2.a' ]) msg = proto_pb2.Message( f=proto_pb2.F(a=a_value), f2=prot...
Jhon Tovar
1

votes
1

answer
305

Views

Unit and e2e testing a grpc microservice

Hi everyone I'm creating a grpc microservice using the nestjs framework. Can anyone give me some advice on how I would test my grpc microservice (unit and e2e).
1

votes
1

answer
174

Views

GRPC how to reuse client connection?

// ServiceA - proto const proto = grpc.load({ root: protoDir, file: 'serviceA.proto' }); // ServiceB - proto const proto = grpc.load({ root: protoDir, file: 'serviceB.proto' }); let clientA = new ddl_proto.com.mypackage.serviceA(common_url, grpc.credentials.createInsecure()); clientA.functionOne({ o...
Akhil Thayyil
1

votes
2

answer
306

Views

Can't deploy a bna to an existing Hyperledger Fabric installation

I'm trying to deploy my BNA (developed on my dev machine) to an existing Hyperledger Fabric installation. The Fabric was installed by another dev whom I'm unable to contact. I am able to fire up the Playground and see another deployed network, but I'm unable to deploy my own: $ composer network inst...
ulu
1

votes
1

answer
91

Views

User specific routing in Istio / Kuberentes

I'm wondering if Istio is a good tool to support a particular routing situation, and if not (or even if it is), what other approaches are available. I have two microservices, X and Y, with have some number of replicas for each. X sends requests to Y. X sends requests as a particular user, say 'bob'....
David Terei
1

votes
1

answer
30

Views

Building grpc fails

i try to buld grpc my java java -version openjdk version '1.8.0_144' OpenJDK Runtime Environment (IcedTea 3.5.1) (suse-10.15.2-x86_64) OpenJDK 64-Bit Server VM (build 25.144-b01, mixed mode) start build : ./gradlew build *** Skipping the build of codegen and compilation of proto files because skip...
susanne
1

votes
0

answer
151

Views

DelegatingHandler SendAsync issue

We are overriding the SendAsync method on the System.Net.Http.DelegatingHandler in order to run some custom logic: protected override async Task SendAsync(HttpRequestMessage request, CancellationToken cancellationToken) { //logic block 1 var response = await base.SendAsync(request, cancellationToken...
ec256
1

votes
1

answer
500

Views

Serialization failure (grpc/node)

I am attempting to follow the static codegen example as found here, for the node/grpc example. I'm using my own protofiles, but the rest of the code should look familiar. 'use strict'...
Zack
1

votes
1

answer
79

Views

How do I create a rest API to read a text or any file in go lang using gRPC?

I am trying to create a REST API in go programming language, to read the text file. I want to build it using gRPC.
shoaib

View additional questions