Bvh@bdZddlmZddlZddlZddlmZmZddlmZddl m Z m Z m Z m Z mZmZddlmZddlmZdd lmZdd lmZmZmZmZdd lmZdd lmZdd lm Z m!Z!ddl"m#Z#m$Z$ddl%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,ddl-m.Z.ddl/m0Z0m1Z1m2Z2ddl3m4Z4m5Z5ddl6m7Z7ddl8m9Z9m:Z:ddl;mZ>ddl?m@Z@ddlAmBZBddlCmDZDdZEdZFdZGeFeGdZHeeedZIe*e(e'dZJdZKeKZLd ZMejeOZPe eee:ee0ee1ee$fe eQe ffZR d3d!ZSd4d"ZTd5d#ZU d6d$ZV d7d%ZW d8 d9d&ZX d: d;d'ZY d< d=d(ZZd)Z[ d>d*Z\ d?d+Z]d@d,Z^dAd-Z_ dB dCd.Z`Gd/d0eZaGd1d2eaZby)DzF OpenTelemetry SDK Configurator for Easy Instrumentation with Distros ) annotationsN)ABCabstractmethod)environ)AnyCallableMappingSequenceTypeUnion)Literal)set_event_logger_provider)set_logger_provider)OTEL_LOGS_EXPORTEROTEL_METRICS_EXPORTEROTEL_PYTHON_ID_GENERATOROTEL_TRACES_EXPORTER)set_meter_provider)EventLoggerProvider)LoggerProviderLoggingHandler)BatchLogRecordProcessor LogExporter)1_OTEL_PYTHON_LOGGING_AUTO_INSTRUMENTATION_ENABLED OTEL_EXPORTER_OTLP_LOGS_PROTOCOL#OTEL_EXPORTER_OTLP_METRICS_PROTOCOLOTEL_EXPORTER_OTLP_PROTOCOL"OTEL_EXPORTER_OTLP_TRACES_PROTOCOLOTEL_TRACES_SAMPLEROTEL_TRACES_SAMPLER_ARG) MeterProvider)MetricExporter MetricReaderPeriodicExportingMetricReader) AttributesResource)TracerProvider)BatchSpanProcessor SpanExporter) IdGenerator)Sampler)ResourceAttributes)set_tracer_provider) entry_pointsotlpotlp_proto_grpcotlp_proto_http)grpcz http/protobuf)tracesmetricslogsrandomopentelemetry_traces_samplerc g}|D]A} |j|ttt||j fC|S#t $rt d|dt$rt d|d|dwxYw)N)groupnamezRequested entry point 'z ' not foundzRequested component 'z' not found in entry point '')appendnextiterr.loadKeyError RuntimeError StopIteration)selected_componentsentry_point_namecomponent_implementationsselected_components S/RAG/venv/lib/python3.12/site-packages/opentelemetry/sdk/_configuration/__init__.py_import_config_componentsrHis!#1  % , ,&(&6=O df  22 %$ )*:);;G  '(:';< 014  s >A  3A>c6tjtdSN)rgetrrG _get_samplerrNs ;;*D 11rMc>tjttSrJ)rrKr_DEFAULT_ID_GENERATORrLrMrG_get_id_generatorrQs ;;/1F GGrMc|tttfvr|Stjt |xstjt }|s|tk(rtS|S|j}|tk(r |tvrtd|dt|Stj |}|r||k7rtjd|||S)NzUnsupported OTLP protocol 'z' is configuredz)--nbA ## ~> > ? /rMc (g}|xsi}|jD]_\}}|j|i}t|tr|j |di|@|j t |di|at ||}t|y)N)rmmetric_readersrL)rnrK issubclassr#r<r$r!r)exporters_or_readersrmrqrxrsexporter_or_reader_classrurrs rG _init_metricsr|sN)/R';'A'A'C# #)--.FK . =  ! !":"K]"K L  ! !-,=}=  (Dh~NHx rMc t|}t||xsi}|jD]7\}}|j|i}|j t |di|9t |}t||rItttj|} tjj| yy)N)rm)logger_provider)levelr~rL)rrrnrKadd_log_record_processorrrr_patch_basic_configrloggingNOTSET getLogger addHandler) rprmsetup_logging_handlerrqrrrsrtruevent_logger_providerhandlers rG _init_loggingrs x0H!)/R&__.>)--nbA )) #N$C]$C D / 0I34!..(  &&w/rMcFtjfd}|t_y)Nctj}t|jdk(xrt |jdt }|r4|jj }|i||j|y|i|y)Nr)rrlenhandlers isinstancerpopr)argskwargsroot has_only_otel otel_handleroriginal_basic_configs rGpatched_basic_configz1_patch_basic_config..patched_basic_configs{  "DMM*a/ J MM! n5  ==,,.L !4 26 2 OOL ) !4 26 2rM)r basicConfig)rrs @rGrrs#// 3/GrMcni}i}i}t|dD](\}}t|tr|||<t|dt|dD].\}}t|tt fr|||<"t|dt|dD](\}}t|t r|||<t|d|||fS)Nopentelemetry_traces_exporterz is not a trace exporteropentelemetry_metrics_exporterz is not a metric exporteropentelemetry_logs_exporterz is not a log exporter)rHryr)rAr"r#r)trace_exporter_namesmetric_exporter_nameslog_exporter_namestrace_exportersmetric_exporters log_exportersr[ exporter_impls rG_import_exportersr*sOM #=   m\ 2-:OM *-0HIJ J   #?   mnl%C D.; ] +-0IJK K  #9   m[ 1+8M- (-0FGH H   ,m ;;rMcPt|jgtd\}}|S)Nr)rHrW_OTEL_SAMPLER_ENTRY_POINT_GROUP) sampler_namers sampler_impls rG_import_sampler_factoryr]s40     ? OA| rMc|sy t|}d}|dvr' ttjtd}|}ntjt}||}t|ts)d|d|d}tj|t ||S#t t f$rtjdd}YwxYw#t$r!}tjd||Yd}~yd}~wwxYw) N) traceidratioparentbased_traceidratiorazGCould not convert TRACES_SAMPLER_ARG to float. Using default value 1.0.g?zSampler factory, z, produced output, z, which is not a Sampler.z;Using default sampler. Failed to initialize sampler, %s: %s) rfloatosgetenvr ValueError TypeErrorrYrZrr+ Exception)rsampler_factoryargraterlmessageexcs rG_import_samplerrfs 1,? G G RYY'>CD C))34C!#&'7+)/)::MgYVopG OOG $W% % * ]    I    s:C#BAC&C?CCC C/C**C/ct|jgdd\}}t|tr|St |d)Nopentelemetry_id_generatorrz is not an IdGenerator)rHrWryr*rA)id_generator_nameid_generator_impls rG_import_id_generatorrsX+D  "#%A,, ((#[1 "" +,,BC DDrMc |g}|g}|g}t|tdz|tdz|tdz\} } } |t} t| }|t } t | }|i}|r||t j<tj|}t| ||||t| |||9tjtdjj!dk(}t#| |||y)Nr3r4r5)rprkrlrmrq)rqfalsetrue)rrirNrrQrr,TELEMETRY_AUTO_VERSIONr&creatervr|rrrrWrer)auto_instrumentation_versionrrrrlresource_attributesrkrrqspan_exportersrrrrrms rG_initialize_componentsrs?#!$ "!6G28<< 3I >>08873N$m #~ !,/-/+,=> " # ( .EEF 23H !+ (6G$ IIA7 UW UW   + rMc4eZdZdZdZdZdZedZdZ y)_BaseConfiguratorzAn ABC for configurators Configurators are used to configure SDKs (i.e. TracerProvider, MeterProvider, Processors...) to reduce the amount of manual configuration required. NFcn|jtj|g|i||_|jSrJ) _instanceobject__new__)clsrrs rGrz_BaseConfigurator.__new__s0 == "NN3@@@CM}}rMc y)Configure the SDKNrLselfrs rG _configurez_BaseConfigurator._configuresrMc (|jdi|y)rNrL)rrs rG configurez_BaseConfigurator.configures!&!rM) __name__ __module__ __qualname____doc__r_is_instrumentedrrrrrLrMrGrrs2I   "rMrceZdZdZdZy)_OTelSDKConfiguratoraA basic Configurator by OTel Python for initializing OTel SDK components Initializes several crucial OTel SDK components (i.e. TracerProvider, MeterProvider, Processors...) according to a default implementation. Other Configurators can subclass and slightly alter this initialization. NOTE: This class should not be instantiated nor should it become an entry point on the `opentelemetry-sdk` package. Instead, distros should subclass this Configurator and enhance it as needed. c tdi|y)NrL)rrs rGrz_OTelSDKConfigurator._configures ((rMN)rrrrrrLrMrGrrs  )rMr)rC Sequence[str]rDstrreturnzlist[tuple[str, Type]])r str | None)rr)r[rr\$Literal['traces', 'metrics', 'logs'])r\rrz list[str])NNNN) rpzdict[str, Type[SpanExporter]]rkIdGenerator | NonerlSampler | NonermResource | NonerqExporterArgsMap | None)NN)rzz:dict[str, Union[Type[MetricExporter], Type[MetricReader]]]rmrrqr)NTN)rpzdict[str, Type[LogExporter]]rmrrboolrqr)rrrrrrrz~tuple[dict[str, Type[SpanExporter]], dict[str, Union[Type[MetricExporter], Type[MetricReader]]], dict[str, Type[LogExporter]]])rrrz'Callable[[float | str | None], Sampler])rrrr)rrrr*) NNNNNNNNN)rrrlist[str] | NonerrrrrlrrzAttributes | Nonerkrrz bool | Nonerqr)cr __future__rrrabcrrrtypingrrr r r r typing_extensionsr opentelemetry._eventsropentelemetry._logsr#opentelemetry.environment_variablesrrrropentelemetry.metricsropentelemetry.sdk._eventsropentelemetry.sdk._logsrropentelemetry.sdk._logs.exportrr'opentelemetry.sdk.environment_variablesrrrrrrr opentelemetry.sdk.metricsr! opentelemetry.sdk.metrics.exportr"r#r$opentelemetry.sdk.resourcesr%r&opentelemetry.sdk.tracer'opentelemetry.sdk.trace.exportr(r)$opentelemetry.sdk.trace.id_generatorr* opentelemetry.sdk.trace.samplingr+opentelemetry.semconv.resourcer,opentelemetry.tracer-&opentelemetry.util._importlib_metadatar.rSrTrUrXrdrV_RANDOM_ID_GENERATORrPrrrrYrExporterArgsMaprHrNrQr_rirvr|rrrrrrrrrrLrMrGrs # #@@%;3 59BO4 =2K<4=3?-- &. #$  12 ,   ,"@ '  H %  \ ^ \ [   CH %&%:=%%B2H))%I)X 5   (," $04  , $    .  4!%04 !! ! . !6!%"&04 0+00 0. 0:/$0<'0<(0<&0< 0