opensource/opentelemetry-python-contrib
1
0
Fork 0
mirror of https://github.com/open-telemetry/opentelemetry-python-contrib.git synced 2025-08-01 17:34:38 +08:00
Code Issues Packages Projects Releases Wiki Activity

gRPC client instrumentation docs fixes (#245)

Browse Source
This commit is contained in:
Michael Stella
2020-12-11 13:18:16 -05:00
committed by GitHub
parent 11a06db3d5
commit be463c548a
1 changed files with 14 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
instrumentation/opentelemetry-instrumentation-grpc/src/opentelemetry/instrumentation/grpc/__init__.py
View File

@ -26,7 +26,7 @@ Usage Client
import grpc import grpc
from opentelemetry import trace from opentelemetry import trace
from opentelemetry.instrumentation.grpc import GrpcInstrumentorClient, client_interceptor from opentelemetry.instrumentation.grpc import GrpcInstrumentorClient
from opentelemetry.sdk.trace import TracerProvider from opentelemetry.sdk.trace import TracerProvider
from opentelemetry.sdk.trace.export import ( from opentelemetry.sdk.trace.export import (
ConsoleSpanExporter, ConsoleSpanExporter,
@ -51,8 +51,9 @@ Usage Client
metrics.set_meter_provider(MeterProvider()) metrics.set_meter_provider(MeterProvider())
# Optional - export GRPC specific metrics (latency, bytes in/out, errors) by passing an exporter # Optional - export GRPC specific metrics (latency, bytes in/out, errors) by passing an exporter
instrumentor = GrpcInstrumentorClient(exporter=ConsoleMetricsExporter(), interval=10) instrumentor = GrpcInstrumentorClient().instrument(
instrumentor.instrument() exporter = ConsoleMetricsExporter(),
interval = 10)
def run(): def run():
with grpc.insecure_channel("localhost:50051") as channel: with grpc.insecure_channel("localhost:50051") as channel:
@ -175,6 +176,16 @@ class GrpcInstrumentorServer(BaseInstrumentor):
class GrpcInstrumentorClient(BaseInstrumentor): class GrpcInstrumentorClient(BaseInstrumentor):
"""
Globally instrument the grpc client
Usage::
grpc_client_instrumentor = GrpcInstrumentorClient()
grpc.client_instrumentor.instrument()
"""
def _instrument(self, **kwargs): def _instrument(self, **kwargs):
exporter = kwargs.get("exporter", None) exporter = kwargs.get("exporter", None)
interval = kwargs.get("interval", 30) interval = kwargs.get("interval", 30)