diff --git a/src/emailservice/Dockerfile b/src/emailservice/Dockerfile index 26be3de..80224ad 100644 --- a/src/emailservice/Dockerfile +++ b/src/emailservice/Dockerfile @@ -50,4 +50,4 @@ COPY --from=builder /usr/local/lib/python3.7/ /usr/local/lib/python3.7/ # Add the application COPY . . EXPOSE 8080 -ENTRYPOINT [ "ddtrace-run", "python", "email_server.py" ] +ENTRYPOINT [ "python", "email_server.py" ] diff --git a/src/emailservice/email_client.py b/src/emailservice/email_client.py index c31f4ef..7101512 100644 --- a/src/emailservice/email_client.py +++ b/src/emailservice/email_client.py @@ -25,6 +25,9 @@ logger = getJSONLogger('emailservice-client') from opencensus.trace.tracer import Tracer from opencensus.trace.exporters import stackdriver_exporter from opencensus.trace.ext.grpc import client_interceptor +from ddtrace import patch_all +patch_all() +from ddtrace import tracer try: exporter = stackdriver_exporter.StackdriverExporter() @@ -33,6 +36,7 @@ try: except: tracer_interceptor = client_interceptor.OpenCensusClientInterceptor() +@tracer.wrap('send_confirmation_email', service='emailservice') def send_confirmation_email(email, order): channel = grpc.insecure_channel('0.0.0.0:8080') channel = grpc.intercept_channel(channel, tracer_interceptor) diff --git a/src/emailservice/email_server.py b/src/emailservice/email_server.py index 9380ebb..ee5fc71 100644 --- a/src/emailservice/email_server.py +++ b/src/emailservice/email_server.py @@ -38,6 +38,10 @@ from opencensus.trace.samplers import always_on # import googleclouddebugger import googlecloudprofiler +from ddtrace import patch_all +patch_all() +from ddtrace import tracer + from logger import getJSONLogger logger = getJSONLogger('emailservice-server') @@ -118,6 +122,7 @@ class HealthCheck(): return health_pb2.HealthCheckResponse( status=health_pb2.HealthCheckResponse.SERVING) +@tracer.wrap('start', service='emailservice') def start(dummy_mode): server = grpc.server(futures.ThreadPoolExecutor(max_workers=10), interceptors=(tracer_interceptor,)) diff --git a/src/recommendationservice/recommendation_server.py b/src/recommendationservice/recommendation_server.py index 1219555..67d598a 100644 --- a/src/recommendationservice/recommendation_server.py +++ b/src/recommendationservice/recommendation_server.py @@ -38,6 +38,9 @@ from grpc_health.v1 import health_pb2_grpc from logger import getJSONLogger logger = getJSONLogger('recommendationservice-server') +from ddtrace import patch_all +patch_all() + def initStackdriverProfiling(): project_id = None try: