From 9c6f36c605668d75543a3dc48cde0407616c09ed Mon Sep 17 00:00:00 2001 From: Dan Sanche Date: Thu, 14 Jun 2018 12:45:44 -0700 Subject: [PATCH] added implementation of server --- .../recommendation_server.py | 26 ++++++++++++++++++- 1 file changed, 25 insertions(+), 1 deletion(-) diff --git a/src/recommendationservice/recommendation_server.py b/src/recommendationservice/recommendation_server.py index 3734010..7007604 100644 --- a/src/recommendationservice/recommendation_server.py +++ b/src/recommendationservice/recommendation_server.py @@ -1,5 +1,29 @@ import grpc import demo_pb2 import demo_pb2_grpc +from concurrent import futures +import time -print("Hello World") +class RecommendationService(demo_pb2_grpc.RecommendationServiceServicer): + def ListRecommendations(self, request, context): + response = demo_pb2.ListRecommendationsResponse() + return response + +if __name__ == "__main__": + # create gRPC server + server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) + + # add class to gRPC server + demo_pb2_grpc.add_RecommendationServiceServicer_to_server(RecommendationService(), server) + + # start server + print("Listening on port 8080") + server.add_insecure_port('[::]:8080') + server.start() + + # keep alive + try: + while True: + time.sleep(86400) + except KeyboardInterrupt: + server.stop(0)