o i'` @sddlmZddlZddlZddlmZddlmZddlmZddlm Z ddl m Z ddl m Z dd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZe e Z!dZ"Gddde#Z$Gddde#Z%         dLdefddZ&ddZ'dd Z(d!d"Z)d#d$Z*d%d&Z+d'e,e-efd(e d)ee,e-efd*e-de.eee/ff d+d,Z0d'e,e-efd(e d)eed*e-de.eee/ff d-d.Z1d'e,e-efd(e d)ee,e-efd*e-de.eee/ff d/d0Z2d'e,e-efd(e d)ee,e-efd*e-de.eee/ff d1d2Z3d'e,e-efd(e d)eed*e-de.eee/ff d3d4Z4d'e,e-efd(e d)eed*e-de.eee/ff d5d6Z5d'e,e-efd(e d)eed*e-de.eee/ff d7d8Z6d9e,e-efd*e-d:e7d(e deef d;d<Z8d=e,e-efd)eed(e deefd>d?Z9d@e,e-efd*e-d:e7d(e deef dAdBZ:dCe,e-efd*e-d:e7d(e deef dDdEZ;dFe,e-efd(e d)eedeefdGdHZdS)M)timezoneN)Any)Literal)Optional)Span) get_logger)generate_128bit_trace_id)format_trace_id)LLMOBS_TRACE_ID)parse_model_id) _get_ml_app)_get_session_id) safe_json)LLMObsSpanEvent)Message) _ErrorField)_Meta)_MetaIO) _SpanField.Ac@eZdZdZdS)"BedrockGuardrailTriggeredExceptionzMCustom exception to represent Bedrock Agent Guardrail Triggered trace events.N__name__ __module__ __qualname____doc__rr_/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/llmobs/_integrations/bedrock_agents.pyrrc@r)BedrockFailureExceptionzACustom exception to represent Bedrock Agent Failure trace events.Nrrrrrr %rr returnc Cs| durt} t|j} |t}|dur|j}t|}t|}d|d|dg}|t| t|t|p7|j|t |p>|j t |pCt |rHdndt t |ditttdit| t|| dd }| durn| |d d <|d krtd nd}| durd|d vr| |d d|<| durd|d vr| |d d|<|durd|d vr||d dd<|durd|d vr||d dd<|S)Nzml_app:z session_id:zintegration:bedrock_agentserrorok)kind)spanmetadatainputoutputr")span_idtrace_id apm_trace_id) namer)r* parent_idtagsstart_nsdurationstatusmetametrics_ddr2r&llmmessagesvaluer'r(messagetype)rr r* _get_ctx_itemr r r strr)intr/DEFAULT_SPAN_DURATIONrrrr) span_name root_spanr- span_kindr/ duration_nsr" error_msg error_typer)r& input_val output_valr+llmobs_trace_id session_idml_appr. span_eventio_keyrrr_build_span_event+sT       rKcCs|di}|rt|trt|dkrdStt|\}}|r&t|ts(dSd|vr5|dvr5|dSt|dkr=dStt|\}}|dS)a"Extracts the trace step ID from a Bedrock trace object. Due to the union structure of bedrock traces (only one key-value pair representing the actual trace object), some trace types have the trace step ID in the underlying trace object, while others have it in a nested object. traceNtraceIdcustomOrchestrationTrace failureTraceguardrailTraceget isinstancedictlennextiteritemsbedrock_trace_obj trace_part trace_type_rrr_extract_trace_step_idhs    r`cCsB|di}|rt|trt|dkrdStt|\}}|S)z_Extracts the first key from a Bedrock trace object, which represents the underlying trace type.rLrMNrSr[rrr_extract_trace_type{s racCs:|d}|r|jtjdd}t|S|j}t|S)N eventTimetzinfoeArTreplacerutc timestampr/r<)r\r?r/rrr_extract_start_nss rjcCsL|d}|r|jtjdd}n|j}|ddd}t|t|fS)zeExtracts the start time and duration from the Bedrock trace metadata (non-orchestration trace types). startTimercre totalTimeMsrMrrf)bedrock_metadatar?r/rArrr)_extract_start_and_duration_from_metadatas rnc Cst|pd}||}|s.|s|jn|d|j}td|||jd||d|id}|||<|didi}|sR|rR|didrR|did|dd<|rj|did rj|did |dd <|rv|drv|d sx|St|d |d|d|d <|S) zCreates/updates a Bedrock trace step span based on the provided trace and inner span event. Sets the trace step span's input from the first inner span event, and the output from the last inner span event. z Bedrock Agentr/z{} Stepworkflowbedrock_trace_id)r>r?r-r@r/r)r&r2r'r(r0)rarTr/rKformatr)r<) rL trace_step_idinner_span_eventr? span_dictr^rIr/trace_step_inputrrr)_create_or_update_bedrock_trace_step_spans.    rvrLr?current_active_spanrrc Cs`|didi}t||}|di}|rt|tsdStd||d||ddd }|d fS) zTranslates a custom orchestration bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating if the trace is finished. rLrPeventNFcustomOrchestrationtasktext)r>r?r-r@r/rEF)rTrjrUrVrK)rLr?rwrrcustom_orchestration_tracer/custom_orchestration_eventrIrrr%_translate_custom_orchestration_traces   rc Cs|didi}t||}|di}|r t||||dfS|di}|r0t|||dfS|di}|rAt||||dfS|di} | rRt| |||dfS|d i} | rgt| trgt| ||dfSd S) zTranslates an orchestration bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating if the trace is finished. rLorchestrationTracemodelInvocationInputFmodelInvocationOutputT rationaleinvocationInput observationry) rTrj_model_invocation_input_span_model_invocation_output_span_rationale_span_invocation_input_spanrUrV_observation_span) rLr?rwrrorchestration_tracer/model_invocation_inputmodel_invocation_outputrinvocation_inputrrrr_translate_orchestration_traces$      rc Cs|didi}|di}t||\}}zt|ddty/|jtYnw|dd}|dd} td||d||d || d } | d fS) zTranslates a failure bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating that the span is finished. rLrQr& failureReasonr} failureType failureEventr{T) r>r?r-r@r/rAr"rBrC)rTrnr set_exc_infosysexc_inforK) rLr?rwrr failure_tracefailure_metadatar/rArBrCrIrrr_translate_failure_traces,     rc Cs|didi}|di}t||\}}|dd}||dg|dgd} t|d k} td ||d ||| | r=d nd | rBdnd t| d } | rcztd tyb|jtY| dfSw| dfS)zTranslates a guardrail bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating that the span is finished. rLrRr&actionr}inputAssessmentsoutputAssessments)rrr INTERVENED guardrailr{zGuardrail intervenedNGuardrailTriggered) r>r?r-r@r/rAr"rBrCrET) rTrnboolrKrrrrr) rLr?rwrrguardrail_traceguardrail_metadatar/rArguardrail_outputguardrail_triggeredrIrrr_translate_guardrail_traces:         rcCd|didi}t||}|di}|r t||||dfS|di}|r0t|||dfSdS)zTranslates a postprocessing bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating if the span is finished. rLpostProcessingTracerFrTryrTrjrr)rLr?rwrrpostprocessing_tracer/rrrrr _translate_post_processing_trace&   rcCr)zTranslates a preprocessing bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating if the span is finished. rLpreProcessingTracerFrTryr)rLr?rwrrpreprocessing_tracer/rrrrr_translate_pre_processing_trace7rrc Cs|didi}t||}|di}|r t||||dfS|di}|r0t|||dfS|di}|rAt||||dfS|di} | rVt| trVt| ||dfSd S) zTranslates a routing classifier bedrock trace into a LLMObs span event. Returns the translated span event and a boolean indicating if the span is finished. rLroutingClassifierTracerFrTrrry)rTrjrrrrUrVr) rLr?rwrr routing_tracer/rrrrrrr#_translate_routing_classifier_traceHs     r model_inputr/c Cs|dd}t|\}}z t|dd}Wntjtfy*tdi}Ynwt|ddddg}|dgD]} | t| d d| d ddqTranslates a Bedrock rationale trace into a LLMObs span event. reasoningr{r|r})r/rE)rKrT)rrrr/r?rIrrrrsrrc Cs:d}i}i}|dd}|dkr6|di}|d}|di} dd| D}|d d|d dd }nX|d krT|d i}|d}dt|diddi}n:|dkru|di}|d}t|ddt|ddd}n|dkr|di}|d}dt|ddi}t|||d||t|d} | S)zETranslates a Bedrock invocation input trace into a LLMObs span event.r}invocationType ACTION_GROUPactionGroupInvocationInputactionGroupName parameterscSsi|] }|dt|dqS)r,r7)r;).0argrrr sz*_invocation_input_span..function executionType)rexecution_typeAGENT_COLLABORATOR agentCollaboratorInvocationInputagentCollaboratorNamer|r'ACTION_GROUP_CODE_INTERPRETERcodeInterpreterInvocationInputcodefiles)rrKNOWLEDGE_BASEknowledgeBaseLookupInputknowledgeBaseIdtool)r&rD)rTr;rKr) rrrr/r?r> tool_metadata tool_argsinvocation_typebedrock_tool_callparamsrIrrrrs8          $  rrc Cs>|dd}|dvr dS|stddSd}i}|dkr0|di}|di}|d d}nL|d krK|d i}|di}|d id d}n1|d krf|di}|di}|did d}n|dkr||di}|di}|dd}t||\}}t||d<t||d<d |dvr||dd d<|S)z@Translates a Bedrock observation trace into a LLMObs span event.r9r})FINISHREPROMPTNz Error in processing observation.ractionGroupInvocationOutputr&r|r!agentCollaboratorInvocationOutputr(rknowledgeBaseLookupOutputretrievedReferencesrcodeInterpreterInvocationOutputexecutionOutputr/r0r2r7)rTrrrnr<) rr?rwobservation_type output_valuerm output_chunkr/rArrrrs<              r)rPrQrRrrrrc Cst|pd}|tvrtd||dS|di|i}|r$t|ts-td||dS|dvr@t|dkr@td||dSt|}|||||\}}||fS)zTranslates a Bedrock trace into a LLMObs span event. Routes the trace to the appropriate translation method based on the trace type. Returns the translated span event and a boolean indicating if the span is finished. r}z0Unsupported trace type '%s' in Bedrock trace: %sryrLz/Invalid trace structure for trace type '%s': %srOrM)ra'BEDROCK_AGENTS_TRACE_CONVERSION_METHODSrrrTrUrVrW) rLr?current_active_span_eventrrr^nested_trace_dicttranslation_methodtranslated_span_eventfinishedrrrtranslate_bedrock_traces r) NNNNNNNNN)?datetimerrrtypingrrrddtrace._trace.spanrddtrace.internal.loggerrddtrace.internal.nativerddtrace.internal.utils.formatsr ddtrace.llmobs._constantsr *ddtrace.llmobs._integrations.bedrock_utilsr ddtrace.llmobs._utilsr r rddtrace.llmobs._writerrddtrace.llmobs.typesrrrrrrrr= Exceptionrr rKr`rarjrnrvrVr;tuplerrrrrrrrr<rrrrrrrrrrrsf                     =           $              #  (