]jl)dZddlZddlZddlZddlZ ddlZddlZddl m Z dZ dZ dZ dZdZd Zd Zd Zd Zd ZdZdZdZdZdZdZy#e$rdZY;wxYw)z&Helper functions for logging handlers.N)_get_django_requestCONTENT_LENGTHHTTP_X_CLOUD_TRACE_CONTEXTHTTP_TRACEPARENTHTTP_USER_AGENT REMOTE_ADDR HTTP_REFERERX_CLOUD_TRACE_CONTEXT TRACEPARENTSERVER_PROTOCOLctj|j\}}|t|t|dzd|j|j d}t jdttj|dS)zHelper to format a LogRecord in in Stackdriver fluentd format. Returns: str: JSON str to be written to the log file. DEPRECATED: use StructuredLogHandler to write formatted logs to standard out instead. geA)secondsnanos)message timestampthreadseverityzHformat_stackdriver_json is deprecated. Use StructuredLogHandler instead.F) ensure_ascii) mathmodfcreatedintr levelnamewarningswarnDeprecationWarningjsondumps)recordr subsecondsecondpayloads S/root/env/lib/python3.12/site-packages/google/cloud/logging_v2/handlers/_helpers.pyformat_stackdriver_jsonr$*ss &..1Iv!$Vs9s?7KL--$$ G  MMR ::gE 22c8ttjsytjjtjjtjjj tjj jtd}tjjjt}t|\}}}|? L]] " " & &'9 :F':6'B$Hg}&&**+EF+>v+F('= 7M 99r%ct}|y |j}|j||jj t |jj td}|jj t}t|\}}}|.|jj t}t|\}}}||||fS#t$rd}YwxYw)aCGet http_request and trace data from django request headers. Returns: Tuple[Optional[dict], Optional[str], Optional[str], bool]: Data related to the current http request, trace_id, span_id, and trace_sampled for the request. All fields will be None if a django request isn't found. Nr'r() rbuild_absolute_uri Exceptionr/METAr4_DJANGO_USERAGENT_HEADERr5_DJANGO_TRACEPARENTr8_DJANGO_XCLOUD_TRACE_HEADERr:)r. request_urlr;r<r=r>r?s r#get_request_data_from_djangorI`s"#G&002 !!\\%%&>?LL$$%56 L\\  1 2F':6'B$Hg}!!"=>+>v+F('= 7M 99)  sC CCc 8dx}}d}|ry d}d}d}d}d|d|d|d|d }tj||} | jd }| jd }t| jd d } t | dz}|||fS#t t f$rYwxYw)aGiven a w3 traceparent header, extract the trace and span ids. For more information see https://www.w3.org/TR/trace-context/ Args: header (str): the string extracted from the traceparent header example: 00-0af7651916cd43dd8448eb211c80319c-b7ad6b7169203331-01 Returns: Tuple[Optional[dict], Optional[str], bool]: The trace_id, span_id and trace_sampled extracted from the header Each field will be None if header can't be parsed in expected format. NFz(?!ff)[a-f\d]{2}z(?![0]{32})[a-f\d]{32}z(?![0]{16})[a-f\d]{16}z [a-f\d]{2}z^\s?(z)-(z )(-.*)?\s?$)rematchgrouprbool IndexErrorAttributeError) r<r=r>r? VERSION_PART TRACE_ID_PARTPARENT_ID_PART FLAGS_PARTregexrQint_flags r#r8r8sHwM  .L5M6N&J\N#m_C?OsS]R^^jkEHHUF+E{{1~Hkk!nG5;;q>2.H A.M Wm ++N+   sA8BBBc@dx}}d}|rl d}tj||}|jd}|jd}|jddk(} t|}|dkDr |d kr|d }nd}|||fS#tt f$rd}YwxYw#t $rY'wxYw) aWGiven an X_CLOUD_TRACE header, extract the trace and span ids. Args: header (str): the string extracted from the X_CLOUD_TRACE header Returns: Tuple[Optional[str], Optional[str], bool]: The trace_id, span_id and trace_sampled extracted from the header Each field will be None if not found. NFz"([\w-]+)?(\/?([\w-]+))?(;?o=(\d))?rOrL1rl016x)rPrQrRr ValueError TypeErrorrT)r<r=r>r?rZrQ span_id_ints r#r:r:sHwM 9EHHUF+E{{1~Hkk!nG!KKNc1M !'l ?{U':!,T 2G"G Wm ++  *     s0ABA::B B BB BBctjj}|tjjjk7r}|j }tjj |j}tjj|j}|jj}|||fSy)arHelper to retrieve trace, span ID, and trace sampled information from the current OpenTelemetry span. Returns: Tuple[Optional[str], Optional[str], bool]: Data related to the current trace_id, span_id, and trace_sampled for the current OpenTelemetry span. If a span is not found, return None/False for all fields. NNF) opentelemetrytraceget_current_spanspan INVALID_SPANget_span_contextformat_trace_idr=format_span_idr> trace_flagssampled)rhcontextr=r>r?s r#%_retrieve_current_open_telemetry_spanrps    / / 1D }""''444'') &&66w7G7GH%%44W__E++33 -// r%ct\}}}ttf}d\}}}}|D]}|\}}}}|d\}}}n|r||||fS||||fS)a[Helper to get http_request and trace data from supported web frameworks (currently supported: Flask and Django), as well as OpenTelemetry. Attempts to retrieve trace/spanID from OpenTelemetry first, before going to Traceparent then XCTC. HTTP request data is taken from a supporting web framework (currently Flask or Django). Because HTTP request data is decoupled from OpenTelemetry, it is possible to get as a return value the HTTP request from the web framework of choice, and trace/span data from OpenTelemetry, even if trace data is present in the HTTP request headers. Returns: Tuple[Optional[dict], Optional[str], Optional[str], bool]: Data related to the current http request, trace_id, span_id, and trace_sampled for the request. All fields will be None if a http request isn't found. r'rd)rprIr@) otel_trace_id otel_span_idotel_trace_sampledcheckersr; http_trace_id http_span_idhttp_trace_sampledcheckers r#get_request_datarzs& ./  %#H EAL-/AHO E m\3E  >O ;M<);  ]L:LLL]L:LLLr%)__doc__rrrPrr- ImportErroropentelemetry.tracere3google.cloud.logging_v2.handlers.middleware.requestr_DJANGO_CONTENT_LENGTHrGrFrE_DJANGO_REMOTE_ADDR_HEADER_DJANGO_REFERER_HEADERr9r7r5r$r@rIr8r:rprzr%r#rs- S):(,*'4"$3.:>%:P ,F*,Z,-Mm EsA AA