dQj,`TdZddlmZddlZddlZddlZddlZddlmZm Z ddl m Z m Z m Z ddlmZddlmZmZmZddlmZdd lmZmZmZmZdd lmZdd lmZmZmZdd l m!Z!dd l"m#Z#m$Z$ddl%m&Z&m'Z'm(Z(m)Z)m*Z*m+Z+m,Z,m-Z-m.Z.m/Z/m0Z0ddl1m2Z2ddl3m4Z4ddl5m6Z6m7Z7m8Z8ddl9m:Z:m;Z;ddlZ>m?Z?ddl@mAZAmBZBddlCmDZDddlEmFZFddlGmHZHddlImJZJddlKmLZLdZMdZNdZOeNeOdZPeeedZQe+e)e(dZRdZSeSZTd ZUejeWZXe eYeBeYe6zeYe7zeYe$ze eZeffZ[Gd!d"eZ\Gd#d$eZ]d>d%Z^d?d&Z_d@d'Z`d?d(Zad?d)Zbd?d*ZcdAd+Zd dBd,Ze dC dDd-Zf dE dFd.Zg dG dHd/ZhdId0Zi dJd1Zj dKd2Zk dLd3Zl dMd4Zm dNd5ZndOd6ZodPd7Zp dQd8Zq dR dSd9ZrGd:d;eZsGd<d=esZty)TzF OpenTelemetry SDK Configurator for Easy Instrumentation with Distros ) annotationsN)ABCabstractmethod)CallableMappingSequence)environ)AnyLiteralProtocol)set_logger_provider)OTEL_LOGS_EXPORTEROTEL_METRICS_EXPORTEROTEL_PYTHON_ID_GENERATOROTEL_TRACES_EXPORTER)set_meter_provider)LoggerProviderLoggingHandlerLogRecordProcessor)_LoggerConfiguratorT)BatchLogRecordProcessorLogRecordExporter) 1_OTEL_PYTHON_LOGGING_AUTO_INSTRUMENTATION_ENABLEDOTEL_CONFIG_FILE OTEL_EXPORTER_OTLP_LOGS_PROTOCOL#OTEL_EXPORTER_OTLP_METRICS_PROTOCOLOTEL_EXPORTER_OTLP_PROTOCOL"OTEL_EXPORTER_OTLP_TRACES_PROTOCOLOTEL_PYTHON_LOGGER_CONFIGURATOROTEL_PYTHON_METER_CONFIGURATOROTEL_PYTHON_TRACER_CONFIGURATOROTEL_TRACES_SAMPLEROTEL_TRACES_SAMPLER_ARG) MeterProvider)_MeterConfiguratorT)MetricExporter MetricReaderPeriodicExportingMetricReader) AttributesResource) SpanProcessorTracerProvider_TracerConfiguratorT)BatchSpanProcessor SpanExporter) IdGenerator)Sampler)ResourceAttributes)set_tracer_provider) entry_pointsotlpotlp_proto_grpcotlp_proto_http)grpcz http/protobuf)tracesmetricslogsrandomopentelemetry_traces_samplerceZdZddZy)$_ConfigurationExporterSpanProcessorTcyN)self span_exporterargskwargss n/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/opentelemetry/sdk/_configuration/__init__.py__call__z-_ConfigurationExporterSpanProcessorT.__call__jN)rDr/returnr+__name__ __module__ __qualname__rHrBrJrGr?r?isZrJr?ceZdZddZy))_ConfigurationExporterLogRecordProcessorTcyrArB)rCexporterrErFs rGrHz2_ConfigurationExporterLogRecordProcessorT.__call__nrIrJN)rSrrKrrLrBrJrGrQrQms_rJrQc g}|D]A} |j|ttt||j fC|S#t $rt d|dt$rt d|d|dwxYw)NgroupnamezRequested entry point 'z ' not foundzRequested component 'z' not found in entry point '')appendnextiterr4loadKeyError RuntimeError StopIteration)selected_componentsentry_point_namecomponent_implementationsselected_components rG_import_config_componentsrdqs "1  % , ,&l1AHZ[\]bbd  %$ X!89I8J+VW W '(:';;WXhWiijk  s >A  3A>c6tjtdSrA)r getr"rBrJrG _get_samplerrgs ;;*D 11rJc>tjttSrA)r rfr_DEFAULT_ID_GENERATORrBrJrG_get_id_generatorrjs ;;/1F GGrJc6tjtdSrA)r rfr!rBrJrG_get_tracer_configuratorrl ;;6 ==rJc6tjtdSrA)r rfr rBrJrG_get_meter_configuratorros ;;5t <)--nbA ##$4^5Tm5T$UVWrJc *g}|xsi}|jD]_\}}|j|i}t|tr|j |di|@|j t |di|at |||}t|y)N)rmetric_readers_meter_configuratorrB)rrf issubclassr'rYr(r$r) exporters_or_readersrrmeter_configuratorrrexporter_or_reader_classrrs rG _init_metricsrs N)/R';'A'A'Cl# #)--.FK . =  ! !":"K]"K L  ! !"?@X@i[h@i"j k l%.H x rJc t||}t||xsi}|xst}|xsg}|D]} |j| |j D]4\} } |j | i} |j|| di| 6|rdt jdtttj|} tjj| t| yy)N)r_logger_configuratorzThe `OTEL_PYTHON_LOGGING_AUTO_INSTRUMENTATION_ENABLED` environment variable and the `LoggingHandler` in `opentelemetry-sdk` that it controls are deprecated.Install `opentelemetry-instrumentation-logging` package instead.)levellogger_providerrB)rr radd_log_record_processorrrfwarningswarnDeprecationWarningrloggingNOTSET getLogger addHandler_overwrite_logging_config_fns)rrsetup_logging_handlerrlog_record_processorsexport_log_record_processorlogger_configuratorrrlog_record_processorrrrhandlers rG _init_loggingrsxFYZH!)/R2M6M17R 5@))*>?@'__.]>)--nbA ))*:>;ZM;Z*[\]  O   !w~~xP&&w/%g.rJcHtjdfd }|tjjtj_|tjjtj_|tj t_y)Ncfd}|S)Ncd}jvrd}jj |i||rjyy#|rjwwxYw)NFT)handlersremover)rErFremoved_handler config_fnrroots rGoverwritten_config_fnzM_overwrite_logging_config_fns..wrapper..overwritten_config_fn,sj#O$--'"& $$W- -4*6*#OOG,#?OOG,#s A A#rB)rrrrs` rGwrapperz._overwrite_logging_config_fns..wrapper+s -%$rJ)rrrKr)rrconfig fileConfig dictConfig basicConfig)rrrs` @rGrr(sa    D%"!((A(A BGNN '(A(A BGNN!'"5"56GrJc|sy t|jgdd\}}|S#t$r!}tj d||Yd}~yd}~wwxYw)N"_opentelemetry_logger_configuratorrzMUsing default logger configurator. Failed to load logger configurator, %s: %srdrw Exceptionryrz)logger_configurator_namerlogger_configurator_implexcs rG_import_logger_configuratorrAo $ &? % + + - . 0'  ' # # $#  [ $   !( AA  Ac|sy t|jgdd\}}|S#t$r!}tj d||Yd}~yd}~wwxYw)N"_opentelemetry_tracer_configuratorrzMUsing default tracer configurator. Failed to load tracer configurator, %s: %sr)tracer_configurator_namertracer_configurator_implrs rG_import_tracer_configuratorrVrrc|sy t|jgdd\}}|S#t$r!}tj d||Yd}~yd}~wwxYw)N!_opentelemetry_meter_configuratorrzKUsing default meter configurator. Failed to load meter configurator, %s: %sr)meter_configurator_namermeter_configurator_implrs rG_import_meter_configuratorrkso # %> $ * * , - /&  & " " #"  Y #   rcni}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)rdrr/r^r&r'r)trace_exporter_namesmetric_exporter_nameslog_exporter_namestrace_exportersmetric_exporters log_exportersr{ exporter_impls rG_import_exportersrsOM ##79X YK  m\ 2-:OM *-0HIJ JK ##8:Z [ L  mnl%C D.; ] +-0IJK K L ##57T UI  m%6 7+8M- (-0FGH HI ,m ;;rJcPt|jgtd\}}|S)Nr)rdrw_OTEL_SAMPLER_ENTRY_POINT_GROUP) sampler_namer sampler_impls rG_import_sampler_factoryrs-01C1C1E0FHghijkOA| rJc|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_traceidratiorzGCould 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 TypeErrorryrz isinstancer1r)rsampler_factoryargratermessagers rG_import_samplerrs 1,? G G RYY'>CDC))34C!#&'7+)/)::MgYVopG OOG $W% % *  ij   I    s:C#BAC&C?CCC C/C**C/ct|jgdd\}}t|tr|St |d)Nopentelemetry_id_generatorrz is not an IdGenerator)rdrwrr0r^)id_generator_nameid_generator_impls rG_import_id_generatorrsX+D  "#%A,, ((#[1 "" +,,BC DDrJcd} tttd|}|jS#t$rt j dYyt$r!}t jd||Yd}~yd}~wwxYw)aNHelper for OpAMP entry points loading This in development, at the moment we are looking for a callable that takes the resource and instantiate an OpAMP agent. Since configuration is not specified every implementer may have its own. Refer to the opentelemetry-opamp-client package on how to setup the OpAMP agent. N_opentelemetry_opamprUzNo OpAMP init function foundz;Failed to load OpAMP init function from entry point, %s: %s) rZr[r4r\r_rydebugAttributeErrorrz)rW entry_pointrs rG _import_opamprsK  4 3IPT UVW !! 6 45    I     s.3A<A<A77A<c |i}|r||tj<tj|}t d}||||g}|g}|g}t |t dz|t dz|t dz\}}}|t}t|}|t}t|}| t}t|} |t}t|}|t}t!|}t#|||||| | | t%|||||9t'j(t*dj-j/dk(}t1||||| | | t d }| ||yy) Npre_sdk_init_functionr9r:r;)rrrrrrrr)rrrrfalsetrue)rrrrpost_sdk_init_function)r2TELEMETRY_AUTO_VERSIONr*createrrrrgrrjrrlrrorrqrrrrrrrwrr)auto_instrumentation_versionrrrrresource_attributesrrrrrrrrrrr _init_opampspan_exportersrrrrrrrs rG_initialize_componentsrs&" # ( .EEF 23H 78KH#!$ "!6G28<< 3I >>08873N$m #~ !,/-/+,=> "#;#= 9:RS!"9";78OP"#;#= 9:RS !+'3/ -+-  $ IIG Q W W Y _ _ aek k +3$?/ 89KHrJc@eZdZdZdZdZfdZedZdZ xZ S)_BaseConfiguratorzAn ABC for configurators Configurators are used to configure SDKs (i.e. TracerProvider, MeterProvider, Processors...) to reduce the amount of manual configuration required. NFc\|jt| ||_|jSrA) _instancesuper__new__)clsrErF __class__s rGrz_BaseConfigurator.__new__js' == !GOC0CM}}rJc y)Configure the SDKNrBrCrFs rG _configurez_BaseConfigurator._configureprIrJc (|jdi|y)rNrB)rrs rG configurez_BaseConfigurator.configurets!&!rJ) rMrNrO__doc__r_is_instrumentedrrrr __classcell__)rs@rGrr_s3I   "rJrceZdZdZdZy)_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 tjtx}r> ddlm}m}|r$tjdtt||||ytdi|y#t $r}ttd|d}~wwxYw)Nr) configure_sdkload_config_filezr is set but opentelemetry-configuration is not installed. Install it with: pip install opentelemetry-configurationz+%s is set; ignoring configurator kwargs: %srB) r rfropentelemetry.configurationr%r& ImportErrorr^ryrzsortedr)rCrF config_filer%r&rs rGrz_OTelSDKConfigurator._configures!++&67 7; 7   A$6N *;7 8 (( "'()OO  sA&& B/BBN)rMrNrOrrrBrJrGr#r#ys  )rJr#)r` Sequence[str]rastrrKzlist[tuple[str, type]])rK str | None)rKr,)r{r,r|$Literal['traces', 'metrics', 'logs'])r|r.rKz list[str])NNNNNNN)rzdict[str, type[SpanExporter]]rIdGenerator | NonerSampler | NonerResource | NonerExporterArgsMap | NonerSequence[SpanProcessor] | Noner+_ConfigurationExporterSpanProcessorT | Noner_TracerConfiguratorT | None)NNN)rz.dict[str, type[MetricExporter | MetricReader]]rr1rr2r_MeterConfiguratorT | None)NTNNNN)rz"dict[str, type[LogRecordExporter]]rr1rboolrr2r#Sequence[LogRecordProcessor] | Noner0_ConfigurationExporterLogRecordProcessorT | Noner_LoggerConfiguratorT | None)rrrKNone)rr-rKr:)rr-rKr5)rr-rKr6)rr+rr+rr+rKzxtuple[dict[str, type[SpanExporter]], dict[str, type[MetricExporter | MetricReader]], dict[str, type[LogRecordExporter]]])rr,rKz'Callable[[float | str | None], Sampler])rr-rKr0)rr,rKr0)rWz:Literal['pre_sdk_init_function', 'post_sdk_init_function']rKz!Callable[[Resource], None] | None)NNNNNNNNNNNNNNNN) r r-rlist[str] | Nonerr<rr<rr0r zAttributes | Nonerr/rz bool | Nonerr2rr3rr4rr8rr9rr5rr6rr:)ur __future__rrlogging.configrrabcrrcollections.abcrrrr typingr r r opentelemetry._logsr #opentelemetry.environment_variablesrrrropentelemetry.metricsropentelemetry.sdk._logsrrr!opentelemetry.sdk._logs._internalropentelemetry.sdk._logs.exportrr'opentelemetry.sdk.environment_variablesrrrrrrrr r!r"r#opentelemetry.sdk.metricsr$#opentelemetry.sdk.metrics._internalr% opentelemetry.sdk.metrics.exportr&r'r(opentelemetry.sdk.resourcesr)r*opentelemetry.sdk.tracer+r,r-opentelemetry.sdk.trace.exportr.r/$opentelemetry.sdk.trace.id_generatorr0 opentelemetry.sdk.trace.samplingr1opentelemetry.semconv.resourcer2opentelemetry.tracer3&opentelemetry.util._importlib_metadatar4rsrtrurxrrv_RANDOM_ID_GENERATORrirrrMrytyper,ExporterArgsMapr?rQrdrgrjrlrorqrrrrrrrrrrrrrrrrr#rBrJrGrWsM # #77))3 5 C    4C = L<4=3?-- &. #$  12 ,   ,"@ '  H %n--\0BBTJ[E\\ CH [8[``%,2H>=>#Li5ii(," $046:IM7;W,W$WW W . W 4 WGW5W@!%0459 !H!!.!3 !6!%"&04AETX7;"/1"/"/ "/. "/ ? "/ "R "/5"/J72$($ $*$($ $*#'##**<'*<(*<&*< *E D&604-1.2+/"-1'+)-046:IMAETX7;597;!d",d*d,d) d  d + d%d'd.d4dGd?d"Rd5d3d 5!dN""4+),+)rJ