jh)ddlZddlmZmZddlmZddlmZmZddl m Z ddl m Z ej ejd ZGd d ZGd d ZdS)N)AsyncClientWrapperSyncClientWrapper)RequestOptions)AsyncRawOpentelemetryClientRawOpentelemetryClient)OtelResourceSpan)OtelTraceResponse.c|eZdZdefdZedefdZdddej e dej e de fd ZdS) OpentelemetryClientclient_wrapperc0t||_dSN)r)r _raw_clientselfrs k/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/langfuse/api/opentelemetry/client.py__init__zOpentelemetryClient.__init__s1PPPreturnc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawOpentelemetryClient rrs rwith_raw_responsez%OpentelemetryClient.with_raw_response rNrequest_optionsresource_spansrcH|j||}|jS)a **OpenTelemetry Traces Ingestion Endpoint** This endpoint implements the OTLP/HTTP specification for trace ingestion, providing native OpenTelemetry integration for Langfuse Observability. **Supported Formats:** - Binary Protobuf: `Content-Type: application/x-protobuf` - JSON Protobuf: `Content-Type: application/json` - Supports gzip compression via `Content-Encoding: gzip` header **Specification Compliance:** - Conforms to [OTLP/HTTP Trace Export](https://opentelemetry.io/docs/specs/otlp/#otlphttp) - Implements `ExportTraceServiceRequest` message format **Documentation:** - Integration guide: https://langfuse.com/integrations/native/opentelemetry - Data model: https://langfuse.com/docs/observability/data-model Parameters ---------- resource_spans : typing.Sequence[OtelResourceSpan] Array of resource spans containing trace data as defined in the OTLP specification request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- OtelTraceResponse Examples -------- from langfuse import LangfuseAPI from langfuse.opentelemetry import ( OtelAttribute, OtelAttributeValue, OtelResource, OtelResourceSpan, OtelScope, OtelScopeSpan, OtelSpan, ) client = LangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) client.opentelemetry.export_traces( resource_spans=[ OtelResourceSpan( resource=OtelResource( attributes=[ OtelAttribute( key="service.name", value=OtelAttributeValue( string_value="my-service", ), ), OtelAttribute( key="service.version", value=OtelAttributeValue( string_value="1.0.0", ), ), ], ), scope_spans=[ OtelScopeSpan( scope=OtelScope( name="langfuse-sdk", version="2.60.3", ), spans=[ OtelSpan( trace_id="0123456789abcdef0123456789abcdef", span_id="0123456789abcdef", name="my-operation", kind=1, start_time_unix_nano="1747872000000000000", end_time_unix_nano="1747872001000000000", attributes=[ OtelAttribute( key="langfuse.observation.type", value=OtelAttributeValue( string_value="generation", ), ) ], status={}, ) ], ) ], ) ], ) rrr export_tracesdatarrr _responses rr#z!OpentelemetryClient.export_tracess1V$22)?3  ~r)__name__ __module__ __qualname__rrpropertyr rtypingSequencer Optionalrr r#rrr r sQ*;QQQQ #9   X <@ nnn(89n 8 n  nnnnnnrr c|eZdZdefdZedefdZdddej e dej e de fd ZdS) AsyncOpentelemetryClientrc0t||_dSr)rrrs rrz!AsyncOpentelemetryClient.__init__s6nUUUrrc|jS)z Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawOpentelemetryClient rrs rrz*AsyncOpentelemetryClient.with_raw_responserrNrrrcXK|j||d{V}|jS)a **OpenTelemetry Traces Ingestion Endpoint** This endpoint implements the OTLP/HTTP specification for trace ingestion, providing native OpenTelemetry integration for Langfuse Observability. **Supported Formats:** - Binary Protobuf: `Content-Type: application/x-protobuf` - JSON Protobuf: `Content-Type: application/json` - Supports gzip compression via `Content-Encoding: gzip` header **Specification Compliance:** - Conforms to [OTLP/HTTP Trace Export](https://opentelemetry.io/docs/specs/otlp/#otlphttp) - Implements `ExportTraceServiceRequest` message format **Documentation:** - Integration guide: https://langfuse.com/integrations/native/opentelemetry - Data model: https://langfuse.com/docs/observability/data-model Parameters ---------- resource_spans : typing.Sequence[OtelResourceSpan] Array of resource spans containing trace data as defined in the OTLP specification request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- OtelTraceResponse Examples -------- import asyncio from langfuse import AsyncLangfuseAPI from langfuse.opentelemetry import ( OtelAttribute, OtelAttributeValue, OtelResource, OtelResourceSpan, OtelScope, OtelScopeSpan, OtelSpan, ) client = AsyncLangfuseAPI( x_langfuse_sdk_name="YOUR_X_LANGFUSE_SDK_NAME", x_langfuse_sdk_version="YOUR_X_LANGFUSE_SDK_VERSION", x_langfuse_public_key="YOUR_X_LANGFUSE_PUBLIC_KEY", username="YOUR_USERNAME", password="YOUR_PASSWORD", base_url="https://yourhost.com/path/to/api", ) async def main() -> None: await client.opentelemetry.export_traces( resource_spans=[ OtelResourceSpan( resource=OtelResource( attributes=[ OtelAttribute( key="service.name", value=OtelAttributeValue( string_value="my-service", ), ), OtelAttribute( key="service.version", value=OtelAttributeValue( string_value="1.0.0", ), ), ], ), scope_spans=[ OtelScopeSpan( scope=OtelScope( name="langfuse-sdk", version="2.60.3", ), spans=[ OtelSpan( trace_id="0123456789abcdef0123456789abcdef", span_id="0123456789abcdef", name="my-operation", kind=1, start_time_unix_nano="1747872000000000000", end_time_unix_nano="1747872001000000000", attributes=[ OtelAttribute( key="langfuse.observation.type", value=OtelAttributeValue( string_value="generation", ), ) ], status={}, ) ], ) ], ) ], ) asyncio.run(main()) r!Nr"r%s rr#z&AsyncOpentelemetryClient.export_tracessSf*88)?9        ~r)r'r(r)rrr*rrr+r,r r-rr r#r.rrr0r0sV*<VVVV #>   X <@ vvv(89v 8 v  vvvvvvrr0)r+core.client_wrapperrrcore.request_optionsr raw_clientrr types.otel_resource_spanr types.otel_trace_responser castAnyOMITr r0r.rrr<s GGGGGGGG111111KKKKKKKK666666888888v{6:s##}}}}}}}}@EEEEEEEEEEr