Chiebot-Mirror
/
grpc
mirror of https://github.com/grpc/grpc.git
8
0
Fork 0
Code Issues Projects Releases Wiki Activity
The C based gRPC (C++, Python, Ruby, Objective-C, PHP, C#) https://grpc.io/
You can not select more than 25 topics Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
55219 Commits
276 Branches
378 Tags
1.2 GiB
 
 
 
 
 
 
Tag: Branch: Tree: ab3943e828
Branches Tags
${ item.name }
Create tag ${ searchTerm }
Create branch ${ searchTerm }
from 'ab3943e828'
${ noResults }
grpc/examples/python/async_streaming
Sergii Tkachenko de6ed9ba9f
[Python] Migrate from yapf to black (#33138) 		2 years ago
..
README.md Add async bidi-streaming example 4 years ago
client.py [Python] Migrate from yapf to black (#33138) 2 years ago
phone.proto Add async bidi-streaming example 4 years ago
phone_pb2.py Update third_party/protobuf to 3.21.4 (#30377) 2 years ago
phone_pb2.pyi Update third_party/protobuf to 3.21.4 (#30377) 2 years ago
phone_pb2_grpc.py Update third_party/protobuf to 3.21.4 (#30377) 2 years ago
server.py [Python] Migrate from yapf to black (#33138) 2 years ago

README.md

gRPC Python Non-Blocking Streaming RPC Client Example

The goal of this example is to demonstrate how to handle streaming responses without blocking the current thread. Effectively, this can be achieved by converting the gRPC Python streaming API into callback-based.

In this example, the RPC service Phone simulates the life cycle of virtual phone calls. It requires one thread to handle the phone-call session state changes, and another thread to process the audio stream. In this case, the normal blocking style API could not fulfill the need easily. Hence, we should asynchronously execute the streaming RPC.

Steps to run this example

Start the server in one session

python3 server.py

Start the client in another session

python3 client.py

Example Output

$ python3 server.py
INFO:root:Server serving at [::]:50051
INFO:root:Received a phone call request for number [1415926535]
INFO:root:Created a call session [{
  "sessionId": "0",
  "media": "https://link.to.audio.resources"
}]
INFO:root:Call finished [1415926535]
INFO:root:Call session cleaned [{
  "sessionId": "0",
  "media": "https://link.to.audio.resources"
}]

$ python3 client.py
INFO:root:Waiting for peer to connect [1415926535]...
INFO:root:Call toward [1415926535] enters [NEW] state
INFO:root:Call toward [1415926535] enters [ACTIVE] state
INFO:root:Consuming audio resource [https://link.to.audio.resources]
INFO:root:Call toward [1415926535] enters [ENDED] state
INFO:root:Audio session finished [https://link.to.audio.resources]
INFO:root:Call finished!