o 3Ih)< @sddlZddlZddlmZddlmZddlmZmZddl m Z ddl m Z m Z mZmZddlmZddlmZmZdd lmZmZmZmZdd lmZdd lmZdd lmZm Z d Z!dZ"ej#ej$ej%ej&ej'ej(ej)gZ*e e eeeegZ+ej'ej$ej)ej#ej(ej,ej-ej.gZ/e e eeeegZ0ej'ej$ej)ej(ej,gZ1e egZ2dZ3GdddZ4GdddeZ5de5fddZ6de5fddZ7GdddZ8e5j9fddZ:e5j9fddZ;dd Zd%d&Z?d'd(Z@d)d*ZAd+d,ZBd-d.ZCd/d0ZDd1d2ZEd3d4ZFd5d6ZGd7d8ZHd9d:ZId;d<ZJd=d>ZKd?d@ZLdAdBZMdCdDZNdEe5j9fdFeOdGePdHeQdIeRdJe5f dKdLZSde5dMeQfdNdOZTdS)PN)Enum)http_status_to_status_code)CLIENT_ADDRESS CLIENT_PORT) ERROR_TYPE)HTTP_REQUEST_METHODHTTP_REQUEST_METHOD_ORIGINALHTTP_RESPONSE_STATUS_CODE HTTP_ROUTE)NETWORK_PROTOCOL_VERSION)SERVER_ADDRESS SERVER_PORT)URL_FULLURL_PATH URL_QUERY URL_SCHEME)USER_AGENT_ORIGINAL)SpanAttributes)Status StatusCode)gg@g$@g9@gI@gR@gY@g@o@g@@gp@g@@g@g@gL@g@)g{Gzt?g{Gz?g?g?g333333?g?g?g?g?g@g@ OTEL_SEMCONV_STABILITY_OPT_INc@seZdZdZdZdS)!_OpenTelemetryStabilitySignalTypehttpdatabaseN)__name__ __module__ __qualname__HTTPDATABASEr"r"f/home/air/sanwanet/gpt-api/venv/lib/python3.10/site-packages/opentelemetry/instrumentation/_semconv.pyrsrc@s eZdZdZdZdZdZdZdS)_StabilityModedefaultrzhttp/duprz database/dupN)rrrDEFAULTr HTTP_DUPr! DATABASE_DUPr"r"r"r#r$s r$modecCs |tjkSN)r$r&r)r"r"r# _report_news r,cCs|tjtjfvSr*)r$r r!r+r"r"r# _report_oldsr-c@sJeZdZdZeZiZeddZ e ddZ ede de fdd Zd S) )_OpenTelemetrySemanticConventionStabilityFcCs|j[|jr WddStjt}|s/tjtj tj tj i|_ d|_ WddSdd| dD}| |tjtj|j tj<| |tj tj|j tj <d|_WddS1sawYdS)NTcSsg|]}|qSr")strip).0sr"r"r# szI_OpenTelemetrySemanticConventionStability._initialize..,)_lock _initializedosenvirongetrrr r$r&r!&_OTEL_SEMCONV_STABILITY_SIGNAL_MAPPINGsplit _filter_moder'r()clsopt_in opt_in_listr"r"r# _initializes:  "z5_OpenTelemetrySemanticConventionStability._initializecCs"|j|vr|S|j|vr|StjSr*)valuer$r&)r> stable_modedup_moder"r"r#r;s  z6_OpenTelemetrySemanticConventionStability._filter_mode signal_typereturncCs|j|tjSr*)r9r8r$r&)r<rCr"r"r#(_get_opentelemetry_stability_opt_in_modeszR_OpenTelemetrySemanticConventionStability._get_opentelemetry_stability_opt_in_modeN)rrrr5 threadingLockr4r9 classmethodr? staticmethodr;rr$rEr"r"r"r#r.s $  r.cCs<i}|tjkr |n|}|D] \}}||vr|||<q|Sr*)r$r items)attrs old_attrs new_attrssem_conv_opt_in_modefiltered_attrsallowed_attributeskeyvalr"r"r#_filter_semconv_duration_attrssrScCs\i}t|r|D] \}}||vr|||<q t|r,|D] \}}||vr+|||<q|Sr*)r-rJr,)rKrLrMrNrOrQrRr"r"r#)_filter_semconv_active_request_count_attrsrTcCs|r|||<dSdSr*r"resultrQr@r"r"r#set_string_attribute s rWcCs0|rz t|||<WdStyYdSwdSr*)int ValueErrorrUr"r"r#set_int_attributes rZcCs^|}|}||krt|rt|t|t|r!t|tj|t|r-t|t|dSdSr*)r/r,rWrr-r HTTP_METHODr)rVoriginal normalizedrNr"r"r#_set_http_methods r^cC2t|r t|tj|t|rt|t|dSdSr*)r-rZrHTTP_STATUS_CODEr,r )rVcoderNr"r"r#_set_http_status_code' rbcCr_r*)r-rWrHTTP_URLr,r)rVurlrNr"r"r# _set_http_url.rcrfcCr_r*)r-rWr HTTP_SCHEMEr,r)rVschemerNr"r"r#_set_http_scheme5rcricCr_r*r-rWr HTTP_FLAVORr,r rVversionrNr"r"r#_set_http_flavor_version<rcrncCr_r*)r-rWrHTTP_USER_AGENTr,r)rV user_agentrNr"r"r#_set_http_user_agentCsrqcCr_r*)r-rWr HTTP_HOSTr,r rVhostrNr"r"r#_set_http_host_clientOrcrucCr_r*)r-rWr NET_PEER_NAMEr,r )rV peer_namerNr"r"r#_set_http_net_peer_name_clientVrcrxcCr_r*)r-rZr NET_PEER_PORTr,r rVportrNr"r"r#_set_http_peer_port_client]rcr|cCr_r*rjrlr"r"r#"_set_http_network_protocol_versiondrcr}cCr_r*)r-rWr NET_HOST_NAMEr,r rsr"r"r#_set_http_net_hostnrcrcCr_r*)r-rZr NET_HOST_PORTr,r rzr"r"r#_set_http_net_host_porturcrcCsJt|r t|tj|t|r!|rt|t||r#t|t|dSdSdSr*)r-rWr HTTP_TARGETr,rr)rVtargetpathqueryrNr"r"r#_set_http_target|s rcC@t|r t|tj|t|r|tst|t|dSdSdSr*)r-rWrrrr,r8r rsr"r"r#_set_http_host_servers rcCrr*)r-rWr NET_PEER_IPr,r8r)rViprNr"r"r#_set_http_peer_ip_servers rcCr_r*)r-rZrryr,rrzr"r"r#_set_http_peer_port_serverrcrcCr_r*)r-rWrrvr,r)rVnamerNr"r"r#_set_http_net_peer_name_serverrcrTmetrics_attributes status_codestatus_code_str server_spanrNcCs|dkr)t|r ||t<|r't|r|t||ttjd|dSdSt||d}t |rC|r>|t j |||t j <t|rh|rQ|t |||t <|tjkrh|rd|t|||t<|ru|t|dSdS)NrzNon-integer HTTP status: )r) r,r is_recording set_attribute set_statusrrERRORrr-rr`r )spanrrrrrNstatusr"r"r# _set_statussB      rrDcCs|tjurdStjS)Nz'https://opentelemetry.io/schemas/1.11.0)r$r&r SCHEMA_URLr+r"r"r#_get_schema_urls r)Ur6rFenumr#opentelemetry.instrumentation.utilsr2opentelemetry.semconv.attributes.client_attributesrr1opentelemetry.semconv.attributes.error_attributesr0opentelemetry.semconv.attributes.http_attributesrrr r 3opentelemetry.semconv.attributes.network_attributesr 2opentelemetry.semconv.attributes.server_attributesr r /opentelemetry.semconv.attributes.url_attributesrrrr6opentelemetry.semconv.attributes.user_agent_attributesropentelemetry.semconv.traceropentelemetry.trace.statusrr#HTTP_DURATION_HISTOGRAM_BUCKETS_OLD#HTTP_DURATION_HISTOGRAM_BUCKETS_NEWr`rrryrvr[rkrg_client_duration_attrs_old_client_duration_attrs_newHTTP_SERVER_NAMEr~r_server_duration_attrs_old_server_duration_attrs_new'_server_active_requests_count_attrs_old'_server_active_requests_count_attrs_newrrr$r,r-r.r&rSrTrWrZr^rbrfrirnrqrurxr|r}rrrrrrrdictrXstrboolrrr"r"r"r#s           E         ,