vbatts/microservices-demo
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Adds explicit PROJECT_ID for stackdriver exporter

Browse source
This commit is contained in:
Megan O'Keefe 2019-12-15 17:28:49 -05:00
parent 61dd04992b
commit 8d063632f4
2 changed files with 8 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/emailservice/email_server.py
View file

@ -37,6 +37,9 @@ import googlecloudprofiler
try: try:
sampler = always_on.AlwaysOnSampler() sampler = always_on.AlwaysOnSampler()
exporter = stackdriver_exporter.StackdriverExporter(
project_id=os.environ.get('GCP_PROJECT_ID'),
transport=AsyncTransport)
exporter = stackdriver_exporter.StackdriverExporter() exporter = stackdriver_exporter.StackdriverExporter()
tracer_interceptor = server_interceptor.OpenCensusServerInterceptor(sampler, exporter) tracer_interceptor = server_interceptor.OpenCensusServerInterceptor(sampler, exporter)
except: except:

7
src/recommendationservice/recommendation_server.py
View file

@ -99,7 +99,9 @@ if __name__ == "__main__":
try: try:
sampler = always_on.AlwaysOnSampler() 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) tracer_interceptor = server_interceptor.OpenCensusServerInterceptor(sampler, exporter)
except: except:
tracer_interceptor = server_interceptor.OpenCensusServerInterceptor() tracer_interceptor = server_interceptor.OpenCensusServerInterceptor()
@ -123,7 +125,8 @@ if __name__ == "__main__":
product_catalog_stub = demo_pb2_grpc.ProductCatalogServiceStub(channel) product_catalog_stub = demo_pb2_grpc.ProductCatalogServiceStub(channel)
# create gRPC server # 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 # add class to gRPC server
service = RecommendationService() service = RecommendationService()