diff options
author | Youngchan Kim <ovekyc@gmail.com> | 2018-10-19 11:05:02 +0900 |
---|---|---|
committer | Youngchan Kim <ovekyc@gmail.com> | 2018-10-23 13:45:25 +0900 |
commit | 0a925095be72a6d0af16053e34820c8c1a4f084a (patch) | |
tree | cadf214b21aad3158e98f7ad3013b8d5e825a5e9 /examples | |
parent | cf09d16ca8c6852f39e9cc347e4d726a79d6c1cf (diff) |
Simplify example
Diffstat (limited to 'examples')
-rw-r--r-- | examples/python/helloworld/greeter_client_with_options.py | 34 |
1 files changed, 13 insertions, 21 deletions
diff --git a/examples/python/helloworld/greeter_client_with_options.py b/examples/python/helloworld/greeter_client_with_options.py index 50c9346a59..b08dd6d6e1 100644 --- a/examples/python/helloworld/greeter_client_with_options.py +++ b/examples/python/helloworld/greeter_client_with_options.py @@ -22,28 +22,20 @@ import helloworld_pb2_grpc def run(): + # NOTE(gRPC Python Team): .close() is possible on a channel and should be + # used in circumstances in which the with statement does not fit the needs + # of the code. + # # For more channel options, please see https://grpc.io/grpc/core/group__grpc__arg__keys.html - channel = grpc.insecure_channel( - target='localhost:50051', - options=[('grpc.lb_policy_name', 'pick_first'), - ('grpc.enable_retries', 0), - ('grpc.keepalive_timeout_ms', 10), - ('grpc.max_receive_message_length', 12)]) - stub = helloworld_pb2_grpc.GreeterStub(channel) - - try: - # synchronous rpc call - stub.SayHello(helloworld_pb2.HelloRequest(name='you')) - except Exception as err: - print('Raised by max_receive_message_length option\n' + str(err)) - - try: - # asynchronous rpc call. timeout in second - future = stub.SayHello.future(helloworld_pb2.HelloRequest(name='me'), timeout=1) - response = future.result() - print("Greeter client received: " + response.message) - finally: - channel.close() + with grpc.insecure_channel( + target='localhost:50051', + options=[('grpc.lb_policy_name', 'pick_first'), + ('grpc.enable_retries', 0), + ('grpc.keepalive_timeout_ms', 10)]) as channel: + stub = helloworld_pb2_grpc.GreeterStub(channel) + # timeout in second + response = stub.SayHello(helloworld_pb2.HelloRequest(name='you'), timeout=1) + print("Greeter client received: " + response.message) if __name__ == '__main__': |