ZjxUddlmZddlZddlZddlZddlZddlZddlmZddl m Z ddl m Z ddl mZddlmZmZmZmZddlmZdd lmZmZmZmZmZmZmZdd lmZeje Z!d1dZ"d2dZ#ej$e%ej&e&ej'e(ej)e"ej*e#e%ej+e#e&ej,e#e(ej-e#e"iZ.d3dZ/d4dZ0d5dZ1d6d!Z2e2d"d#d$Z3d%e4d&<d7d,Z5d8d0Z6dS)9) annotationsN)Callable)Any)parse)load_entry_point)AttributeNameValue AttributeTypeExperimentalResourceDetectorIncludeExclude)Resource)_DEFAULT_RESOURCEOTEL_SERVICE_NAMESERVICE_INSTANCE_ID SERVICE_NAMEProcessResourceDetectorr _HostResourceDetector)AttributeValuevalueobjectreturnboolcvt|tr|dvSt|S)N)false0) isinstancestrlowerr)rs g/var/www/FlaskApp/flask-venv/lib/python3.11/site-packages/opentelemetry/sdk/_configuration/_resource.py _coerce_boolr %s4%7{{}}$666 ;;coercercfdS)Nc fd|DS)Nc&g|] }|Sr&).0itemr"s r z,_array....,s!9994&&,,999r!r&)rr"s rz_array..,s99995999r!r&)r"s`r_arrayr++s 9 9 9 99r!attrrcrt|j}|||jn|jS)zLCoerce an attribute value to the correct Python type based on AttributeType.) _COERCIONSgettyper)r,r"s r_coerce_attribute_valuer1<s3 ^^DI & &F!'!366$*   Cr!attributes_listrdict[str, str]cRi}|dD]}|}|sd|vrtd|9|dd\}}t j|||<|S)zParse a comma-separated key=value string into a dict. Format is the same as OTEL_RESOURCE_ATTRIBUTES: key=value,key=value Values are always strings (no type coercion). ,=z6Invalid resource attribute pair in attributes_list: %s)maxsplit)splitstrip_loggerwarningrunquote)r2resultr(keyrs r_parse_attributes_listr@Bs  F%%c** ; ;zz||   d?? OOH    ZZaZ00 U#mEKKMM::syy{{ Mr!configResourceConfig | Noner cJtjttdi}||Si}|jr'|t |j|jr!|jD]}t|||j <|j }|}|j rki}|j j r|j j D]}t||t||j j}|r"|t|}t||} || S)aZCreate an SDK Resource from declarative config. Does NOT read OTEL_RESOURCE_ATTRIBUTES. Resource detectors are only run when explicitly listed under detection_development.detectors in the config. Starts from SDK telemetry defaults (telemetry.sdk.*), merges any detected attributes, then merges explicit config attributes on top (highest priority). Args: config: Resource config from the parsed config file, or None. Returns: A Resource with SDK defaults, optional detector attributes, and any config-specified attributes merged in priority order. unknown_service)r merger rr2updater@ attributesr1name schema_urldetection_development detectors_run_detectors_filter_attributes) rAbase config_attrsr,rIr>detected_attrsdetector_configfilteredconfig_resources rcreate_resourcerTXsL"  "8\;L,M#N#N O OD ~ ')L L263IJJKKK D% D DD&=d&C&CL # #"J F # 6,.  ' 1 @#)#?#I @ @????% F8C    6\\(8"4"455F|Z88O << ( ((r!_configrdict[str, AttributeValue]ctttji}tjtx}r ||t<|S)zDService detector: generates instance ID and reads OTEL_SERVICE_NAME.) rruuiduuid4osenvironr/rr)rUattrs service_names r_detect_servicer^sK S..(Ez~~&7888|+*l Lr!cfttjSN)dictrdetectrG_s rr*r*s$d02299;;FGGr!cfttjSr`)rarrbrGrcs rr*r*s$577>>@@KLLr!)servicehostprocessz5dict[str, Callable[[Any], dict[str, AttributeValue]]]_RESOURCE_DETECTOR_REGISTRYrQr rPdict[str, object]Nonec6tj|D]}t||jd}||jtvr.|t |j|Wt d|j}||di|pij|j D]I\}}t d|}||di|pijJdS)uRun detectors present in a single detector config entry. Known detectors (service, host, process) are handled directly via _RESOURCE_DETECTOR_REGISTRY. All other detectors — including known schema fields like container that require contrib packages, and unknown plugin detectors captured in additional_properties — are loaded via the ``opentelemetry_resource_detector`` entry point group. The detected_attrs dict is updated in-place; later detectors overwrite earlier ones for the same key. Nopentelemetry_resource_detectorr&) dataclassesfieldsgetattrrHrirFrrbrGadditional_propertiesitems)rQrPrHrcls plugin_configs rrLrLsH"?33 L LD99 =  93 3 3  ! !+DI6u==    #149C  ! !##"6"6""6"6"="="?"?"J K K K K.DJJLLPPm@$GGcc::]%8b::AACCNOOOOPPr!r\ filter_configIncludeExclude | Nonec||S|j}|j}|s|s|Si}|D]F\}|rtfd|Ds#|rtfd|DrA||<G|S)uyFilter detected attribute keys using include/exclude glob patterns. Mirrors other SDK IncludeExcludePredicate.createPatternMatching behaviour: - No filter config (attributes absent) → include all detected attributes. - included patterns are checked first; excluded patterns are applied after. - An empty included list is treated as "include everything". Nc3BK|]}tj|VdSr`fnmatchr'patr?s r z%_filter_attributes..s/NNcS 9 9NNNNNNr!c3BK|]}tj|VdSr`ryr{s rr}z%_filter_attributes..s/JJ#GOC55JJJJJJr!)includedexcludedrrany)r\rurrr>rr?s @rrMrMs %H%H H "Fkkmm U  CNNNNXNNNNN    JJJJJJJJJ  s Mr!)rrrr)r"rrr)r,rrr)r2rrr3)rArBrr )rUrrrV)rQr rPrjrrk)r\rjrurvrrj)7 __future__rrnrzloggingrZrXcollections.abcrtypingrurllibr(opentelemetry.sdk._configuration._commonr'opentelemetry.sdk._configuration.modelsrr r r r ResourceConfigopentelemetry.sdk.resourcesr rrrrropentelemetry.util.typesr getLogger__name__r;r r+stringrintdoublefloatr string_array int_array double_array bool_arrayr.r1r@rTr^ri__annotations__rLrMr&r!rrs#"""""" $$$$$$EEEEEE ONNNNN433333 ' H % % :::: #s% s VVC[[u ff\22  DDDD ,2)2)2)2)j G GLLPPPPDr!