g:6dZddlZddlZddlmZmZddlmZddlmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZdd lmZmZmZmZdd lmZdd lmZdd lm Z m!Z!dd l"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'dZJdZKeKZLdZMejeOZPd e eQd!eQd"e e eQeRffd#ZSd"e eQfd$ZTd"eQfd%ZUd&eQd'edfd(ZVd'edd"e eQfd)ZW dCd*e eQee:fd+ed-e5fd.ZX dDd/e eQeee0ee1ffd-e5fd0ZY dDd*e eQee$fd-e5fd1ZZd2e eQd3e eQd4e eQd"e e eQee:fe eQeee0ee1ffe eQee$fffd5Z[d6eQd"eeQge>ffd7Z\d6eQd"e e>fd8Z]d9eQd"edZ`Gd?d@eZaGdAdBeaZby)FzF OpenTelemetry SDK Configurator for Easy Instrumentation with Distros N)ABCabstractmethod)environ)CallableDictListOptionalSequenceTupleTypeUnion)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_samplerselected_componentsentry_point_namereturnc 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)r9r:component_implementationsselected_components ^/var/www/openai/venv/lib/python3.12/site-packages/opentelemetry/sdk/_configuration/__init__.py_import_config_componentsrJ]s!#1  % , ,&(&6=O df  22 %$ )*:);;G  '(:';< 014  s >A  3A>c6tjtdSN)rgetr rI _get_samplerrP~s ;;*D 11rOc>tjttSrL)rrMr_DEFAULT_ID_GENERATORrNrOrI_get_id_generatorrSs ;;/1F GGrO exporter_name signal_typec|tttfvr|Stjt |xstjt }|s|tk(rtS|S|j}|tk(r |tvrtd|dt|Stj |}|r||k7rtjd|||S)NzUnsupported OTLP protocol 'z' is configuredz ## ~> > ? /rOexporters_or_readersc g}|jD]O\}}i}t|tr|j|di|0|jt |di|Qt ||}t |y)N)rometric_readersrN)rq issubclassr$r@r%r"r)rxrorzrtexporter_or_reader_classrvrss rI _init_metricsr}s N';'A'A'C# # . =  ! !":"K]"K L  ! !-,=}=  (Dh~NHx rOc Pt|}t||jD]'\}}i}|jt |di|)t t j|}t jj|t|}t|y)N)ro)levellogger_provider)rrN) rrrqadd_log_record_processorrrloggingNOTSET getLogger addHandlerrr)rlrorsrtrurvhandlerevent_logger_providers rI _init_loggingrsx0H!&__.> )) #N$C]$C D / 7>>8LG ""7+/I34rOtrace_exporter_namesmetric_exporter_nameslog_exporter_namescni}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)rJr{r*rEr#r$r)rrrtrace_exportersmetric_exporters log_exportersrT exporter_impls rI_import_exportersrsOM #=   m\ 2-:OM *-0HIJ J   #?   mnl%C D.; ] +-0IJK K  #9   m[ 1+8M- (-0FGH H   ,m ;;rO sampler_namecPt|jgtd\}}|S)Nr)rJr[_OTEL_SAMPLER_ENTRY_POINT_GROUP)rrt sampler_impls rI_import_sampler_factoryr4s2/     ? OA| rOc|sy t|}d}|dvr& ttjt}|}ntjt}||}t|ts)d|d|d}tj|t ||S#t t f$rtjdd}YwxYw#t$r!}tjd||Yd}~yd}~wwxYw)N) traceidratioparentbased_traceidratiozGCould 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 TypeErrorr]r^ isinstancer, Exception)rsampler_factoryargraternmessageexcs rI_import_samplerr;s 1,? G G RYY'>?@ C))34C!#&'7+)/)::MgYVopG OOG $W% % * ]    I    s:C"BAC&C>CCC C. C))C.id_generator_namect|jgdd\}}t|tr|St |d)Nopentelemetry_id_generatorrz is not an IdGenerator)rJr[r{r+rE)rid_generator_impls rI_import_id_generatorr\sX+D  "#%A,, ((#[1 "" +,,BC DDrOauto_instrumentation_versionresource_attributeslogging_enabledc|g}|g}|g}t|tdz|tdz|tdz\}} } |t} t| }|t } t | }|i}|r||t j<tj|} t|||| t| | |9tjtdjj!dk(}|r t#| | yy)Nr4r5r6)rlrmrnrofalsetrue)rrkrPrrSrr-TELEMETRY_AUTO_VERSIONr'createrwr}rrrr[rgr)rrrrrnrrmrspan_exportersrrrrros rI_initialize_componentsrgs3#!$ "!6G28<< 3I >>08873N$m #~ !,/-/+,=> " # ( .EEF 23H !  "H- IIA7 UW UW   mX.rOc4eZdZdZdZdZdZedZdZ 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||_|jSrL) _instanceobject__new__)clsargskwargss rIrz_BaseConfigurator.__new__s0 == "NN3@@@CM}}rOc y)Configure the SDKNrNselfrs rI _configurez_BaseConfigurator._configuresrOc (|jdi|y)rNrN)rrs rI configurez_BaseConfigurator.configures!&!rO) __name__ __module__ __qualname____doc__r_is_instrumentedrrrrrNrOrIrrs2I   "rOrceZdZdZdZy)_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)NrN)rrs rIrz_OTelSDKConfigurator._configures ((rON)rrrrrrNrOrIrrs  )rOr)NNNrL)NNNNNNNN)crrrabcrrrtypingrrrr r r r r typing_extensionsropentelemetry._eventsropentelemetry._logsr#opentelemetry.environment_variablesrrrropentelemetry.metricsropentelemetry.sdk._eventsropentelemetry.sdk._logsrropentelemetry.sdk._logs.exportrr'opentelemetry.sdk.environment_variablesrrrrrr r!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/rWrXrYr\rfrZ_RANDOM_ID_GENERATORrRrrrr]strrrJrPrSrarkrwr}rrrrrboolrrrrNrOrIrs  #OOO%;3 59BO4 =2K<4=3?-- &. #$  12 ,   ,"@ '  H %%c%69% eCK !%B2hsm2H3H))%,-H%I)X 45  c]  !%  Cl++,     0 ! U4'l);; <<! !45Ck**+55*0<"3-0<#C=0<! 0< d< !eD($|*<<= =>d;  " 02J#(7*;BECEKE370415.2!%04 $&*7/"*3-7/"49-7/$DI.7/!c+ 7/ g  7/ "*- 7/7/d^7/t""4 ), )rO