From 8d063632f4507f6d5a222137b36cadc0fbca748e Mon Sep 17 00:00:00 2001 From: Megan O'Keefe Date: Sun, 15 Dec 2019 17:28:49 -0500 Subject: [PATCH] Adds explicit PROJECT_ID for stackdriver exporter --- src/emailservice/email_server.py | 3 +++ src/recommendationservice/recommendation_server.py | 7 +++++-- 2 files changed, 8 insertions(+), 2 deletions(-) diff --git a/src/emailservice/email_server.py b/src/emailservice/email_server.py index 5af5ff9..4dd8dbb 100644 --- a/src/emailservice/email_server.py +++ b/src/emailservice/email_server.py @@ -37,6 +37,9 @@ import googlecloudprofiler try: sampler = always_on.AlwaysOnSampler() + exporter = stackdriver_exporter.StackdriverExporter( + project_id=os.environ.get('GCP_PROJECT_ID'), + transport=AsyncTransport) exporter = stackdriver_exporter.StackdriverExporter() tracer_interceptor = server_interceptor.OpenCensusServerInterceptor(sampler, exporter) except: diff --git a/src/recommendationservice/recommendation_server.py b/src/recommendationservice/recommendation_server.py index 357f25f..c4e8fe6 100644 --- a/src/recommendationservice/recommendation_server.py +++ b/src/recommendationservice/recommendation_server.py @@ -99,7 +99,9 @@ if __name__ == "__main__": try: sampler = always_on.AlwaysOnSampler() - exporter = stackdriver_exporter.StackdriverExporter() + exporter = stackdriver_exporter.StackdriverExporter( + project_id=os.environ.get('GCP_PROJECT_ID'), + transport=AsyncTransport) tracer_interceptor = server_interceptor.OpenCensusServerInterceptor(sampler, exporter) except: tracer_interceptor = server_interceptor.OpenCensusServerInterceptor() @@ -123,7 +125,8 @@ if __name__ == "__main__": product_catalog_stub = demo_pb2_grpc.ProductCatalogServiceStub(channel) # create gRPC server - server = grpc.server(futures.ThreadPoolExecutor(max_workers=10)) # ,interceptors=(tracer_interceptor,)) + server = grpc.server(futures.ThreadPoolExecutor(max_workers=10), + interceptors=(tracer_interceptor,)) # add class to gRPC server service = RecommendationService()