+hQ@ddlmZddlZddlZddlmZmZmZmZm Z m Z m Z ddl m Z mZddlZddlmZmZmZmZddlmZmZddlmZmZdd lmZdd lmZmZdd l m!Z!dd l"m#Z#m$Z$e%gd Z&e ge'fZ(e gdfZ)edeejTejVfZ,edeeeeefZ-dj]gdZ/Gdde!Z0Gdde$e,e-fZ1Gdde1ejTeefeZ2Gdde1ejVeefeZ3y)) annotationsN)AnyUnionMappingTypeVarCallable Awaitableoverload)Selfoverride) NOT_GIVENOmitTimeoutNotGiven)is_given is_mapping)OpenAI AsyncOpenAI)FinalRequestOptions)Stream AsyncStream) OpenAIError)DEFAULT_MAX_RETRIES BaseClient)z /completionsz/chat/completionsz /embeddingsz/audio/transcriptionsz/audio/translationsz/images/generationszstr | Awaitable[str] _HttpxClientT)bound_DefaultStreamT)c eZdZdfd ZxZS)MutuallyExclusiveAuthErrorc$t|dy)NzThe `api_key`, `azure_ad_token` and `azure_ad_token_provider` arguments are mutually exclusive; Only one can be passed at a time)super__init__)self __class__s C/var/www/html/venv/lib/python3.12/site-packages/openai/lib/azure.pyr&z#MutuallyExclusiveAuthError.__init__+s  O )returnNone)__name__ __module__ __qualname__r& __classcell__r(s@r)r#r#*s   r*r#c2eZdZe dfd ZxZS)BaseAzureClientc|jtvr_t|jrJ|jj d}|-dt |j vrd||j|_t|!|S)Nmodelz /deploymentsz /deployments/) url_deployments_endpointsr json_datagetstrbase_urlr%_build_request)r'optionsr5r(s r)r<zBaseAzureClient._build_request2sq ;;0 0Z@Q@Q5R%%))'2E 3t}};M)M -eWW[[MB w%g..r*)r=rr+z httpx.Request)r-r.r/r r<r0r1s@r)r3r31s'  /$ /  / /r*r3c.eZdZeddddddeeddddd ddZeddddddeeddddd ddZedddddeeddddd ddZddddddddeeddddd dfd Zeddddddededdddid  dfd ZeZ dd Z edfd Z xZ S) AzureOpenAINF azure_deployment api_versionapi_keyazure_ad_tokenazure_ad_token_provider organizationtimeout max_retriesdefault_headers default_query http_client_strict_response_validationc yNr'azure_endpointrArBrCrDrErFrGrHrIrJrKrLs r)r&zAzureOpenAI.__init__@$ r*c yrNrO r'rArBrCrDrErFrGrHrIrJrKrLs r)r&zAzureOpenAI.__init__T" r* rBrCrDrErFrGrHrIrJrKrLc yrNrO r'r;rBrCrDrErFrGrHrIrJrKrLs r)r&zAzureOpenAI.__init__grUr*)rBrQrArCrDrErFr;rGrHrIrJrKrLc *|tjjd}|tjjd}|| | td|tjjd}| t d| d|i} ni| d|i} |>|tjjd}| t d ||d |}n|d }n | t d |t }t ||||| | | | | | ||_||_ ||_ y)a=Construct a new synchronous azure openai client instance. This automatically infers the following arguments from their corresponding environment variables if they are not provided: - `api_key` from `AZURE_OPENAI_API_KEY` - `organization` from `OPENAI_ORG_ID` - `azure_ad_token` from `AZURE_OPENAI_AD_TOKEN` - `api_version` from `OPENAI_API_VERSION` - `azure_endpoint` from `AZURE_OPENAI_ENDPOINT` Args: azure_endpoint: Your Azure endpoint, including the resource, e.g. `https://example-resource.azure.openai.com/` azure_ad_token: Your Azure Active Directory token, https://www.microsoft.com/en-us/security/business/identity-access/microsoft-entra-id azure_ad_token_provider: A function that returns an Azure Active Directory token, will be invoked on every request. azure_deployment: A model deployment, if given sets the base client URL to include `/deployments/{azure_deployment}`. Note: this means you won't be able to use non-deployment endpoints. NAZURE_OPENAI_API_KEYAZURE_OPENAI_AD_TOKENMissing credentials. Please pass one of `api_key`, `azure_ad_token`, `azure_ad_token_provider`, or the `AZURE_OPENAI_API_KEY` or `AZURE_OPENAI_AD_TOKEN` environment variables.OPENAI_API_VERSION_Must provide either the `api_version` argument or the `OPENAI_API_VERSION` environment variable api-versionAZURE_OPENAI_ENDPOINTuMust provide one of the `base_url` or `azure_endpoint` arguments, or the `AZURE_OPENAI_ENDPOINT` environment variable/openai/deployments//openai2base_url and azure_endpoint are mutually exclusive rCrFr;rGrHrIrJrKrL osenvironr9r ValueErrorAPI_KEY_SENTINELr%r& _api_version_azure_ad_token_azure_ad_token_provider)r'rBrQrArCrDrErFr;rGrHrIrJrKrLr(s r)r&zAzureOpenAI.__init__zrJ ?jjnn%;K  q   *K8MI}Im[IM  %!#0G!H% L +,--ABRAST,-W5) !UVV ?&G %#+'#(C  (-(?%r*rCrFrBrDrEr;rGrKrHrIset_default_headersrJset_default_query _extra_kwargsct||||||| | | | | |xs |j|xs |j|xs |jd| Sz~ Create a new client instance re-using the same options given to the current client with optional overriding. )rBrDrE) rCrFr;rGrKrHrIrprJrqrrr%copyrkrlrmr'rCrFrBrDrEr;rGrKrHrIrprJrqrrr(s r)rvzAzureOpenAI.copyr,w|%##+ 3'/*?d.?.?"0"HD4H4H+B+cdFcFc   r*c|j |jS|j}|)|}|rt|tst d||SyNzOExpected `azure_ad_token_provider` argument to return a string but it returned )rlrm isinstancer:rir'providertokens r)_get_azure_ad_tokenzAzureOpenAI._get_azure_ad_tokensa    +'' '00  JE 5# 6 efkelmLr*cNt|jri|jni}||_|j}||jdGd||d<n>|jt ur!|jd|j|d<n t dt|!|SN AuthorizationzBearer zapi-keyzUnable to handle auth rheadersrr9rCrjrir%_prepare_optionsr'r=rrDr(s r)rzAzureOpenAI._prepare_optionss@H@Y).4859+/,1  %      # "= ! 3  2 3 ) &* !  &(,"&"%)?C#'5>.4859+/,1 %     #  "= ! 3  2 3 ) &*    $ #'"%)?C#'5>.4859+/,1      #  "= ! 3  2 3 ) &*    *#'%)'+"%)?C#'#5>.4859+/,1!_@ _@# _@ % _@  _@#_@"=_@!_@_@3_@_@2_@3_@)_@ &*!_@" #_@B##'"&%)?C+/5>+/&/488<599=+-!& & ! &  & # & "=& )& 3& )& $& 2& 6& 3& 7& )!& " #& & PL 11r*r?c.eZdZeddddddeeddddd ddZeddddddeeddddd ddZedddddeeddddd ddZddddddddeeddddd dfd Zeddddddededdddid  dfd ZeZ dd Z edfd Z xZ S)AsyncAzureOpenAINFr@c yrNrOrPs r)r&zAsyncAzureOpenAI.__init__)rRr*c yrNrOrTs r)r&zAsyncAzureOpenAI.__init__=rUr*rVc yrNrOrXs r)r&zAsyncAzureOpenAI.__init__PrUr*)rQrArBrCrDrErFr;rGrHrIrJrKrLc *|tjjd}|tjjd}|| | td|tjjd}| t d| d|i} ni| d|i} |>|tjjd}| t d ||d |}n|d }n | t d |t }t ||||| | | | | | ||_||_ ||_ y)a>Construct a new asynchronous azure openai client instance. This automatically infers the following arguments from their corresponding environment variables if they are not provided: - `api_key` from `AZURE_OPENAI_API_KEY` - `organization` from `OPENAI_ORG_ID` - `azure_ad_token` from `AZURE_OPENAI_AD_TOKEN` - `api_version` from `OPENAI_API_VERSION` - `azure_endpoint` from `AZURE_OPENAI_ENDPOINT` Args: azure_endpoint: Your Azure endpoint, including the resource, e.g. `https://example-resource.azure.openai.com/` azure_ad_token: Your Azure Active Directory token, https://www.microsoft.com/en-us/security/business/identity-access/microsoft-entra-id azure_ad_token_provider: A function that returns an Azure Active Directory token, will be invoked on every request. azure_deployment: A model deployment, if given sets the base client URL to include `/deployments/{azure_deployment}`. Note: this means you won't be able to use non-deployment endpoints. NrZr[r\r]r^r_r`rarbrcrdrerf)r'rQrArBrCrDrErFr;rGrHrIrJrKrLr(s r)r&zAsyncAzureOpenAI.__init__crnr*roct||||||| | | | | |xs |j|xs |j|xs |jd| Srtrurws r)rvzAsyncAzureOpenAI.copyrxr*cK|j |jS|j}|H|}tj|r |d{}|rt |t st d||Sy7'wrz)rlrminspect isawaitabler{r:rir|s r)rz$AsyncAzureOpenAI._get_azure_ad_tokens    +'' '00  JE""5)#  5# 6 efkelmL$sAA4 A2 (A4c~Kt|jri|jni}||_|jd{}||jdGd||d<n>|jt ur!|jd|j|d<n t dt|!|d{S7u7wrrrs r)rz!AsyncAzureOpenAI._prepare_optionss@H@Y).485904,1  %      # "B ! 3  2 3 . &* !  &(,"&"%)DH#'5>.485904,1 %     #  "B ! 3  2 3 . &*    $ #'"%)DH#'5>.485904,1      #  "B ! 3  2 3 . &*    *&*'+"&"%)DH#'#5>.485904,1!_@#_@% _@  _@  _@#_@"B_@!_@_@3_@_@2_@3_@._@ &*!_@" #_@B##'"&%)DH+/5>04&/488<599=+-!& & ! &  & # & "B& )& 3& .& $& 2& 6& 3& 7& )!& " #& & PL"77r*r)4 __future__rrgrtypingrrrrrr r typing_extensionsr r httpx_typesrrrr_utilsrr_clientrr_modelsr _streamingrr _exceptionsr _base_clientrrsetr7r:AzureADTokenProviderAsyncAzureADTokenProviderClient AsyncClientrrjoinrjr#r3r?rrOr*r)rs$" NNN, 77))),%:  C($R)?%?@uU\\5CTCT5T/UV +5kRUFV9V3WX 7789   /j!?@ /f1/%,,s ";