| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152 | # Copyright 2018 The 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 reflection-enabled version of gRPC helloworld.Greeter server."""from concurrent import futuresimport timeimport grpcfrom grpc_reflection.v1alpha import reflectionimport helloworld_pb2import helloworld_pb2_grpc_ONE_DAY_IN_SECONDS = 60 * 60 * 24class Greeter(helloworld_pb2_grpc.GreeterServicer):    def SayHello(self, request, context):        return helloworld_pb2.HelloReply(message='Hello, %s!' % request.name)def serve():    server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))    helloworld_pb2_grpc.add_GreeterServicer_to_server(Greeter(), server)    SERVICE_NAMES = (        helloworld_pb2.DESCRIPTOR.services_by_name['Greeter'].full_name,        reflection.SERVICE_NAME,    )    reflection.enable_server_reflection(SERVICE_NAMES, server)    server.add_insecure_port('[::]:50051')    server.start()    try:        while True:            time.sleep(_ONE_DAY_IN_SECONDS)    except KeyboardInterrupt:        server.stop(0)if __name__ == '__main__':    serve()
 |