o 3Ih*@s6ddlZddlZddlmZddlmZddlmZmZm Z m Z m Z ddl m Z eeeeefZedeeeeee efZeeZdede jdeed ee e je e eeefd fffd d Zde jdeed e jfd dZdede jdeed e jfddZde jdeed ee jfddZGdddeZdS)N) OrderedDict)MutableMapping)MappingOptionalSequenceTupleUnion)typeskeyvaluemax_lenreturn.cCs|rt|tstd|dSt|trt||St|trrd}g}|D]I}t||}|dur5||q$t|}|tvrNtd|j |ddtDdS|durU|}n||krhtd||j t|j dS||q$t |Stdt|j |ddtDdS) akChecks if attribute value is valid and cleans it if required. The function returns the cleaned value or None if the value is not valid. An attribute value is valid if it is either: - A primitive type: string, boolean, double precision floating point (IEEE 754-1985) or integer. - An array of primitive type values. The array MUST be homogeneous, i.e. it MUST NOT contain values of different types. An attribute needs cleansing if: - Its length is greater than the maximum allowed length. - It needs to be encoded/decoded e.g, bytes to strings. +invalid key `%s`. must be non-empty string.NzLInvalid type %s in attribute '%s' value sequence. Expected one of %s or NonecSg|]}|jqS__name__.0 valid_typerra/home/air/sanwanet/gpt-api/venv/lib/python3.10/site-packages/opentelemetry/attributes/__init__.py Usz$_clean_attribute..z>Attribute %r mixes types %s and %s in attribute value sequencezYInvalid type %s for attribute '%s' value. Expected one of %s or a sequence of those typescSrrrrrrrrt) isinstancestr_loggerwarning_VALID_ATTR_VALUE_TYPES_clean_attribute_valuerappendtypertuple)r r r sequence_first_valid_type cleaned_seqelement element_typerrr_clean_attribute*sV         r&cCsb|dus t|tr|durt|tr|d|}|St|trCi}|D]\}}|r0t|ts7td|q%t|||d||<q%|St|trd}g}|D]K}|durZ| |qN|durit|tri|d|}t |}|tvr{t ||d}t |}|dur|}n||krtd|j t |j dS| |qNt |Stdt |j dddtDd ) Nr)r r r r z1Mixed types %s and %s in attribute value sequencez Invalid type z& for attribute value. Expected one of cSrrrrrrrrrz3_clean_extended_attribute_value..z or a sequence of those types)rrrritemsrr_clean_extended_attributerrr _clean_extended_attribute_valuerr! TypeError_VALID_ANY_VALUE_TYPES)r r cleaned_dictr r$r"r#r%rrrr*ys^        r*c Csb|rt|tstd|dSzt||dWSty0}ztd||WYd}~dSd}~ww)a.Checks if attribute value is valid and cleans it if required. The function returns the cleaned value or None if the value is not valid. An attribute value is valid if it is an AnyValue. An attribute needs cleansing if: - Its length is greater than the maximum allowed length. rNr'zAttribute %s: %s)rrrrr*r+)r r r exceptionrrrr)s r)limitcCsd|durdSt|tr!z|}Wnty tdYdSw|dur0t|tr0|d|}|S)Nz$Byte attribute could not be decoded.)rbytesdecodeUnicodeDecodeErrorrrr)r r/rrrrs     rc @seZdZdZ     ddeedeejdedeed ef d d Z d e fd dZ de d ej fddZ de dej d dfddZde d dfddZddZd efddZddZdS)BoundedAttributeszAn ordered dict with a fixed max capacity. Oldest elements are dropped when the dict is full and a new element is added. NTFmaxlen attributes immutable max_value_lenextended_attributescCsr|durt|tr |dkrtd||_d|_||_||_i|_t |_ |r4| D]\}}|||<q+||_ dS)Nrz.maxlen must be valid int greater or equal to 0) rint ValueErrorr4droppedr7_extended_attributes_dict threadingRLock_lockr( _immutable)selfr4r5r6r7r8r r rrr__init__s    zBoundedAttributes.__init__r cCs t|jSN)dictr=rBrrr__repr__ s zBoundedAttributes.__repr__r cCs |j|SrD)r=rBr rrr __getitem__ zBoundedAttributes.__getitem__r cCst|ddrt|jx|jdur&|jdkr&|jd7_ WddS|jr1t|||j}nt|||j}|durE WddS||j vrO|j |=n'|jdurvt |j |jkrvt |j t sht |j |_ |j j dd|jd7_||j |<WddS1swYdS)NrAFr)last)getattrr+r@r4r;r<r)r7r&r=lenrrpopitem)rBr r rrr __setitem__s0      "zBoundedAttributes.__setitem__cCsDt|ddrt|j |j|=WddS1swYdS)NrAF)rMr+r@r=rHrrr __delitem__,s  "zBoundedAttributes.__delitem__cCs8|jt|jWdS1swYdSrD)r@iterr=copyrFrrr__iter__2s $zBoundedAttributes.__iter__cCs t|jSrD)rNr=rFrrr__len__6rJzBoundedAttributes.__len__cCs |jSrD)r=rSrFrrrrS9rJzBoundedAttributes.copy)NNTNF)r __module__ __qualname____doc__rr9r _ExtendedAttributesboolrCrrGAnyValuerIrPrQrTrUrSrrrrr3s2  r3) loggingr> collectionsrcollections.abcrtypingrrrrropentelemetry.utilr rZrr0r9floatrr r, getLoggerrrAttributeValuer&r[r*r)rr3rrrrsd    " O E