o QDi9@sdZddlZddlZddlmZmZddlmZddlmZm Z m Z m Z m Z m Z mZmZddlmZddlmZddlmZmZmZmZdd lmZdd lmZmZdd lmZm Z dd l!m"Z"m#Z#m$Z$m%Z%m&Z&m'Z'm(Z(dd l)m*Z*ddl+m,Z,m-Z-m.Z.ddl/m0Z0m1Z1ddl2m3Z3ddl4m5Z5m6Z6ddl7m8Z8ddl9m:Z:ddl;mZ>ddl?m@Z@dZAdZBdZCeBeCdZDeeedZEe&e$e#dZFdZGeGZHdZIeJeKZLde eMdeMd e e eMeNffd!d"ZOd e eMfd#d$ZPd eMfd%d&ZQd'eMd(edfd)d*ZRd(edd e eMfd+d,ZS   dNd-e eMee6fd.e8d/e:d0e1fd1d2ZT dOd3e eMeee,ee-ffd0e1fd4d5ZU dOd-e eMee fd0e1fd6d7ZVd8e eMd9e eMd:e eMd e e eMee6fe eMeee,ee-ffe eMee fffd;d<ZWd=eMd eeMge:ffd>d?ZXd=eMd e e:fd@dAZYdBeMd e8fdCdDZZ        dPdEe eMd8e e eMd9e e eMd:e e eMd/e e:dFe e0d.e8dGe e[fdHdIZ\GdJdKdKeZ]GdLdMdMe]Z^dS)QzF OpenTelemetry SDK Configurator for Easy Instrumentation with Distros N)ABCabstractmethod)environ)CallableDictListOptionalSequenceTupleTypeUnion)Literal)set_logger_provider)OTEL_LOGS_EXPORTEROTEL_METRICS_EXPORTEROTEL_PYTHON_ID_GENERATOROTEL_TRACES_EXPORTER)set_meter_provider)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 Csxg}|D]5}z||ttt||dfWqty(td|dty9td|d|dw|S)N)groupnamezRequested entry point 'z ' not foundzRequested component 'z' not found in entry point '')appendnextiterr,loadKeyError RuntimeError StopIteration)r6r7component_implementationsselected_componentrEb/var/www/Datamplify/venv/lib/python3.10/site-packages/opentelemetry/sdk/_configuration/__init__.py_import_config_components[s6   rGcCs ttdSN)rgetrrErErErF _get_sampler rJcCs tttSrH)rrIr_DEFAULT_ID_GENERATORrErErErF_get_id_generatorrKrM exporter_name signal_typecCs|tttfvr |Stt|ptt}|s|tkrtS|S|}|tkr7|tvr3t d|dt|St|}|rI||krIt d|||S)NzUnsupported OTLP protocol 'z' is configuredzs z'_get_exporter_names..,)rrI_EXPORTER_ENV_BY_SIGNAL_TYPElowerrTsplit)rOnamesrEr_rF_get_exporter_namess  rf exporters id_generatorsamplerresourcecCsHt|||d}t||D]\}}i}|t|di|qdS)N)rhrirjrE)r%r+itemsadd_span_processorr&)rgrhrirjprovider_exporter_class exporter_argsrErErF _init_tracingsrqexporters_or_readerscCsjg}|D]"\}}i}t|tr||di|q|t|di|qt||d}t|dS)N)rjmetric_readersrE)rk issubclassr!r<r"rr)rrrjrsrnexporter_or_reader_classrprmrErErF _init_metricss    rvcCs`t|d}t||D]\}}i}|t|di|q ttj|d}t |dS)N)rj)levellogger_providerrE) rrrkadd_log_record_processorrrloggingNOTSET getLogger addHandler)rgrjrmrnrorphandlerrErErF _init_loggings rtrace_exporter_namesmetric_exporter_nameslog_exporter_namescCsi}i}i}t|dD]\}}t|tr|||<q t|dt|dD]\}}t|ttfr5|||<q%t|dt|dD]\}}t|trO|||<qAt|d|||fS)Nopentelemetry_traces_exporterz is not a trace exporteropentelemetry_metrics_exporterz is not a metric exporteropentelemetry_logs_exporterz is not a log exporter)rGrtr'rAr r!r)rrrtrace_exportersmetric_exporters log_exportersrN exporter_implrErErF_import_exporterss>       r sampler_namecCst|gtd\}}|S)Nr)rGrT_OTEL_SAMPLER_ENTRY_POINT_GROUP)rrn sampler_implrErErF_import_sampler_factory2s  rc Cs|sdSzLt|}d}|dvr.z ttt}Wnttfy*tdd}Ynw|}ntt}||}t |t sNd|d|d}t|t||WSt yj}ztd||WYd}~dSd}~ww)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 TypeErrorrVrW isinstancer) Exception)rsampler_factoryargraterimessageexcrErErF_import_sampler9s>   rid_generator_namecCs6t|gdd\}}t|tr|St|d)Nopentelemetry_id_generatorrz is not an IdGenerator)rGrTrtr(rA)rid_generator_implrErErF_import_id_generatorZs  rauto_instrumentation_versionresource_attributeslogging_enabledcCs|durg}|dur g}|durg}t|td|td|td\}} } |dur2t} t| }|dur=t} t| }|durCi}|rJ||tj<t |} t |||| dt | | |durlt tddk}|rut| | dSdS)Nr1r2r3)rgrhrirjfalsetrue)rrfrJrrMrr*TELEMETRY_AUTO_VERSIONr$createrqrvrrrrTrcr)rrrrrirrhrspan_exportersrrrrrjrErErF_initialize_componentsesT       rc@s4eZdZdZdZdZddZeddZdd Z dS) _BaseConfiguratorzAn ABC for configurators Configurators are used to configure SDKs (i.e. TracerProvider, MeterProvider, Processors...) to reduce the amount of manual configuration required. NFcOs*|jdurtj|g|Ri||_|jSrH) _instanceobject__new__)clsargskwargsrErErFrs z_BaseConfigurator.__new__cKsdS)Configure the SDKNrEselfrrErErF _configuresz_BaseConfigurator._configurecKs|jdi|dS)rNrE)rrrErErF configuresz_BaseConfigurator.configure) __name__ __module__ __qualname____doc__r_is_instrumentedrrrrrErErErFrs  rc@seZdZdZddZdS)_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. cKstdi|dS)NrE)rrrErErFrsz_OTelSDKConfigurator._configureN)rrrrrrErErErFrs r)NNNrH)NNNNNNNN)_rrzrabcrrrtypingrrrrr r r r typing_extensionsr opentelemetry._logsr#opentelemetry.environment_variablesrrrropentelemetry.metricsropentelemetry.sdk._logsrropentelemetry.sdk._logs.exportrr'opentelemetry.sdk.environment_variablesrrrrrrropentelemetry.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,rPrQrRrUrbrS_RANDOM_ID_GENERATORrLrr|rrVstrrrGrJrMrZrfrqrvrrrrrboolrrrrErErErFs (   $         $ ,     3!     :