OpenTelemetry Redis Instrumentation
Instrument redis to report Redis queries.
There are two options for instrumenting code. The first option is to use the
opentelemetry-instrument
executable which will automatically
instrument your Redis client. The second is to programmatically enable
instrumentation via the following code:
Usage
from opentelemetry.instrumentation.redis import RedisInstrumentor
import redis
# Instrument redis
RedisInstrumentor().instrument()
# This will report a span with the default settings
client = redis.StrictRedis(host="localhost", port=6379)
client.get("my-key")
Async Redis clients (i.e. redis.asyncio.Redis) are also instrumented in the same way:
from opentelemetry.instrumentation.redis import RedisInstrumentor
import redis.asyncio
# Instrument redis
RedisInstrumentor().instrument()
# This will report a span with the default settings
async def redis_get():
client = redis.asyncio.Redis(host="localhost", port=6379)
await client.get("my-key")
The instrument method accepts the following keyword args:
tracer_provider (TracerProvider) - an optional tracer provider
request_hook (Callable) - a function with extra user-defined logic to be performed before performing the request this function signature is: def request_hook(span: Span, instance: redis.connection.Connection, args, kwargs) -> None
response_hook (Callable) - a function with extra user-defined logic to be performed after performing the request this function signature is: def response_hook(span: Span, instance: redis.connection.Connection, response) -> None
for example:
API
- class opentelemetry.instrumentation.redis.RedisInstrumentor(*args, **kwargs)[source]
Bases:
BaseInstrumentor
An instrumentor for Redis See BaseInstrumentor
- instrumentation_dependencies()[source]
Return a list of python packages with versions that the will be instrumented.
The format should be the same as used in requirements.txt or pyproject.toml.
For example, if an instrumentation instruments requests 1.x, this method should look like: :rtype:
Collection
[str
]- def instrumentation_dependencies(self) -> Collection[str]:
return [‘requests ~= 1.0’]
This will ensure that the instrumentation will only be used when the specified library is present in the environment.