o i @sdZddlZddlmZddlmZddlmZzddlm Z Wn e y@Z ze de e d ed e dZ [ wweGd d d ejZGd ddeZdS)z6Azure OpenAI Realtime Beta LLM service implementation.N) dataclass)logger)OpenAIRealtimeBetaLLMService)connectz Exception: zvIn order to use OpenAI, you need to `pip install pipecat-ai[openai]`. Also, set `OPENAI_API_KEY` environment variable.zMissing module: c@seZdZdZdS)AzureRealtimeBetaLLMSettingsz)Settings for AzureRealtimeBetaLLMService.N)__name__ __module__ __qualname____doc__r r _/home/ubuntu/.local/lib/python3.10/site-packages/pipecat/services/openai_realtime_beta/azure.pyrsrcs@eZdZUdZeZeed<dedeffdd ZddZ Z S) AzureRealtimeBetaLLMServiceaAzure OpenAI Realtime Beta LLM service with Azure-specific authentication. .. deprecated:: 0.0.84 `AzureRealtimeBetaLLMService` is deprecated, use `AzureRealtimeLLMService` instead. This class will be removed in version 1.0.0. Extends the OpenAI Realtime service to work with Azure OpenAI endpoints, using Azure's authentication headers and endpoint format. Provides the same real-time audio and text communication capabilities as the base OpenAI service. _settingsapi_keybase_urlc sjtjd||d|ttdtjdtddWdn1s(wY||_||_dS)aInitialize Azure Realtime Beta LLM service. Args: api_key: The API key for the Azure OpenAI service. base_url: The full Azure WebSocket endpoint URL including api-version and deployment. Example: "wss://my-project.openai.azure.com/openai/realtime?api-version=2024-10-01-preview&deployment=my-realtime-deployment" **kwargs: Additional arguments passed to parent OpenAIRealtimeBetaLLMService. )rralwaysztAzureRealtimeBetaLLMService is deprecated and will be removed in version 1.0.0. Use AzureRealtimeLLMService instead.) stacklevelNr ) super__init__warningscatch_warnings simplefilterwarnDeprecationWarningrr)selfrrkwargs __class__r r r0s   z$AzureRealtimeBetaLLMService.__init__c sz(|jrWdStd|jt|jd|jidIdH|_|||_WdSt yL}z|j d||dIdHd|_WYd}~dSd}~ww)NzConnecting to zapi-key)uriadditional_headerszError connecting: ) error_msg exception) _websocketrinforwebsocket_connectr create_task_receive_task_handler _receive_task Exception push_error)rer r r _connectMs z$AzureRealtimeBetaLLMService._connect) rr r r rSettings__annotations__strrr- __classcell__r r rr r!s  r)r r dataclassesrlogururopenairwebsockets.asyncio.clientrr&ModuleNotFoundErrorr,errorr*r.rrr r r r s$