o ưi6@s>dZddlmZddlmZmZmZddlZGdddZdS)z4Database connection and data extraction for LiteLLM.)datetime)AnyOptionalListNc @sHeZdZdZddZ   d deedeedeedej fd d Z dS) LiteLLMDatabasez;Handle LiteLLM PostgreSQL database connections and queries.cCs"ddlm} |durtd|S)Nr) prisma_clientzDatabase not connected. Connect a database to your proxy - https://docs.litellm.ai/docs/simple_proxy#managing-auth---virtual-keys)Zlitellm.proxy.proxy_serverr Exception)selfrr ^/home/app/Keep/.python/lib/python3.10/site-packages/litellm/integrations/cloudzero/database.py_ensure_prisma_clients z%LiteLLMDatabase._ensure_prisma_clientNlimitstart_time_utc end_time_utcreturnc s|}d}||g}|dur*z |t|Wn ttfy%tdw|d7}z|jj|g|RIdH}tj|ddWSt yT}z t dt |d}~ww)z8Retrieve usage data from LiteLLM daily user spend table.aj SELECT dus.id, dus.date, dus.user_id, dus.api_key, dus.model, dus.model_group, dus.custom_llm_provider, dus.prompt_tokens, dus.completion_tokens, dus.spend, dus.api_requests, dus.successful_requests, dus.failed_requests, dus.cache_creation_input_tokens, dus.cache_read_input_tokens, dus.created_at, dus.updated_at, vt.team_id, vt.key_alias as api_key_alias, tt.team_alias, ut.user_email as user_email FROM "LiteLLM_DailyUserSpend" dus LEFT JOIN "LiteLLM_VerificationToken" vt ON dus.api_key = vt.token LEFT JOIN "LiteLLM_TeamTable" tt ON vt.team_id = tt.team_id LEFT JOIN "LiteLLM_UserTable" ut ON dus.user_id = ut.user_id WHERE ($1::timestamptz IS NULL OR dus.updated_at >= $1::timestamptz) AND ($2::timestamptz IS NULL OR dus.updated_at <= $2::timestamptz) ORDER BY dus.date DESC, dus.created_at DESC Nzlimit must be an integerz LIMIT $3)Zinfer_schema_lengthzError retrieving usage data: ) r appendint TypeError ValueErrordbZ query_rawpl DataFramerstr) r r rrclientqueryparamsZ db_responseer r r get_usage_data(s(!zLiteLLMDatabase.get_usage_data)NNN) __name__ __module__ __qualname____doc__r rrrrrrr r r r rs r) r!rtypingrrrZpolarsrrr r r r s