rb.py 791 B

12345678910111213141516171819202122232425262728293031
  1. """
  2. Instrumentation for Redis Blaster (rb)
  3. https://github.com/getsentry/rb
  4. """
  5. from sentry_sdk.integrations.redis._sync_common import patch_redis_client
  6. from sentry_sdk.integrations.redis.modules.queries import _set_db_data
  7. def _patch_rb() -> None:
  8. try:
  9. import rb.clients # type: ignore
  10. except ImportError:
  11. pass
  12. else:
  13. patch_redis_client(
  14. rb.clients.FanoutClient,
  15. is_cluster=False,
  16. set_db_data_fn=_set_db_data,
  17. )
  18. patch_redis_client(
  19. rb.clients.MappingClient,
  20. is_cluster=False,
  21. set_db_data_fn=_set_db_data,
  22. )
  23. patch_redis_client(
  24. rb.clients.RoutingClient,
  25. is_cluster=False,
  26. set_db_data_fn=_set_db_data,
  27. )