https://stackoverflow.com/questions/67299012/multithreadedrendezvous-of-rpc-that-terminated-with-details-exception-iter
I am trying to create a bidirectional streaming service using gRPC.
### Proto definition
syntax = "proto3";
message Features {
int32 id = 1;
float sensor1 = 2 ;
float sensor2 = 3 ;
float sensor3 = 4 ;
float sensor4 = 5 ;
}
message Empty{}
service StreamDataBroker{
rpc StreamDataBroker(stream Empty) returns(stream Features);
}
### Server snippet
def StreamDataBroker(self, requests, context):
#csv_filename = "./dataset/sensors.csv"
response = msg.Features()
for request in requests:
print("server running")
total_rows = row_obj.init_count()
current_row = row_obj.current_row
row = row_obj.get_next_row(current_row)
response.id = row[0]
response.sensor1 = row[1]
response.sensor2 = row[2]
response.sensor3 = row[3]
response.sensor4 = row[4]
row_obj.current_row = row_obj.current_row + 1
yield response
### Client snippet
def send_request_stream(self):
request = empty_pb2.Empty()
responses = self.stub.StreamDataBroker(request)
for response in responses:
print(response)
When I try to run the client I get the following error
Traceback (most recent call last):
File "client.py", line 27, in <module>
main()
File "client.py", line 22, in main
client.send_request_stream()
File "client.py", line 17, in send_request_stream
for response in responses:
File
"/home/edge/.local/lib/python3.8/site-packages/grpc/_channel.py", line 426,
in __next__
return self._next()
File
"/home/edge/.local/lib/python3.8/site-packages/grpc/_channel.py", line 809,
in _next
raise self
grpc._channel._MultiThreadedRendezvous: <_MultiThreadedRendezvous of
RPC that terminated with:
status = StatusCode.UNKNOWN
details = "Exception iterating requests!"
debug_error_string = "None"
>
What is going wrong here and How do I handle iterating requests properly
[Source code][1]
I tried this [solution][2] bud did not work for me.
[1]: https://github.com/ipa-rar/gRPC-ws/tree/main/data_broker_stream
[2]: https://github.com/grpc/grpc/issues/13544
--
You received this message because you are subscribed to the Google Groups
"grpc.io" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To view this discussion on the web visit
https://groups.google.com/d/msgid/grpc-io/e27108fd-c73f-47c1-bd74-31e159e73d6en%40googlegroups.com.
