o i @sddlZddlmZddlmZddlZddlmZddlm Z ddl m Z ddl m Z ddlmZdd lmZe eZd Zed d ejjd ddDZdZdad!ddZdefddZdeefddZde ede!de!de efddZ"ddZ#dd Z$dS)"N)Any)Optional)config) get_hostname) get_logger) otel_config)telemetry_writer)TELEMETRY_NAMESPACE)rcc|]}t|VqdSNint.0xrW/home/ubuntu/.local/lib/python3.10/site-packages/ddtrace/internal/opentelemetry/logs.py r.grpcFreturncCsVtsdSt}|durdStjj}t|}|durdSt|||s$dSdadt_ dS)zASet up the OpenTelemetry Logs exporter if not already configured.NTF) _should_configure_logs_exporter_build_resourcerexporter LOGS_PROTOCOL_import_exporter_initialize_loggingDD_LOGS_PROVIDER_CONFIGUREDr_logs_injection)resourceprotocolexporter_classrrrset_otel_logs_providers  r&c Cstr tddSttkr&tddddtDdddtDdSzdd lm}|d ur9td WdSWntyU}ztd t |WYd }~dSd }~wwt d dS)z>Check if the OpenTelemetry Logs exporter should be configured.zNOpenTelemetry Logs exporter was already configured by ddtrace, skipping setup.FzOpenTelemetry API requires version %s or higher to enable logs collection. Found version %s. Please upgrade the opentelemetry-api package before enabling ddtrace OpenTelemetry Logs support.rcsr r strrrrrr:rz2_should_configure_logs_exporter..csr r r'rrrrr;rr)_LOGGER_PROVIDERNzfOpenTelemetry Logs provider was configured before ddtrace instrumentation was applied, skipping setup.z0OpenTelemetry Logs support is not available: %s.zMOpenTelemetry Logs exporter is not configured, proceeding with ddtrace setup.T) r!logwarning API_VERSIONMINIMUM_SUPPORTED_VERSIONjoinopentelemetry._logs._internalr) ImportErrorr(debug)logger_providererrrr0s8   rcCs~z/ddlm}itjtjtjtjd}tjr!d|vr!t|d<dd| D}| |WSt y>t dYdSw) zKBuild an OpenTelemetry Resource using DD_TAGS and OTEL_RESOURCE_ATTRIBUTES.r)Resource)z service.namezservice.versionzdeployment.environmentz host.namecSs&i|]\}}||durt|ndqS)Nr')rkvrrr as&z#_build_resource..zOpenTelemetry SDK is not installed, opentelemetry logs will not be enabled. Please install the OpenTelemetry SDK before enabling ddtrace OpenTelemetry Logs support.N)opentelemetry.sdk.resourcesr4rtagsserviceversionenv_report_hostnameritemscreater0r*r+)r4resource_attributesrrrrRs&    r otel_exporterr$encodingcsGfddd|}|S)zWCreate a custom OpenTelemetry Logs exporter that adds telemetry metrics and debug logs.cs6eZdZdZdedededeffdd ZZS)z)_dd_logs_exporter..DDLogsExporterzPA custom OpenTelemetry Logs exporter that adds telemetry metrics and debug logs.batchargskwargsrcsPttjdt|dfdfftdt|tj|g|Ri|S)z)Export logs and queues telemetry metrics.zotel.log_recordsr$rCz@Exporting %d OpenTelemetry Logs with %s protocol and %s encoding) radd_count_metricr TRACERSlenr*r1superexport)selfrDrErF) __class__rCr$rrrKrs z0_dd_logs_exporter..DDLogsExporter.export)__name__ __module__ __qualname____doc__rrK __classcell__rrCr$)rMrDDLogsExporteros*rTr)rBr$rCrTrrSr_dd_logs_exporterlsrUc CszT|dkrddlm}ddlm}n|dkr#ddlm}ddlm}n td|WdStdd | d dd Dt krItd |t |WdSt || d ddWSt yw}ztd||dkrfdndt |WYd}~dSd}~ww)zLImport the appropriate OpenTelemetry Logs exporter based on the set protocolrr)OTLPLogExporter) __version__z http/protobufzZOpenTelemetry Logs exporter protocol '%s' is not supported. Use 'grpc' or 'http/protobuf'.Ncsr r rrrrrrrz#_import_exporter..rrzOpenTelemetry Logs exporter for %s requires version %r or higher, but found version %r. Please upgrade the appropriate opentelemetry-exporter package./protobufzOpenTelemetry Logs exporter for %s is not available. Please install a supported package (ex: opentelemetry-exporter-otlp-proto-%s): %shttp)4opentelemetry.exporter.otlp.proto.grpc._log_exporterrV.opentelemetry.exporter.otlp.proto.grpc.versionrW4opentelemetry.exporter.otlp.proto.http._log_exporter.opentelemetry.exporter.otlp.proto.http.versionr*r+tuplesplitr-rUr0r()r$rVexporter_versionr3rrrrs>  $rc Cs|z"ddlm}dtjvrdtjvrtjjtjd<|||i|dWdSty=}zt dt |WYd}~d Sd}~ww) z7Configures and sets up the OpenTelemetry Logs exporter.r) _init_loggingOTEL_EXPORTER_OTLP_ENDPOINT OTEL_EXPORTER_OTLP_LOGS_ENDPOINT)r#TzThe installed OpenTelemetry SDK is missing required components: %s. Logging exporter not initialized. Please file an issue at github.com/Datadog/dd-trace-py.NF) opentelemetry.sdk._configurationrbosenvironrr LOGS_ENDPOINTr0r*r+r()r%r$r#rbr3rrrr s r )rN)%rftypingrropentelemetry.version opentelemetryddtracerddtrace.internal.hostnamerddtrace.internal.loggerr(ddtrace.internal.settings._opentelemetryrddtrace.internal.telemetryr$ddtrace.internal.telemetry.constantsr rNr*r-r_r<rWr`r,DEFAULT_PROTOCOLr!r&boolrrtyper(rUrr rrrrs*        $ "" '