§ jó"ãó²—ddlZddlmZmZddlmZddlmZmZddl m Z ddl m Z ej ejd ¦«ZGd „d ¦«ZGd „d ¦«ZdS)éNé)ÚAsyncClientWrapperÚSyncClientWrapper)ÚRequestOptionsé)ÚAsyncRawIngestionClientÚRawIngestionClient)ÚIngestionEvent)ÚIngestionResponse.c ó¢—eZdZdefd„Zedefd„¦«Zeddœde j e de j e j d e j edefd „ZdS) ÚIngestionClientÚclient_wrappercó0—t|¬¦«|_dS©N)r)r Ú _raw_client©Úselfrs úg/lsinfo/ai/hellotax_ai/base_platform/venv/lib/python3.11/site-packages/langfuse/api/ingestion/client.pyÚ__init__zIngestionClient.__init__s€Ý-¸^ÐLÑLÔLˆÔÐÐóÚreturncó—|jS)z— Retrieves a raw implementation of this client that returns raw responses. Returns ------- RawIngestionClient ©r©rs rÚwith_raw_responsez!IngestionClient.with_raw_responseó €ðÔÐrN©ÚmetadataÚrequest_optionsÚbatchrrcóJ—|j |||¬¦«}|jS)aË **Legacy endpoint for batch ingestion for Langfuse Observability.** -> Please use the OpenTelemetry endpoint (`/api/public/otel/v1/traces`). Learn more: https://langfuse.com/integrations/native/opentelemetry Within each batch, there can be multiple events. Each event has a type, an id, a timestamp, metadata and a body. Internally, we refer to this as the "event envelope" as it tells us something about the event but not the trace. We use the event id within this envelope to deduplicate messages to avoid processing the same event twice, i.e. the event id should be unique per request. The event.body.id is the ID of the actual trace and will be used for updates and will be visible within the Langfuse App. I.e. if you want to update a trace, you'd use the same body id, but separate event IDs. Notes: - Introduction to data model: https://langfuse.com/docs/observability/data-model - Batch sizes are limited to 3.5 MB in total. You need to adjust the number of events per batch accordingly. - The API does not return a 4xx status code for input errors. Instead, it responds with a 207 status code, which includes a list of the encountered errors. Parameters ---------- batch : typing.Sequence[IngestionEvent] Batch of tracing events to be ingested. Discriminated by attribute `type`. metadata : typing.Optional[typing.Any] Optional. Metadata field used by the Langfuse SDKs for debugging. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- IngestionResponse Examples -------- import datetime from langfuse import LangfuseAPI from langfuse.ingestion import IngestionEvent_TraceCreate, TraceBody 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.ingestion.batch( batch=[ IngestionEvent_TraceCreate( id="abcdef-1234-5678-90ab", timestamp="2022-01-01T00:00:00.000Z", body=TraceBody( id="abcdef-1234-5678-90ab", timestamp=datetime.datetime.fromisoformat( "2022-01-01 00:00:00+00:00", ), environment="production", name="My Trace", user_id="1234-5678-90ab-cdef", input="My input", output="My output", session_id="1234-5678-90ab-cdef", release="1.0.0", version="1.0.0", metadata="My metadata", tags=["tag1", "tag2"], public=True, ), ) ], ) ©r rr©rr Údata©rr rrÚ _responses rr zIngestionClient.batchs3€ð`Ô$×*Ò*Ø (¸Oð+ñ ô ˆ ðŒ~Ðr)Ú__name__Ú __module__Ú __qualname__rrÚpropertyr rÚOMITÚtypingÚSequencer ÚOptionalÚAnyrr r ©rrr r s΀€€€€ðMÐ*;ðMðMðMðMðð Ð#5ð ð ð ñ„Xð ð15Ø;?ð SðSðSðŒ˜~Ô.ðSð”/ &¤*Ô-ð Sð  œ¨Ô8ð Sð ð SðSðSðSðSðSrr c ó¢—eZdZdefd„Zedefd„¦«Zeddœde j e de j e j d e j edefd „ZdS) ÚAsyncIngestionClientrcó0—t|¬¦«|_dSr)rrrs rrzAsyncIngestionClient.__init__us€Ý2À.ÐQÑQÔQˆÔÐÐrrcó—|jS)zœ Retrieves a raw implementation of this client that returns raw responses. Returns ------- AsyncRawIngestionClient rrs rrz&AsyncIngestionClient.with_raw_responsexrrNrr rrcƒóZK—|j |||¬¦«ƒd{V—†}|jS)a˜ **Legacy endpoint for batch ingestion for Langfuse Observability.** -> Please use the OpenTelemetry endpoint (`/api/public/otel/v1/traces`). Learn more: https://langfuse.com/integrations/native/opentelemetry Within each batch, there can be multiple events. Each event has a type, an id, a timestamp, metadata and a body. Internally, we refer to this as the "event envelope" as it tells us something about the event but not the trace. We use the event id within this envelope to deduplicate messages to avoid processing the same event twice, i.e. the event id should be unique per request. The event.body.id is the ID of the actual trace and will be used for updates and will be visible within the Langfuse App. I.e. if you want to update a trace, you'd use the same body id, but separate event IDs. Notes: - Introduction to data model: https://langfuse.com/docs/observability/data-model - Batch sizes are limited to 3.5 MB in total. You need to adjust the number of events per batch accordingly. - The API does not return a 4xx status code for input errors. Instead, it responds with a 207 status code, which includes a list of the encountered errors. Parameters ---------- batch : typing.Sequence[IngestionEvent] Batch of tracing events to be ingested. Discriminated by attribute `type`. metadata : typing.Optional[typing.Any] Optional. Metadata field used by the Langfuse SDKs for debugging. request_options : typing.Optional[RequestOptions] Request-specific configuration. Returns ------- IngestionResponse Examples -------- import asyncio import datetime from langfuse import AsyncLangfuseAPI from langfuse.ingestion import IngestionEvent_TraceCreate, TraceBody 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.ingestion.batch( batch=[ IngestionEvent_TraceCreate( id="abcdef-1234-5678-90ab", timestamp="2022-01-01T00:00:00.000Z", body=TraceBody( id="abcdef-1234-5678-90ab", timestamp=datetime.datetime.fromisoformat( "2022-01-01 00:00:00+00:00", ), environment="production", name="My Trace", user_id="1234-5678-90ab-cdef", input="My input", output="My output", session_id="1234-5678-90ab-cdef", release="1.0.0", version="1.0.0", metadata="My metadata", tags=["tag1", "tag2"], public=True, ), ) ], ) asyncio.run(main()) r"Nr#r%s rr zAsyncIngestionClient.batchƒsUèè€ðnÔ*×0Ò0Ø (¸Oð1ñ ô ð ð ð ð ð ð ˆ ðŒ~Ðr)r'r(r)rrr*rrr+r,r-r r.r/rr r r0rrr2r2ts΀€€€€ðRÐ*<ðRðRðRðRðð Ð#:ð ð ð ñ„Xð ð15Ø;?ð ZðZðZðŒ˜~Ô.ðZð”/ &¤*Ô-ð Zð  œ¨Ô8ð Zð ð ZðZðZðZðZðZrr2)r,Úcore.client_wrapperrrÚcore.request_optionsrÚ raw_clientrr Útypes.ingestion_eventr Útypes.ingestion_responser Úcastr/r+r r2r0rrúr<súðð€ € € àGÐGÐGÐGÐGÐGÐGÐGØ1Ð1Ð1Ð1Ð1Ð1ØCÐCÐCÐCÐCÐCÐCÐCØ1Ð1Ð1Ð1Ð1Ð1Ø7Ð7Ð7Ð7Ð7Ð7ð€v„{6”:˜sÑ#Ô#€ðbðbðbðbðbñbôbðbðJiðiðiðiðiñiôiðiðiðir