Ë
|
WñúhÈa ã óN U d Z ddlmZ ddlZddlZddlmZmZ ddlm Z ddl
|
m Z m Z m Z mZmZmZmZ e rddlmZmZ dd lmZ d
|
d lmZ dd lmZmZ dd l m Z ddl m Z ddl m Z ddl!m"Z" ddl#m$Z$ ddlm)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0m1Z1m2Z2m3Z3m4Z4 ejj d« Z6de7d< d(dZ8d)dZ9d*dZ: d+ d,dZ;d-d Z<d-d Z=d-d Z> G d d e« Z? G d! d"e?« Z@ G d# d$e?« ZA d+ d.d%ZB G d& d'« ZCy# e%$ r!Z&ejN jQ d« e&dZ&[&ww xY w)/z1MySQL instrumentation supporting mysql-connector.é )Ú annotationsN)ÚABCÚabstractmethod)Ú nullcontext)Ú TYPE_CHECKINGÚAnyÚCallableÚ
|
CollectionÚDictÚOptionalÚUnioné )ÚMySQLConnectionAbstractÚMySQLCursorAbstract)ÚPooledMySQLConnectioné )Ú connector)Ú CNX_POOL_ARGSÚDEFAULT_CONFIGURATION)Úlogger)Ú VERSION_TEXT)Útrace)ÚTracerProvider)ÚSpanAttributeszGOpenTelemetry installation not found. You must install the API and SDK.é ) ÚCONNECTION_SPAN_NAMEÚ DB_SYSTEMÚDEFAULT_THREAD_IDÚDEFAULT_THREAD_NAMEÚFIRST_SUPPORTED_VERSIONÚNET_SOCK_FAMILYÚNET_SOCK_HOST_ADDRÚNET_SOCK_HOST_PORTÚNET_SOCK_PEER_ADDRÚNET_SOCK_PEER_PORTÚOPTION_CNX_SPANÚOPTION_CNX_TRACERz
|
^/\*.*?\*/z
|
re.PatternÚleading_comment_removerc óÈ | r| j « r|sy| j t j t j j
|
« « | j |« y)z Records an exeception event.N)Ú is_recordingÚ
|
set_statusr ÚStatusÚ
|
StatusCodeÚERRORÚrecord_exception)ÚspanÚexcs ú`H:\Change_password\venv_build\Lib\site-packages\mysql/connector/opentelemetry/instrumentation.pyÚrecord_exception_eventr3 X sD á t×(Ñ(Ô*±#ØàOOELL¤×!1Ñ!1×!7Ñ!7Ó8Ô9Ø×Ñ#Õ ó c óJ | r| j « sy| j « y)z
|
Ends span.N)r* Úend)r0 s r2 Úend_spanr7 a s á t×(Ñ(Ô*ØàHH
Jr4 c óv | r7t | t « r't j d| « j « d S y)z&Parse query to extract operation name.Ú r )Ú
|
isinstanceÚstrr( ÚsubÚsplit)Ú operations r2 Úget_operation_namer? i s2 áZ ¬3Ô/ä&×*Ñ*¨2¨yÓ9×?Ñ?ÓAÀ!ÑDÐDØ r4 c ó |r|j « sy|i }| r | j nd|v}t j t t j |rdndt
|
|rdndi}|r | r | j n|j dt d « |t j < | r | j n|j dt d « |t j < t | d « rú| j rî | j j j « \ |t < }| j j j# « \ |t$ < |t& < |t j |k7 rt||t( < nj| r | j n|j d« |t < t | d « r8| j r, | j j j# « |t$ < |j1 |« y# t* $ r }t- j. d
|
|« Y d}~6d}~ww xY w# t* $ r }t- j. d
|
|« Y d}~bd}~ww xY w) a¼ Defines connection span attributes. If `cnx` is None then we use `cnx_kwargs`
|
to get basic net information. Basic net attributes are defined such as:
|
|
* DB_SYSTEM
|
* NET_TRANSPORT
|
* NET_SOCK_FAMILY
|
|
Socket-level attributes [*] are also defined [**].
|
|
[*]: Socket-level attributes identify peer and host that are directly connected to
|
each other. Since instrumentations may have limited knowledge on network
|
information, instrumentations SHOULD populate such attributes to the best of
|
their knowledge when populate them at all.
|
|
[**]: `CMySQLConnection` connections have no access to socket-level
|
details so socket-level attributes aren't included. `MySQLConnection`
|
connections, on the other hand, do include socket-level attributes.
|
|
References:
|
[1]: https://github.com/open-telemetry/opentelemetry-specification/blob/main/ specification/trace/semantic_conventions/span-general.md
|
NÚ unix_socketÚip_tcpÚinprocÚinetÚunixÚhostÚportÚ_socketz Connection socket is down %s)r* Ú _unix_socketr r Ú NET_TRANSPORTr! Ú_hostÚgetr Ú NET_PEER_NAMEÚ_portÚ NET_PEER_PORTÚhasattrrH ÚsockÚ getpeernamer$ Ú getsocknamer" r# r% Ú Exceptionr ÚwarningÚset_attributes)ÚcnxÚcnx_spanÚ
|
cnx_kwargsÚis_tcpÚattrsÚsock_peer_portÚsock_errs r2 Úset_connection_span_attrsr^ q s ñ8 8×0Ñ0Ô2ØàÐØ
|
á%(×!Ñ!Ñ !¨mÀ:Ð.MFô × Ñ ¤)Ü×$Ñ$±&¡h¸hÜ¡6¨vð Eò á CII *§.¡.°Ô9NÈvÑ9VÓ"Wð n×*Ñ*Ñ+ñ CII *§.¡.°Ô9NÈvÑ9VÓ"Wð n×*Ñ*Ñ+ô 3 Ô " s§{¢{ð ?ð KK×$Ñ$×0Ñ0Ó2ñØÔ,Ñ-Ø"ð KK×$Ñ$×0Ñ0Ó2ñØÔ,Ñ-ØÔ,Ñ-ð
|
×5Ñ5Ñ6¸.ÒHð 1?EÔ,Ò-ñ
|
!$C× Ò ¨¯ © ¸ Ó)Fð Ô Ñ!ô 3 Ô " s§{¢{ð IØ,/¯K©K×,<Ñ,<×,HÑ,HÓ,JÔ(Ñ)ð ×ÑEÕ"øô) ò IÜÐ =¸x×HÑHûð Iûô" ò IÜÐ =¸x×HÑHûð Iús1 Ã+A#G* Æ-+H Ç* HÇ3HÈHÈ H?È H:È:H?c ó d fd }|S )zAAttach the connection span while executing the connection method.c óê | j r;| j j « r!t j | j d¬« n t « 5 | g|¢i |¤cddd« S # 1 sw Y yxY w)z#Connection span attacher decorator.F©Ú end_on_exitN)Ú_spanr* r Úuse_spanr )rW ÚargsÚkwargsÚmethods r2 Úwrapperz'with_cnx_span_attached.<locals>.wrapperÉ s` ø ð YY399×1Ñ1Ô3ô ^^Ø II 5õ
|
ä9D» ñ 0ñ #Ð/ Ò/¨Ñ/÷ 0÷ 0ò 0ús Á A)Á)A2)rW ú'MySQLConnectionAbstract're r rf r Úreturnr © ©rg rh s ` r2 Úwith_cnx_span_attachedrm Æ s ø õ0ð Nr4 c ó d fd }|S )z:Create a query span while executing the connection method.c ó® t j dj « t j t t j
|
| j t j t t j t d| j « i}| j r| j j « r{| j j j j! « t" j$ j& t# j( | j j+ « « g|¬« n t- « 5 | g|¢i |¤cddd« S # 1 sw Y yxY w)ú Query span creator decorator.z%Creating query span for connection.%sÚconnection_type©ÚnameÚkindÚlinksÚ
|
attributesN)r ÚinfoÚ__name__r r ÚDB_USERÚ_userÚ THREAD_IDr Ú THREAD_NAMEr Úget_wrapped_classrc r* Ú_tracerÚstart_as_current_spanÚupperr ÚSpanKindÚCLIENTÚLinkÚget_span_contextr )rW re rf Úquery_span_attributesrg s r2 rh z$with_cnx_query_span.<locals>.wrapperÖ sþ ø ä Ð;¸V¿_¹_ÔMô × $Ñ $¤iÜ × "Ñ " C§I¡IÜ × $Ñ $Ô&7Ü × &Ñ &Ô(;Ø s× 4Ñ 4Ó 6ð '
|
Ð ð YY399×1Ñ1Ô3ð [[× .Ñ .Ø ×&Ñ&Ó(Ü ×&Ñ&Ü::cii× 8Ñ 8Ó :Ó;Ð<Ø,ð /ô
|
ô
|
:E» ñ 0ñ #Ð/ Ò/¨Ñ/÷ 0÷ 0ò 0ús Ä5 E Å E)rW ÚTracedMySQLConnectionre r rf r rj r rk rl s ` r2 Úwith_cnx_query_spanr Ó s ø õ0ð( Nr4 c ó d fd }|S )z6Create a query span while executing the cursor method.c ó t j dj « t | j d« rt | j d« nt | j d« }t j t t j |j t j t t j t d| j « i}| j j! t# |d « xs dt$ j& j( | j* g|¬« 5 | g|¢i |¤cddd« S # 1 sw Y yxY w) rp z!Creating query span for cursor.%sÚ _connectionÚ_cnxÚ cursor_typer z SQL statementrr N)r rw rx rP Ú_wrappedÚgetattrr r ry rz r{ r r| r r} r~ r r? r r r Ú_connection_span_link)Úcurre rf Ú
|
connectionr
rg s r2 rh z'with_cursor_query_span.<locals>.wrapperð s ø ä Ð7¸¿ ¹ ÔIô s|| ]Ô3ô CLL -Ô 0ä vÓ.ð ô × $Ñ $¤iÜ × "Ñ " J×$4Ñ$4Ü × $Ñ $Ô&7Ü × &Ñ &Ô(;Ø 3×0Ñ0Ó2ð '
|
Ð ð [[× .Ñ .Ü# D¨¡GÓ,Ò?°Ü ×&Ñ&Ø×,Ñ,Ð-Ø,ð /ó
|
ñ 0ñ #Ð/ Ò/¨Ñ/÷ 0÷ 0ò 0ús Ä D4Ä4D=)r ÚTracedMySQLCursorre r rf r rj r rk rl s ` r2 Úwith_cursor_query_spanr í s ø õ0ð4 Nr4 c óV e Zd ZdZedd« Zd dZd
|
fd Zd dZd dZ d dZ
|
xZ S )ÚBaseMySQLTracerz<Base class that provides basic object wrapper functionality.c ó y)z"Must be implemented by subclasses.Nrk ©Úselfs r2 Ú__init__zBaseMySQLTracer.__init__ s r4 c ób || j v r t | |« S t | j |« S )zçGets an attribute.
|
|
Attributes defined in the wrapper object have higher precedence
|
than those wrapped object equivalent. Attributes not found in
|
the wrapper are then searched in the wrapped object.
|
)Ú__dict__r r )r Úattrs r2 Ú __getattr__zBaseMySQLTracer.__getattr__ s. ð 4==Ñ ä4 Ó&Ð &ät}} dÓ+Ð+r4 c óÂ d| j vr|| j d< y || j v s|dk( rt | ||« y | j j ||« y )Nr Ú
|
autocommit)r ÚsuperÚ __setattr__r )r rs ÚvalueÚ __class__s r2 r¡ zBaseMySQLTracer.__setattr__! sY ø Ø T]]Ñ *Ø(-DMM*Ñ %Ø à 4==Ñ D¨LÒ$8ä GÑ eÔ ,Ø à ×!Ñ! $¨Õ.r4 c ó: | j j « | S )ú Magic method.)r Ú __enter__r s r2 r¦ zBaseMySQLTracer.__enter__- s à × Ñ Ô!Ø r4 c ó< | j j |i |¤ y)r¥ N)r Ú__exit__©r re rf s r2 r¨ zBaseMySQLTracer.__exit__2 s à × Ñ Ð/¨Ó/r4 c óB | j j j S )z Gets the wrapped class name.)r r£ rx r s r2 r} z!BaseMySQLTracer.get_wrapped_class6 s à}}×&Ñ&×/Ñ/Ð/r4 )rj ÚNone)r r; rj r )rs r; r¢ r rj r« )rj r )re r rf r rj r« ©rj r; ) rx Ú
|
__module__Ú __qualname__Ú__doc__r r r r¡ r¦ r¨ r} Ú __classcell__)r£ s @r2 r r s1 ø ÙFàò1ó ð1ó ,õ
|
/óó
|
0÷0r4 r c óZ e Zd ZdZ ddZedd« Zedd« Zedd« Zy) r z;Wrapper class for a `MySQLCursor` or `CMySQLCursor` object.c óp || _ || _ t j |j « « | _ y©z Constructor.N)r r~ r r r r )r ÚwrappedÚtracerÚconnection_spans r2 r zTracedMySQLCursor.__init__> s/ ð 07 Ø%+ Ü16·±Ø × ,Ñ ,Ó .ó2
|
Õ"r4 c ó: | j j |i |¤S ©úInstrument method.)r Úexecuter© s r2 rº zTracedMySQLCursor.executeK s ð %t}}×$Ñ$ dÐ5¨fÑ5Ð5r4 c ó: | j j |i |¤S r¸ )r Ú executemanyr© s r2 r¼ z TracedMySQLCursor.executemanyP ó ð )t}}×(Ñ(¨$Ð9°&Ñ9Ð9r4 c ó: | j j |i |¤S r¸ )r Úcallprocr© s r2 r¿ zTracedMySQLCursor.callprocU ó ð &t}}×%Ñ% tÐ6¨vÑ6Ð6r4 N)r´ z'MySQLCursorAbstract'rµ z trace.Tracerr¶ ú
|
trace.Span©re r rf r rj r ) rx r r® r¯ r r rº r¼ r¿ rk r4 r2 r r ; sb ÙEð
|
à&ð
|
ð ð
|
ð $ó
|
ð ò6ó ð6ð ò:ó ð:ð ò7ó ñ7r4 r c óp e Zd ZdZd"dZd#dZed$d« Zed$d« Zed$d« Z ed$d« Z
|
ed$d« Z ed$d « Z ed$d
|
« Z ed$d « Zed$d « Zed$d « Zed$d« Zed$d« Zeed%d« « Zed$d« Zed$d« Zed$d« Zed$d« Zed$d« Zed$d« Zed$d« Zed$d« Z ed$d« Z ed$d« Z eed%d« « Z eed%d « « Z eed&d « « Z!e!jD ed'd « « Z!ed$d « Z#ed$d « Z$y!)(r zCWrapper class for a `MySQLConnection` or `CMySQLConnection` object.c ó> || _ | j j }yr³ ©r Úsql_mode)r r´ Ú_s r2 r z TracedMySQLConnection.__init__^ s à3: ð MM× "Ñ "r4 c óz t | j j |i |¤| j | j ¬« S )zWraps the object method.)r´ rµ r¶ )r r Úcursorr~ rc r© s r2 rÉ z TracedMySQLConnection.cursorf s6 ä Ø(DMM×(Ñ(¨$Ð9°&Ñ9Ø<<Ø JJô
|
ð
|
r4 c ó: | j j |i |¤S r¸ )r Úcmd_change_userr© s r2 rË z%TracedMySQLConnection.cmd_change_usern s ð -t}}×,Ñ,¨dÐ=°fÑ=Ð=r4 c ó: | j j |i |¤S r¸ )r Úcommitr© s r2 rÍ z TracedMySQLConnection.commits s ð $t}}×#Ñ# TÐ4¨VÑ4Ð4r4 c ó: | j j |i |¤S r¸ )r Úrollbackr© s r2 rÏ z TracedMySQLConnection.rollbackx rÀ r4 c ó: | j j |i |¤S r¸ )r Ú cmd_queryr© s r2 rÑ z TracedMySQLConnection.cmd_query} ó ð 't}}×&Ñ&¨Ð7°Ñ7Ð7r4 c ó: | j j |i |¤S r¸ )r Ú cmd_init_dbr© s r2 rÔ z!TracedMySQLConnection.cmd_init_db r½ r4 c ó: | j j |i |¤S r¸ )r Ú cmd_refreshr© s r2 rÖ z!TracedMySQLConnection.cmd_refresh r½ r4 c ó: | j j |i |¤S r¸ )r Úcmd_quitr© s r2 rØ z TracedMySQLConnection.cmd_quit rÀ r4 c ó: | j j |i |¤S r¸ )r Ú cmd_shutdownr© s r2 rÚ z"TracedMySQLConnection.cmd_shutdown ó ð *t}}×)Ñ)¨4Ð:°6Ñ:Ð:r4 c ó: | j j |i |¤S r¸ )r Úcmd_statisticsr© s r2 rÝ z$TracedMySQLConnection.cmd_statistics ó ð ,t}}×+Ñ+¨TÐ<°VÑ<Ð<r4 c ó: | j j |i |¤S r¸ )r Úcmd_process_killr© s r2 rà z&TracedMySQLConnection.cmd_process_kill ó ð .t}}×-Ñ-¨tÐ>°vÑ>Ð>r4 c ó: | j j |i |¤S r¸ )r Ú cmd_debugr© s r2 rã z TracedMySQLConnection.cmd_debug rÒ r4 c ó: | j j |i |¤S r¸ )r Úcmd_pingr© s r2 rå z TracedMySQLConnection.cmd_ping¥ rÀ r4 c ó. | j j S r¸ )r Údatabaser s r2 rç z TracedMySQLConnection.databaseª ó ð }}×%Ñ%Ð%r4 c ó: | j j |i |¤S r¸ )r Ú is_connectedr© s r2 rê z"TracedMySQLConnection.is_connected° rÛ r4 c ó: | j j |i |¤S r¸ )r Ú reset_sessionr© s r2 rì z#TracedMySQLConnection.reset_sessionµ s ð +t}}×*Ñ*¨DÐ;°FÑ;Ð;r4 c ó: | j j |i |¤S r¸ )r Úpingr© s r2 rî zTracedMySQLConnection.pingº s ð "t}}×!Ñ! 4Ð2¨6Ñ2Ð2r4 c ó: | j j |i |¤S r¸ )r Ú
|
info_queryr© s r2 rð z TracedMySQLConnection.info_query¿ s ð (t}}×'Ñ'¨Ð8°Ñ8Ð8r4 c ó: | j j |i |¤S r¸ )r Úcmd_stmt_preparer© s r2 rò z&TracedMySQLConnection.cmd_stmt_prepareÄ rá r4 c ó: | j j |i |¤S r¸ )r Úcmd_stmt_executer© s r2 rô z&TracedMySQLConnection.cmd_stmt_executeÉ rá r4 c ó: | j j |i |¤S r¸ )r Úcmd_stmt_closer© s r2 rö z$TracedMySQLConnection.cmd_stmt_closeÎ rÞ r4 c ó: | j j |i |¤S r¸ )r Úcmd_stmt_send_long_datar© s r2 rø z-TracedMySQLConnection.cmd_stmt_send_long_dataÓ s ð 5t}}×4Ñ4°dÐE¸fÑEÐEr4 c ó: | j j |i |¤S r¸ )r Úcmd_stmt_resetr© s r2 rú z$TracedMySQLConnection.cmd_stmt_resetØ rÞ r4 c ó: | j j |i |¤S r¸ )r Úcmd_reset_connectionr© s r2 rü z*TracedMySQLConnection.cmd_reset_connectionÝ s ð 2t}}×1Ñ1°4ÐB¸6ÑBÐBr4 c ó. | j j S r¸ )r Ú time_zoner s r2 rþ z TracedMySQLConnection.time_zoneâ s ð }}×&Ñ&Ð&r4 c ó. | j j S r¸ rÅ r s r2 rÆ z TracedMySQLConnection.sql_modeè rè r4 c ó. | j j S r¸ ©r r r s r2 r z TracedMySQLConnection.autocommitî s ð }}×'Ñ'Ð'r4 c ó& || j _ y)r¹ Nr )r r¢ s r2 r z TracedMySQLConnection.autocommitô s ð $) Õ r4 c ó: | j j |i |¤S r¸ )r Úset_charset_collationr© s r2 r z+TracedMySQLConnection.set_charset_collationú s ð 3t}}×2Ñ2°DÐC¸FÑCÐCr4 c ó: | j j |i |¤S r¸ )r Ústart_transactionr© s r2 r z'TracedMySQLConnection.start_transactionÿ s ð /t}}×.Ñ.°Ð?¸Ñ?Ð?r4 N)r´ ri rj r« )re r rf r rj r r r¬ )rj Úbool)r¢ r rj r« )%rx r r® r¯ r rÉ r rË rÍ rÏ rÑ rÔ rÖ rØ rÚ rÝ rà rã rå Úpropertyrç rê rì rî rð rò rô rö rø rú rü rþ rÆ r Úsetterr r rk r4 r2 r r [ s ÙMó#ó
|
ð ò>ó ð>ð ò5ó ð5ð ò7ó ð7ð ò8ó ð8ð ò:ó ð:ð ò:ó ð:ð ò7ó ð7ð ò;ó ð;ð ò=ó ð=ð ò?ó ð?ð ò8ó ð8ð ò7ó ð7ð Øò&ó ó ð&ð ò;ó ð;ð ò<ó ð<ð ò3ó ð3ð ò9ó ð9ð ò?ó ð?ð ò?ó ð?ð ò=ó ð=ð òFó ðFð ò=ó ð=ð òCó ðCð Øò'ó ó ð'ð Øò&ó ó ð&ð Øò(ó ó ð(ð ×ÑØò)ó ó ð)ð òDó ðDð ò@ó ñ@r4 r c óT t j « d fd « }|S )z.Retrurn the instrumented version of `connect`.c óê t fdt D « « r t j d« | i ¤S t j
|
dt ¬« }|j t t j j ¬« t < |t < t j t d¬« 5 }t d|« | i ¤}t ||« t |¬ « cddd« S # 1 sw Y yxY w)
|
zWraps the connection object returned by the method `connect`.
|
|
Instrumentation for PooledConnections is not supported.
|
c 3 ó& K | ] }|v
|
y w©Nrk )Ú.0Úkeyrf s r2 ú <genexpr>z7_instrument_connect.<locals>.wrapper.<locals>.<genexpr> s øè ø Ò6 sf}Ñ6ùs z4Instrumentation for pooled connections not supportedúMySQL Connector/Python©Úinstrumenting_module_nameÚ instrumenting_library_versionÚtracer_provider©rs rt Fra N©r´ )Úanyr r rU r Ú
|
get_tracerr Ú
|
start_spanr r r r& r' rd r^ r )re rf rµ rX rW Úconnectr s ` r2 rh z$_instrument_connect.<locals>.wrapper sã ù ô Ó6¬ Ô6Ô 6Ü NNÐQÔ RÙDÐ+ FÑ+Ð +ä×!Ñ!Ø&>Ü*6Ø +ô
|
ð #)×"3Ñ"3Ü%¬E¯N©N×,AÑ,Að #4ó #
|
Ñ ð %+Ô Ñ!ô ^^F¤?Ñ 3ÀÔ Gð È8ä % d¨H°fÔ =ñ 4Ð* 6Ñ*Cô & c¨8°VÔ <ä(Øô÷ ÷ ò ús Â1.C)Ã)C2)re r rf r rj z9Union['MySQLConnectionAbstract', 'PooledMySQLConnection'])Ú functoolsÚwraps)r r rh s `` r2 Ú_instrument_connectr s@ ù ô __WÓ ð'Øð'Ø !ð'à Bõ'ó ð'ðR Nr4 c óf e Zd ZU dZdZded< d dZd dZd dZ d ddZ d d Z
|
dd
|
Z y)ÚMySQLInstrumentorz8MySQL instrumentation supporting mysql-connector-python.NzOptional[MySQLInstrumentor]Ú _instancec ó¸ | j Ct j | g|¢i |¤| _ t | j dt j
|
« | j S )zQSinglenton.
|
|
Restricts the instantiation to a singular instance.
|
Ú_original_connect)r! ÚobjectÚ__new__Úsetattrr r )Úclsre rf s r2 r% zMySQLInstrumentor.__new__> sI ð
|
==Ð ä "NN¨3Ð @°Ò @¸Ñ @CMä CMMÐ#6¼ ×8IÑ8IÔ JØ}}Ð r4 c ó dt gS )zoReturn a list of python packages with versions
|
that the will be instrumented (e.g., versions >= 8.1.0).zmysql-connector-python >= )r r s r2 Ú instrumentation_dependenciesz.MySQLInstrumentor.instrumentation_dependenciesJ s ð -Ô-DÐ,EÐFÐGÐGr4 c óÈ t j t | d« k7 rt j d« yt t | d« |j d« ¬« t _ y)a Instrument the library.
|
|
Args:
|
trace_module: reference to the 'trace' module from opentelemetry.
|
tracer_provider (optional): TracerProvider instance.
|
|
NOTE: Instrumentation for pooled connections not supported.
|
r# z3MySQL Connector/Python module already instrumented.Nr )r r )r r r r rU r rL ©r rf s r2 Ú
|
instrumentz MySQLInstrumentor.instrumentO sO ô × Ñ ¤¨Ð.AÓ BÒ BÜ NNÐPÔ QØ Ü /ÜDÐ"5Ó6Ø "JJÐ'8Ó 9ô
|
Õr4 c óÊ t |t « rt j d« |S t |d« r t |d« s,t j d|j
|
j « |S t j dt |¬« }|j t t j j ¬« |_ ||_ t! ||j « t |¬« S ) a Enable instrumentation in a MySQL connection.
|
|
Args:
|
connection: uninstrumented connection instance.
|
trace_module: reference to the 'trace' module from opentelemetry.
|
tracer_provider (optional): TracerProvider instance.
|
|
Returns:
|
connection: instrumented connection instace.
|
|
NOTE: Instrumentation for pooled connections not supported.
|
z Connection already instrumented.rc r~ z+Instrumentation for class %s not supported.r r r r )r: r r rU rP r£ rx r r r r r r r rc r~ r^ )r r r rµ s r2 Úinstrument_connectionz'MySQLInstrumentor.instrument_connection` s ô" jÔ"7Ô 8Ü NNÐ=Ô >Ø Ð äz 7Ô+´7¸:ÀyÔ3QÜ NNØ=Ø×$Ñ$×-Ñ-ô ð Ð ä×!Ñ!Ø&>Ü*6Ø +ô
|
ð
|
"×,Ñ,Ü%¬E¯N©N×,AÑ,Að -ó
|
|
Ôð $
|
Ôä! *¨j×.>Ñ.>Ô?ä$¨ZÔ8Ð8r4 c ó t j t | d« k( rt j d« yt | d« t _ y)zUninstrument the library.r# z5MySQL Connector/Python module already uninstrumented.N)r r r r rU r+ s r2 Ú uninstrumentz MySQLInstrumentor.uninstrument s: ô × Ñ ¤¨Ð.AÓ BÒ BÜ NNÐRÔ SØ Ü # DÐ*=Ó > Õr4 c óf t |d« s,t j d|j j « |S t |t « st j d« |S |j r;|j j « r!|j j « d|_ |j S )a Disable instrumentation in a MySQL connection.
|
|
Args:
|
connection: instrumented connection instance.
|
|
Returns:
|
connection: uninstrumented connection instace.
|
|
NOTE: Instrumentation for pooled connections not supported.
|
rc z-Uninstrumentation for class %s not supported.z"Connection already uninstrumented.N) rP r rU r£ rx r: r rc r* r6 r )r r s r2 Úuninstrument_connectionz)MySQLInstrumentor.uninstrument_connection s ô z 7Ô+Ü NNØ?Ø×$Ñ$×-Ñ-ô ð Ð ä*Ô&;Ô<Ü NNÐ?Ô @Ø Ð ð × Ò
|
× 0Ñ 0× =Ñ =Ô ?Ø × Ñ × Ñ Ô "Ø #JÔ à×"Ñ"Ð"r4 )re r rf r rj r )rj zCollection[str])rf r rj r« r )r ri r ú Optional[trace.TracerProvider]rj ri )r ri rj ri ) rx r r® r¯ r! Ú__annotations__r% r) r, r. r0 r2 rk r4 r2 r r 9 sa
ÙBà-1IÐ*Ó1ó
|
óHó
|
|
ð( ;?ð(9à-ð(9ð 8ð(9ð
|
#ó (9óT?ð #Ø3ð #à "ô #r4 r )r0 rÁ r1 zOptional[Exception]rj r« )r0 rÁ rj r« )r> r; rj r; r )rW z#Optional['MySQLConnectionAbstract']rX rÁ rY zOptional[Dict[str, Any]]rj r« )rg r rj r )r úHCallable[..., Union['MySQLConnectionAbstract', 'PooledMySQLConnection']]r r3 rj r5 )Dr¯ Ú
|
__future__r r ÚreÚabcr r Ú
|
contextlibr Útypingr r r r
|
r r r Ú abstractsr r Úpoolingr r9 r Ú constantsr r r Úversionr Ú opentelemetryr Úopentelemetry.sdk.tracer Úopentelemetry.semconv.tracer Ú ImportErrorÚmissing_dependencies_errÚerrorsÚProgrammingErrorr r r r r r! r" r# r$ r% r& r' Úcompiler( r4 r3 r7 r? r^ rm r r r r r r r rk r4 r2 ú<module>rG s\ ðò: 8õ #ã Û ç #Ý "ß R× RÑ Rñ ÷ IÝ/å ß <Ý Ý "ð $õ $Ý6Ý:÷ ÷ ÷ ó ð '1 b§j¡j° Ó&?Ð Ó ?ó óóð ,0ðR#Ø ,ðR#àðR#ð )ðR#ð
|
ó R#ój
|
óó4 ô@+0cô +0ô\ 7ô 7ô@g@Oô g@ðX 7;ð1Ø Uð1à3ð1ð Nó1÷hv#ò v#øðs ò $Ø
|
×
|
Ñ
|
×
|
+Ñ
|
+ØQó à #ð$ûð$ús Á C> Ã>D$Ä D Ä D$
|
