Zj EvUddlmZddlZddlmZddlmZmZmZddl m Z ddl m Z ddl mZddl mZdd l mZmZmZdd l mZdd l mZdd l mZdd l mZddl mZddl mZ ddl m!Z"ddl#m$Z$m%Z%m&Z&m'Z'mZm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-ddl.m/Z/mZm0Z0mZm1Z1ddl2m Z m3Z3m4Z4m5Z5m6Z6m7Z7m8Z8m!Z!ddl9m:Z:ej;e<Z=dZ>dZ?ej@e&ejAe,ejBe'ejCe-ejDe(ejEe)ejFe*iZGdeHd<dEdZIdFd ZJdGd$ZKdHd'ZLdId*ZMdJd,ZNdKd.ZOeNeOeMd/ZPd0eHd1<dLd3ZQdMd6ZRdNd9ZSdOd=ZT dPdQdBZU dPdRdDZVdS)S) annotationsN)metrics)_map_compression_parse_headersload_entry_point)ConfigurationError) Aggregation)ConsoleMetricExporter)ExemplarFilter)#ExporterDefaultHistogramAggregationExporterTemporalityPreferenceInstrumentType) MeterProvider) MetricReader)OtlpGrpcMetricExporter)OtlpHttpMetricExporter)PeriodicMetricReader)PushMetricExporter)View) AlwaysOffExemplarFilterAlwaysOnExemplarFilterCounter HistogramrObservableCounterObservableGaugeObservableUpDownCounterTraceBasedExemplarFilter UpDownCounter_Gauge)AggregationTemporalityr MetricExporterrPeriodicExportingMetricReader)r DefaultAggregationDropAggregation"ExplicitBucketHistogramAggregation%ExponentialBucketHistogramAggregationLastValueAggregationSumAggregationr)Resourcei`i0uzdict[InstrumentType, type]_INSTRUMENT_TYPE_MAPpref$ExporterTemporalityPreference | Nonereturn"dict[type, AggregationTemporality]c ||tjkrhttjt tjt tjttjttjttjiS|tj krhttj t tjt tj ttj ttjttjiS|tj krhttj t tjt tj ttjttjttjiStd|d)uMap a temporality preference to an explicit preferred_temporality dict. Always returns an explicit dict to suppress OTEL_EXPORTER_OTLP_METRICS_TEMPORALITY_PREFERENCE. Default (None or cumulative) → all instruments CUMULATIVE. Nz$Unsupported temporality preference 'z3'. Supported values: cumulative, delta, low_memory.)r cumulativerr CUMULATIVErrrrrdeltaDELTA low_memoryrr+s m/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/opentelemetry/sdk/_configuration/_meter_provider.py_map_temporalityr7es# |t<GGG +6 1< -8 5@ #%;%F 3>    ,222 +1 1< -3 5; #%;%F 3>    ,777 +1 1< -3 5@ #%;%F 3>     ;t ; ; ;  *ExporterDefaultHistogramAggregation | Nonedict[type, Aggregation]c||tjkrttiS|tjkrtt iSt d|d)uMap a histogram aggregation preference to an explicit preferred_aggregation dict. Always returns an explicit dict to suppress OTEL_EXPORTER_OTLP_METRICS_DEFAULT_HISTOGRAM_AGGREGATION. Default (None or explicit_bucket_histogram) → ExplicitBucketHistogramAggregation. Nz+Unsupported default histogram aggregation 'zS'. Supported values: explicit_bucket_histogram, base2_exponential_bucket_histogram.)r explicit_bucket_histogramrr%"base2_exponential_bucket_histogramr&rr5s r6_map_histogram_aggregationr>s  . H I I=??@@ . Q R R@BBCC  [d [ [ [  r8configAggregationConfigr c|jtS|jtS|j3t |jj|jj |jjndS|jDi}|jj |jj |d<|jj |jj |d<tdi|S|j tS|jtSt!d|d) zICreate an SDK Aggregation from config, passing through detail parameters.NT) boundariesrecord_min_maxmax_size max_scalez3Unknown or unsupported aggregation type in config: zq. Supported types: default, drop, explicit_bucket_histogram, base2_exponential_bucket_histogram, last_value, sum.)defaultr#dropr$r<r%rBrCr=rDrEr& last_valuer'sumr(r)r?kwargss r6_create_aggregationrLs) ~!!### {    '317B3BN0??     0<  4 = I9B :   4 > J9C ; 5>>v>>> $#%%% z  ?f ? ? ?  r8 ViewConfigrc |j}|j}d}|j8t|j}|t d|jd}|jK|jjrt d|jj t|jj }d}|j t|j }t||j|j|j|j|j|j|j|| S)zCreate an SDK View from config.NzUnknown instrument type: zdattribute_keys.excluded is not supported by the Python SDK View; the exclusion list will be ignored.) instrument_typeinstrument_name meter_name meter_versionmeter_schema_urlinstrument_unitname descriptionattribute_keys aggregation)selectorstreamrOr*getrrWexcluded_loggerwarningincludedsetrXrLrrPrQrRrSunitrUrV)r?rYrZrOrWrXs r6 _create_viewrbsH ]FO+.2283KLL  "$HH,DHH '+N (  )  OO6     ) 5 !6!?@@NK %)&*<== ' 0&,!2 [&%    r8ConsoleMetricExporterConfigr!ctt|j}t|j}t ||S)z+Create a ConsoleMetricExporter from config.)preferred_temporalitypreferred_aggregation)r7temporality_preferencer>default_histogram_aggregationr )r?rerfs r6_create_console_metric_exporterrisJ-V-JKK6, !33   r8OtlpHttpMetricExporterConfigcf ddlm}ddlm}n"#t$r}t d|d}~wwxYwt |j|d}t|j |j }|j |j dz nd}t|j }t|j}||j||||| S) z0Create an OTLP HTTP metric exporter from config.r) CompressionOTLPMetricExporterzotlp_http metric exporter requires 'opentelemetry-exporter-otlp-proto-http'. Install it with: pip install opentelemetry-exporter-otlp-proto-httpNT) allow_deflate@@endpointheaderstimeout compressionrerf)&opentelemetry.exporter.otlp.proto.httprl6opentelemetry.exporter.otlp.proto.http.metric_exporterrn ImportErrorrrrurrs headers_listrtr7rgr>rhrr) r?rlrnexcrursrtrerfs r6!_create_otlp_http_metric_exporterr{s+                 R    #KtKV^V-@AAG+1>+Ev~&&4G,V-JKK6,  33    s  .).OtlpGrpcMetricExporterConfigch ddl}ddlm}n"#t$r}t d|d}~wwxYwt |j|j}t|j |j }|j |j dz nd}t|j }t|j}||j|||||S)z0Create an OTLP gRPC metric exporter from config.rNrmzotlp_grpc metric exporter requires 'opentelemetry-exporter-otlp-proto-grpc'. Install it with: pip install opentelemetry-exporter-otlp-proto-grpcrprq)grpc6opentelemetry.exporter.otlp.proto.grpc.metric_exporterrnrxrrrurlrrsryrtr7rgr>rhrr) r?r~rnrzrursrtrerfs r6!_create_otlp_grpc_metric_exporterr*s             R    #6#5t7GHHKV^V-@AAG+1>+Ev~&&4G,V-JKK6,  33    s ,',) otlp_http otlp_grpcconsoledict_METRIC_EXPORTER_REGISTRYPushMetricExporterConfigct|jtdtD]%\}}t ||d}| ||cS&|jrNt t|j\}}td|di|piStd)aBCreate a push metric exporter from config. Known exporter types are checked via typed fields on the PushMetricExporter dataclass. Unknown exporter names captured in additional_properties by the @_additional_properties decorator are loaded via the ``opentelemetry_metrics_exporter`` entry point group. NzLotlp_file_development metric exporter is experimental and not yet supported.opentelemetry_metrics_exporterzjNo exporter type specified in push metric exporter config. Supported types: console, otlp_http, otlp_grpc.rF) otlp_file_developmentrritemsgetattradditional_propertiesnextiterr)r?rUfactoryvalue plugin_configs r6_create_push_metric_exporterrTs#/  %   388::"" gd++  75>> ! ! !  # "4(D(J(J(L(L#M#MNNmG @$GG  "     :  r8PeriodicMetricReaderConfigr"ct|j}|j|jnt}|j|jnt }t |t|t|S)zCreate a PeriodicExportingMetricReader from config. Passes explicit interval/timeout defaults to suppress env var reading. N)exporterexport_interval_millisexport_timeout_millis)rrinterval_DEFAULT_EXPORT_INTERVAL_MILLISrt_DEFAULT_EXPORT_TIMEOUT_MILLISr"float)r?rrrts r6_create_periodic_metric_readerrrsw,FO< %  + )$X#Gnn   r8MetricReaderConfigrc|jt|jS|jtdtd)z"Create a MetricReader from config.NzPull metric readers (e.g. Prometheus) are experimental and not yet supported by declarative config. Use the SDK API directly to configure pull readers.zLNo reader type specified in metric reader config. Supported types: periodic.)periodicrpullr)r?s r6_create_metric_readerrsS "-fo>>> {  Y     %  r8rExemplarFilterConfigobjectc|tjkrtS|tjkrt S|tjkrt Std|d)z5Create an SDK exemplar filter from config enum value.zUnknown exemplar filter value: z7. Supported values: always_on, always_off, trace_based.)r always_onr always_offr trace_basedrr)rs r6_create_exemplar_filterrs $...%''' $///&((( $000')))  @% @ @ @  r8MeterProviderConfig | NoneresourceResource | NonercHt}||jt|j}g}g}|_|jD]$}|t |%|jr,|jD]$}|t|%t||||S)aCreate an SDK MeterProvider from declarative config. Does NOT read OTEL_METRIC_EXPORT_INTERVAL, OTEL_METRICS_EXEMPLAR_FILTER, or any other env vars for values explicitly controlled by the config. Absent config values use OTel spec defaults, matching Java SDK behavior. Args: config: MeterProvider config from the parsed config file, or None. resource: Resource to attach to the provider. Returns: A configured MeterProvider. N)rmetric_readersexemplar_filterviews) rrrreadersappendrrrbr)r?rrrr reader_config view_configs r6create_meter_providerrs&788O f4@1&2HII"$GE #^ A AM NN0?? @ @ @ @ < 8%| 8 8  \+667777 '    r8NonecR|dStjt||dS)uTConfigure the global MeterProvider from declarative config. When config is None (meter_provider section absent from config file), the global is not set — matching Java/JS SDK behavior. Args: config: MeterProvider config from the parsed config file, or None. resource: Resource to attach to the provider. N)rset_meter_providerr)r?rs r6configure_meter_providerrs0~ 4VXFFGGGGGr8)r+r,r-r.)r+r9r-r:)r?r@r-r )r?rMr-r)r?rcr-r!)r?rjr-r!)r?r|r-r!)r?rr-r!)r?rr-r")r?rr-r)rrr-r)N)r?rrrr-r)r?rrrr-r)W __future__rlogging opentelemetryr(opentelemetry.sdk._configuration._commonrrr,opentelemetry.sdk._configuration._exceptionsr'opentelemetry.sdk._configuration.modelsr r@r rcr rr r rrMeterProviderConfigrrrr|rrjrrrrrrMopentelemetry.sdk.metricsrrrrrrrrrr opentelemetry.sdk.metrics.exportr r!r"opentelemetry.sdk.metrics.viewr#r$r%r&r'r(opentelemetry.sdk.resourcesr) getLogger__name__r]rrcounterup_down_counter histogramgaugeobservable_counterobservable_gaugeobservable_up_down_counterr*__annotations__r7r>rLrbrir{rrrrrrrrrFr8r6rs#""""""!!!!!! LKKKKK                                               100000 ' H % %#(!&G"Mi&%'8#_-/F4&&&&R4""""J&&&&R    ####L    H32.##<2        $!%&&&&&V!%HHHHHHHr8