o i3 @sddlmZddlmZddlmZddlmZmZmZm Z m Z m Z ddl m Z ddlmZzddlmZmZmZmZddlmZWneySZzed ed Z[wwer\dd lmZed ZGd ddeZGdddeZGdddeZGddde ddZ Gddde Z!Gddde!Z"Gddde Z#Gddde Z$e ded Z%Gd!d"d"ee%Z&Gd#d$d$e&eZ'Gd%d&d&e&eZ(d S)') annotations)datetime) TracebackType) TYPE_CHECKINGAnyGenericLiteral TypedDictTypeVar)Self)get_base_url_from_token) AsyncClientClientResponseTimeout) BaseClientz2httpx is required to use the Logfire query clientsN)Tableg>@c@eZdZdZdS)QueryExecutionErrorz4Raised when the query execution fails on the server.N__name__ __module__ __qualname____doc__rrg/var/www/html/karishye-ai-python/venv/lib/python3.10/site-packages/logfire/experimental/query_client.pyrrc@r)QueryRequestErrorz)Raised when the query request is invalid.Nrrrrrrrrc@r)InfoRequestErrorzURaised when the request for read token info fails because of unavailable information.Nrrrrrr#rrc@s"eZdZUdZded<ded<dS) ReadTokenInfoz!Information about the read token.strorganization_name project_nameNrrrr__annotations__rrrrr)  rF)totalc@s*eZdZUdZded<ded<ded<dS) ColumnDetailszFThe details of a column in the row-oriented JSON-format query results.r namerdatatypeboolnullableNr#rrrrr'0s  r'c@eZdZUdZded<dS) ColumnDatazFThe data of a column in the column-oriented JSON-format query results.z list[Any]valuesNr#rrrrr-8  r-c@r,) QueryResultsz5The (column-oriented) results of a JSON-format query.zlist[ColumnData]columnsNr#rrrrr0>r/r0c@s"eZdZUdZded<ded<dS)RowQueryResultsz0The row-oriented results of a JSON-format query.zlist[ColumnDetails]r1zlist[dict[str, Any]]rowsNr#rrrrr2Dr%r2T)boundc@s4eZdZdd d Z d d!ddZd"ddZd S)#_BaseLogfireQueryClientbase_urlr read_tokentimeoutrclienttype[T] client_kwargsrcKsB||_||_||_|di}||d<|d|||d||_dS)Nheaders authorization)r9r7r=r)r7r8r9popr:)selfr7r8r9r:r<r=rrr__init__Os  z _BaseLogfireQueryClient.__init__NFsql min_timestampdatetime | None max_timestamplimit int | None row_orientedr*returndict[str, str]cCsLd|i}|durt||d<|rd|d<|r||d<|r$||d<|S)NrBrFtrue json_rowsrCrE)r isoformat)r@rBrCrErFrHparamsrrrbuild_query_paramsWs   z*_BaseLogfireQueryClient.build_query_paramsresponserNonecCsD|jdkr t||jdkrt||jdks J|jdS)Nii) status_coderjsonrcontent)r@rPrrrhandle_response_errorsjs    z._BaseLogfireQueryClient.handle_response_errors) r7r r8r r9rr:r;r<rNNNF) rBr rCrDrErDrFrGrHr*rIrJ)rPrrIrQ)rrrrArOrVrrrrr6Ns   r6ceZdZdZdefd6fd d Zd7ddZ   d8d9ddZd:ddZ   d8d;d$d%Z   d8dd,d-Z    .d?d@d4d5Z ZS)ALogfireQueryClientz/A synchronous client for querying Logfire data.Nr8r r7 str | Noner9rr<rc *|pt|}tj|||tfi|dSN)r superrAr)r@r8r7r9r< __class__rrrAu zLogfireQueryClient.__init__rIr cCs|j|Sr\)r: __enter__r@rrrras zLogfireQueryClient.__enter__exc_typetype[BaseException] | None exc_valueBaseException | None tracebackTracebackType | NonerQcCs|j|||dSr\)r:__exit__r@rcrergrrrriszLogfireQueryClient.__exit__rcCsJ|jd}|||}z |d|ddWSty$tdw)%Get information about the read token./v1/read-token-infor!r"r!r"ZThe read token info response is missing required fields: organization_name or project_namer:getrVrTKeyErrorrr@rP token_inforrrinfos   zLogfireQueryClient.inforBrCrDrErFrGr0cC|jd||||dd}|S)JQuery Logfire data and return the results as a column-oriented dictionary.application/jsonFacceptrBrCrErFrH_queryrTr@rBrCrErFrPrrr query_jsonzLogfireQueryClient.query_jsonr2cCru)GQuery Logfire data and return the results as a row-oriented dictionary.rwTrxrzr|rrrquery_json_rowsr~z"LogfireQueryClient.query_json_rowsrc Cszddl}Wnty}ztd|d}~ww|jd||||d}|j|j }|} Wd| S1s9wY| SzQuery Logfire data and return the results as a pyarrow Table. Note that pyarrow must be installed for this method to succeed. You can use `polars.from_arrow(result)` to convert the returned table to a polars DataFrame. rNz1pyarrow is required to use the query_arrow methodz#application/vnd.apache.arrow.streamryrBrCrErFpyarrow ImportErrorr{ipc open_streamrUread_all r@rBrCrErFrerPreader arrow_tablerrr query_arrows&    zLogfireQueryClient.query_arrowcCs|jd||||d}|jS)Query Logfire data and return the results as a CSV-format string. Use `polars.read_csv(StringIO(result))` to convert the returned CSV to a polars DataFrame. text/csvrr{textr|rrr query_csvs zLogfireQueryClient.query_csvFryNLiteral['application/json', 'application/vnd.apache.arrow.stream', 'text/csv']rHr*rc Cs6||||||}|jjdd|i|d}|||SNz /v1/queryry)r=rNrOr:rprV r@ryrBrCrErFrHrNrPrrrr{s  zLogfireQueryClient._query)r8r r7rZr9rr<rrIr NNNrcrdrerfrgrhrIrQrIr rBr rCrDrErDrFrGrIr0 rBr rCrDrErDrFrGrIr2 rBr rCrDrErDrFrGrIr rBr rCrDrErDrFrGrIr rWryrrBr rCrDrErDrFrGrHr*rIr)rrrrDEFAULT_TIMEOUTrArarirtr}rrrr{ __classcell__rrr^rrYr@       rYcrX)AAsyncLogfireQueryClientz1An asynchronous client for querying Logfire data.Nr8r r7rZr9rasync_client_kwargsrc r[r\)r r]rAr )r@r8r7r9rr^rrrAr`z AsyncLogfireQueryClient.__init__rIr cs|jIdH|Sr\)r: __aenter__rbrrrr sz"AsyncLogfireQueryClient.__aenter__rcrdrerfrgrhrQcs|j|||IdHdSr\)r: __aexit__rjrrrrsz!AsyncLogfireQueryClient.__aexit__rcsR|jdIdH}|||}z |d|ddWSty(tdw)rkrlNr!r"rmrnrorrrrrrts  zAsyncLogfireQueryClient.inforBrCrDrErFrGr0c&|jd||||ddIdH}|S)rvrwFrxNrzr|rrrr}( z"AsyncLogfireQueryClient.query_jsonr2cr)rrwTrxNrzr|rrrr:rz'AsyncLogfireQueryClient.query_json_rowsrc szddl}Wnty}ztd|d}~ww|jd||||dIdH}|j|j }|} Wd| S1s=wY| SrrrrrrrLs(     z#AsyncLogfireQueryClient.query_arrowcs"|jd||||dIdH}|jS)rrrNrr|rrrris  z!AsyncLogfireQueryClient.query_csvFryrrHr*rc s>||||||}|jjdd|i|dIdH}|||Srrrrrrr{}s   zAsyncLogfireQueryClient._query)r8r r7rZr9rrrrrrrrrrrrWr)rrrrrrArrrtr}rrrr{rrrr^rrrr)) __future__rrtypesrtypingrrrrr r typing_extensionsr logfire._internal.configr httpxr rrr httpx._clientrrrrrr RuntimeErrorrrrrr'r-r0r2r4r6rYrrrrrs:        $