Skip to content

Instantly share code, notes, and snippets.

@gaffer-93
Created June 27, 2018 09:48
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save gaffer-93/d8b9d5d392cc20cf3364b42be981f1f9 to your computer and use it in GitHub Desktop.
Save gaffer-93/d8b9d5d392cc20cf3364b42be981f1f9 to your computer and use it in GitHub Desktop.
greeter_client.py with timeouts
```
# Copyright 2015 gRPC authors.
#
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
"""The Python implementation of the GRPC helloworld.Greeter client."""
from __future__ import print_function
import grpc
import time
import logging
import helloworld_pb2
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.
channel = grpc.insecure_channel("my.host.com.:6106")
stub = helloworld_pb2_grpc.GreeterStub(channel)
while True:
msg = 'a'
logging.info('Sending HelloRequest: %s' % msg)
try:
response = stub.SayHello(helloworld_pb2.HelloRequest(name=msg), timeout=0.3)
except Exception:
logging.exception("GRPC TIMEOUT")
else:
logging.error("Resonse Recieved: %s" % response.message)
time.sleep(0.001)
if __name__ == '__main__':
run()
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment