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