ng\j:GF%SrSSKJr SSKJrJrJr SSKJrJrJ r SSK J r J r SSK Jr SSKJr SSKJrJr \(aSS KJr SS KJr SS KJr S q\\ \S 'SrS\\ 4SjrS\S4SjrSHS\S\ S\\S\\!S\\S\\"S\\#S\\!SS 4Sjjr$SSS\ SS 4Sjr%SIS\S \S!\!SS 4S"jjr&\"S#S$S%9SJS&j5r'\"S#S$S%9S'\SSS 4S(j5r(S\SS 4S)jr)S\S\ SS 4S*jr*SKS+\\ S,\\"SS 4S-jjr+S.\S/\S0\#SS 4S1jr,S\SS 4S2jr-SLS\S\!S3\S4\!S,\"S\!S5\#SS 4S6jjr.SKS7\ S8\\S9\\#SS 4S:jjr/SKS;\ S<\\S=\\SS 4S>jjr0SMS=\\SS 4S?jjr1S\S\!S3\S4\!S/\SS 4 S@jr2SASBSCSBSD\SS 4SEjr3SJSFjr4S\#4SGjr5g )Na Async-compatible API for recording observability metrics. This module provides an async-safe interface for Redis async client code to record metrics without needing to know about OpenTelemetry internals. It reuses the same RedisMetricsCollector and configuration as the sync recorder. Usage in Redis async client code: from redis.asyncio.observability.recorder import record_operation_duration start_time = time.monotonic() # ... execute Redis command ... await record_operation_duration( command_name='SET', duration_seconds=time.monotonic() - start_time, server_address='localhost', server_port=6379, db_namespace='0', error=None ) )datetime) TYPE_CHECKINGListOptional)ConnectionStateGeoFailoverReasonPubSubDirection) CloseReasonRedisMetricsCollector)get_observability_instance)!get_observables_registry_instance)deprecated_function str_if_bytes)ConnectionPool) AsyncDatabase) OTelConfigN_async_metrics_collectorconnection_countreturncp[b[$[5R5nUbURR(dgUR 5R [R[R5n[XR5q[$![a g[a gf=f)z Get or create the global metrics collector. Returns: RedisMetricsCollector instance if observability is enabled, None otherwise N) rr get_provider_managerconfigenabled_telemetryget_meter_provider get_meterr METER_NAME METER_VERSION ImportError Exception)managermeters _/home/edenadmin/noVNC/venv/lib/python3.13/site-packages/redis/asyncio/observability/recorder.py_get_or_create_collectorr#/s +'',.CCE ?'.."B"B**,66 ! , ,.C.Q.Q $9#O ''  s6BAB B5) B54B5rc|# [5R5nUcgUR$![a gf=f7f)z Get the OTel configuration from the observability manager. Returns: OTelConfig instance if observability is enabled, None otherwise N)r rrr)r s r" _get_configr%Ps>,.CCE ?~~ s$<,< ,< 9<9< command_nameduration_secondsserver_address server_port db_namespaceerror is_blockingretry_attemptsc z# [5nUcgURUUUUUUUUUUS9 g![a gf=f7f)a  Record a Redis command execution duration. This is an async-safe API that Redis async client code can call directly. If observability is not enabled, this returns immediately with zero overhead. Args: command_name: Redis command name (e.g., 'GET', 'SET') duration_seconds: Command execution time in seconds server_address: Redis server address server_port: Redis server port db_namespace: Redis database index error: Exception if command failed, None if successful is_blocking: Whether the operation is a blocking command retry_attempts: Number of retry attempts made Example: >>> start = time.monotonic() >>> # ... execute command ... >>> await record_operation_duration('SET', time.monotonic() - start, 'localhost', 6379, '0') N) r&r'r(r)r* error_typenetwork_peer_addressnetwork_peer_portr,r-)r#record_operation_durationr) r&r'r(r)r*r+r,r- collectors r"r2r2`sa>)*I ++%-)#%!/)#) ,     s;+; 8;8;connection_poolrcj# [5nUcgURUUS9 g![a gf=f7f)z Record connection creation time. Args: connection_pool: Connection pool implementation duration_seconds: Time taken to create connection in seconds N)r4r')r#record_connection_create_timer)r4r'r3s r"r6r6sI)*I //+- 0     3#3 0303 pool_nameconnection_statecountercl# [5nUcgURUUUS9 g![a gf=f7f)z Record a connection count change for a single state. Args: pool_name: Connection pool identifier connection_state: State to update (IDLE or USED) counter: Number to add (positive) or subtract (negative) N)r8r9r:)r#record_connection_countr)r8r9r:r3s r"r<r<sL)*I ))- *    4$4 1414z{Connection count is now tracked via record_connection_count(). This functionality will be removed in the next major versionz7.4.0)reasonversioncn# [5nUcgSnURUS9 g![a gf=f7f)z: Initialize observable gauge for connection count metric. Nc[5nUR[5n/nUHnURU"55 M U$N)r getCONNECTION_COUNT_REGISTRY_KEYextend)__observables_registry callbacks observationscallbacks r"observable_callback2init_connection_count..observable_callbacksC@B(,,-JK  !H    +")rJ)r#init_connection_countr)r3rKs r"rNrNsK)*I ''( (     s5%5 2525connection_poolsc^^# [5nUcgSSKJm UU4Sjn[5nUR [ U5 g![ a gf=f7f)z? Add connection pools to connection count observable registry. Nr) Observationc z>/nTH1nUR5Hup#URT"X#S95 M M3 U$)N) attributes)get_connection_countappend)rIr4countrSrQrOs r"connection_count_callbackBregister_pools_connection_count..connection_count_callbacksDL#3)8)M)M)O%E '' E(QR*P$4 rM)r#opentelemetry.metricsrQr registerrDr)rOr3rWrGrQs` @r"register_pools_connection_countr[sY)*I 5  AB%% )+D     s(A-AA A AAAch# [5nUcgURUS9 g![a gf=f7f)zU Record a connection timeout event. Args: pool_name: Connection pool identifier Nr8)r#record_connection_timeoutrr8r3s r"r^r^F)*I ++ ,     2"2 /2/2cj# [5nUcgURUUS9 g![a gf=f7f)z Record time taken to obtain a connection from the pool. Args: pool_name: Connection pool identifier duration_seconds: Wait time in seconds N)r8r')r#record_connection_wait_timer)r8r'r3s r"rcrcsI)*I --- .     r7 close_reasonr/cj# [5nUcgURUUS9 g![a gf=f7f)z Record a connection closed event. Args: close_reason: Reason for closing (e.g. 'error', 'application_close') error_type: Error type if closed due to error N)rdr/)r#record_connection_closedr)rdr/r3s r"rfrf5sI)*I **%! +     r7connection_namemaint_notificationrelaxedcl# [5nUcgURUUUS9 g![a gf=f7f)z Record a connection timeout relaxation event. Args: connection_name: Connection identifier (pool name) maint_notification: Maintenance notification type relaxed: True to count up (relaxed), False to count down (unrelaxed) N)rgrhri)r#!record_connection_relaxed_timeoutr)rgrhrir3s r"rkrkMsL)*I 33+1 4    r=ch# [5nUcgURUS9 g![a gf=f7f)zw Record a connection handoff event (e.g., after MOVING notification). Args: pool_name: Connection pool identifier Nr])r#record_connection_handoffrr_s r"rmrmhr`rar0r1 is_internalc t# [5nUcgURUUUUUUUS9 g![a gf=f7f)aL Record error count. Args: server_address: Server address server_port: Server port network_peer_address: Network peer address network_peer_port: Network peer port error_type: Error type (Exception) retry_attempts: Retry attempts is_internal: Whether the error is internal (e.g., timeout, network error) N)r(r)r0r1r/r-rn)r#record_error_countr)r(r)r0r1r/r-rnr3s r"rprp}sX*)*I  $$)#!5/!)# %     s8(8 5858 directionchannelshardedc# [5nUcgUnUb4[5IShvN nUbUR(aSnO [U5nUR UUUS9 gN9![ a gf=f7f)z Record a PubSub message (published or received). Args: direction: Message direction ('publish' or 'receive') channel: Pub/Sub channel name sharded: True if sharded Pub/Sub channel N)rqrrrs)r#r%hide_pubsub_channel_namesrrecord_pubsub_messager)rqrrrsr3effective_channelrs r"rvrvs)*I "}$  &"B"B $ !-W 5  ''% ( %    s3!A/A&A/ AA/ A,)A/+A,,A/ lag_seconds stream_nameconsumer_groupc# [5nUcgUnUb([5IShvN nUbUR(aSnURUUUS9 gN-![a gf=f7f)z Record the lag of a streaming message. Args: lag_seconds: Lag in seconds stream_name: Stream name consumer_group: Consumer group name Nrxryrz)r#r%hide_stream_namesrecord_streaming_lagr)rxryrzr3effective_stream_namers r"r~r~s})*I("}$  &":":$( ! &&#-) ' %    s2!A#AA#AA# A A#A  A#c 6# [5nUcgU(dg[R"5R5n[ 5IShvN nUSL=(a UR n[ U[5(aUR5HyupgU(aSO [U5nUHZn U HQn U up[U 5n U RS5up[SU[U 5S- - 5nURUUUS9 MS M\ M{ gUHvn[US5nU(aSOUnUSHQn U up[U 5n U RS5up[SU[U 5S- - 5nURUUUS9 MS Mx gGNcl# [5nUcgURUUUS9 g![a gf=f7f)z Record a geo failover. Args: fail_from: Database failed from fail_to: Database failed to reason: Reason for the failover N)rrr>)r#record_geo_failoverr)rrr>r3s r"rrPsL)*I %% &    r=cSqg)zK Reset the global async collector (used for testing or re-initialization). N)rrMr"reset_collectorrks $rMc&# [5nUSL$7f)zg Check if observability is enabled. Returns: True if metrics are being collected, False otherwise N)r#)r3s r" is_enabledrss)*I D  s)NNNNNN)r)rN)NN)TrB)6__doc__rtypingrrrredis.observability.attributesrrr redis.observability.metricsr r redis.observability.providersr redis.observability.registryr redis.utilsrrredis.asyncio.connectionrredis.asyncio.multidb.databaserredis.observability.configrr__annotations__rDr#r%strfloatrrboolr2r6r<rNr[r^rcrfrkrmrprvr~rrrrrrrMr"rs,00 KDJ97<5=A(#89@ 2(+@"AB 8L1 &%)!%"&!%"&$(1 1 1 SM1 # 1 3- 1 I  1 $1 SM1  1 h %    6  %    6 C     4 C   +,     :    *     2+/&* ;' #   0      6    8$ $ $ $  $  $  $ $  $ R""" " c]" d^"  " N"&$(  # SM   H%)A SMA  A H          B       6$!$!rM