o i!@sddlmZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZdd lmZdd lmZdd lmZd dlmZd dlmZd dlmZddZddZddZddZddZ dS))deque) HTTPError)config) trace_utils) SpanTypes)core)BlockingException)schematize_url_operation) SpanDirection) ArgumentError)get_argument_value)tracer) CONFIG_KEY)REQUEST_SPAN_KEY)TracerStackContextcsjt}|d}|d}tZtjdtddtjdtj |ij j t j d|dd &}|j}j } t| dd } t| d d} t| d d } t| d d } | d | | }t| dd }t| drc| jnt| di}ddt| diD}fddjD}|dd|d|td|t j ftjjjj \}}|durt|tr|d|t| t |t!j"|t j | |||||| j#|d||d t$ddfj%}|r|j&dur|j&IdHWdWdSz||i|IdHWWdWdSt'yK}z6t$dd|j(dfj%}|rA|j&durA|j&IdHWYd}~WdWdSWYd}~nd}~wwWdn1sWwYWddSWddS1spwYdS)z Wrap the handler execute method so that the entire request is within the same ``TracerStackContext``. This simplifies users code when the automatic ``Context`` retrieval is used via ``Tracer.trace()`` method. default_servicedistributed_tracingztornado.requesthttp)protocol directionT) span_name span_typeservicetagsdistributed_headersintegration_configactivate_distributed_headers#distributed_headers_config_overrideheaders_case_sensitivemethodrhosturiz://query argumentsquery_argumentscSsi|] \}}||qS)lower).0kvr'r']/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/contrib/internal/tornado/handlers.py 8szexecute..headerscsi|]}||qSr') get_cookie)r)r*handlerr'r,r-9scookieNreq_spanzweb.request.startz http.route) r urlr$request_headersraw_uri parsed_querypeer_iprouteheaders_are_case_sensitiverequest_cookiesrequest_path_paramsztornado.start_requesttornadoztornado.block_requestr))settingsrrrcontext_with_datar r INBOUNDrWEBrequestr.rr=spangetattrhasattrr%itemscookieskeyspopset_itemdispatch _find_route applicationdefault_routerrules isinstancestr _set_tag_strsetattrrr set_http_meta remote_ipdispatch_with_resultstornado_futurevaluerargs)funcr1rYkwargsr>rrctxr3rBr rr"r#full_url query_stringquery_parametersr.rG http_route path_params dispatch_resbr'r0r,executes             688 $rdcCst}|D]}||qt|dkrJ|}|j|}durDt|jdr7|jj|dgp5|difSt|j drD| |j j t|dksdifS)zd We have to walk through the same chain of rules that tornado does to find a matching rule. rN_path path_args path_kwargsrOz^$) rappendlenpopleftmatchermatchrEregettarget extendleftrO)initial_rule_setrBrOrulemr'r'r,rL`s      rLcCstdd|f||i|S)z3 Wrap the ``RequestHandler.flush`` method. ztornado.send_responser=)rrK)rZr1rYr[r'r'r, _on_flushtsrsc Csv|j}t|td}|r4|j}d|j|j|_t d|t j |j | ddd||jddddf ||i|S)z Wrap the ``RequestHandler.on_finish`` method. This is the last executed method after the response has been sent, and it's used to retrieve and close the current request span (if available). Nz{}.{}zweb.request.finish?rrT)rBrDr __class__format __module____name__resourcerrKrr=r r]rsplit get_statusr$)rZr1rYr[rB request_spanklassr'r'r, on_finish}s( r~cCsz t||dd}Wn tyd}Ynw|s||i|St}|s+||i|St|tr=tj|j r<|j |n|j |||i|S)a@ Wrap the ``RequestHandler.log_exception``. This method is called when an Exception is not handled in the user code. In this case, we save the exception in the current active span. If the Tornado ``Finish`` exception is raised, this wrapper will not be called because ``Finish`` is not an exception. rrXN) r r r current_spanrPrr _http_server is_error_code status_code set_exc_info)rZr1rYr[rXrr'r'r, log_exceptions     rN)! collectionsr tornado.webrddtracerddtrace.contrib.internalr ddtrace.extrddtrace.internalrddtrace.internal._exceptionsrddtrace.internal.schemar -ddtrace.internal.schema.span_attribute_schemar ddtrace.internal.utilsr r ddtrace.tracer constantsrr stack_contextrrdrLrsr~rr'r'r'r,s(              K