
    Ng                        d dl mZ d dlmZmZmZmZmZ d dlm	Z	 d dl
mZ d dlmZ d dlmZmZmZ d dlmZmZmZmZ  G d d	e          Z G d
 dee          ZdS )    )annotations)AnyDictIteratorListOptional)CallbackManagerForLLMRun)LLM)GenerationChunk)convert_to_secret_strget_from_dict_or_envpre_init)	BaseModel
ConfigDictField	SecretStrc                  >   e Zd ZU dZ ed          ZdZded<   dZded<   	 dZ	ded	<   	 d
Z
ded<   	 dZded<   	 dZded<   	 dZded<   	 dZded<   	 dZded<   	  ee          Zded<   	 dZded<   	 dZded <   	 dZded!<   	 ed'd%            Zed(d&            ZdS ))VolcEngineMaasBasez%Base class for VolcEngineMaas models. )protected_namespacesNr   clientzOptional[SecretStr]volc_engine_maas_akvolc_engine_maas_skz*maas-api.ml-platform-cn-beijing.volces.comzOptional[str]endpointRegionregionzskylark-lite-publicstrmodelmodel_versiong?zOptional[float]top_pgffffff?temperature)default_factoryDict[str, Any]model_kwargsFbool	streaming<   zOptional[int]connect_timeoutread_timeoutvaluesr   returnc                   t          t          |dd                    }t          t          |dd                    }|d         }|d         |d         dk    r|d         }	 ddlm}  |||d	         |d
         |d                   }|                    |                                           |                    |                                           ||d<   ||d<   ||d<   n# t          $ r t          d          w xY w|S )Nr   VOLC_ACCESSKEYr   VOLC_SECRETKEYr    r   )MaasServicer   r(   r)   )connection_timeoutsocket_timeoutr   zMvolcengine package not found, please install it with `pip install volcengine`)r   r   volcengine.maasr0   set_akget_secret_valueset_skImportError)clsr*   r   r   r   r0   maass          d/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/llms/volcengine_maas.pyvalidate_environmentz'VolcEngineMaasBase.validate_environment9   s[   3 )>@PQQ
 
 4 )>@PQQ
 
 *%*)fZ.@B.F.Fj)H	333333;x #)*;#<%n5	  D KK+<<>>???KK+<<>>???,?F(),?F()#F8 	 	 	+  	
 s   "BC' 'Dc                6    | j         | j        d}i || j        S )z:Get the default parameters for calling VolcEngineMaas API.)r    r!   )r    r!   r$   )selfnormal_paramss     r:   _default_paramsz"VolcEngineMaasBase._default_paramsZ   s0     Z+
 

 6-54#455    )r*   r   r+   r   )r+   r#   )__name__
__module____qualname____doc__r   model_configr   __annotations__r   r   r   r   r   r   r    r!   r   dictr$   r&   r(   r)   r   r;   propertyr?   r   r@   r:   r   r      s        //:2666LF/33333$/33333$JHJJJJ-$F$$$$+&E&&&&> $(M''''R !E    D#'K''''Q#(5#>#>#>L>>>>GI(%'O''''R"$L$$$$    X@ 6 6 6 X6 6 6r@   r   c                  N    e Zd ZdZedd            Zdd	Z	 	 dddZ	 	 dddZd
S )VolcEngineMaasLLMa0  volc engine maas hosts a plethora of models.
    You can utilize these models through this class.

    To use, you should have the ``volcengine`` python package installed.
    and set access key and secret key by environment variable or direct pass those to
    this class.
    access key, secret key are required parameters which you could get help
    https://www.volcengine.com/docs/6291/65568

    In order to use them, it is necessary to install the 'volcengine' Python package.
    The access key and secret key must be set either via environment variables or
    passed directly to this class.
    access key and secret key are mandatory parameters for which assistance can be
    sought at https://www.volcengine.com/docs/6291/65568.

    Example:
        .. code-block:: python

            from langchain_community.llms import VolcEngineMaasLLM
            model = VolcEngineMaasLLM(model="skylark-lite-public",
                                          volc_engine_maas_ak="your_ak",
                                          volc_engine_maas_sk="your_sk")
    r+   r   c                    dS )zReturn type of llm.zvolc-engine-maas-llmr   )r=   s    r:   	_llm_typezVolcEngineMaasLLM._llm_type~   s
     &%r@   promptkwargsr   rG   c                r    dd| j         ii}| j        | j        |d         d<   i |d|dgi | j        |dS )Nr   nameversionuser)rolecontent)messages
parameters)r   r   r?   )r=   rM   rN   	model_reqs       r:   _convert_prompt_msg_paramsz,VolcEngineMaasLLM._convert_prompt_msg_params   sv     

	
 ),0,>Igy)

"(V<<=<T1<V<
 
 
 	
r@   NstopOptional[List[str]]run_manager"Optional[CallbackManagerForLLMRun]c                   | j         r!d} | j        |||fi |D ]}||j        z  }|S  | j        |fi |}| j                            |          }|                    di                               di                               dd          S )Nr/   choicemessagerT   )r&   _streamtextrX   r   chatget)	r=   rM   rY   r[   rN   
completionchunkparamsresponses	            r:   _callzVolcEngineMaasLLM._call   s     > 	J%fdKJJ6JJ ) )ej(

00BB6BB;##F++||Hb))--i<<@@BOOOr@   Iterator[GenerationChunk]c              +  @  K    | j         |fi |}| j                            |          D ]r}|rnt          |                    di                               di                               dd                    }|r|                    |j        |           |V  sd S )Nr^   r_   rT   r/   )ra   )re   )rX   r   stream_chatr   rc   on_llm_new_tokenra   )r=   rM   rY   r[   rN   rf   resre   s           r:   r`   zVolcEngineMaasLLM._stream   s       10BB6BB;**622 	 	C '2..229bAAEEiQSTT    J0050III	 	r@   )r+   r   )rM   r   rN   r   r+   rG   )NN)
rM   r   rY   rZ   r[   r\   rN   r   r+   r   )
rM   r   rY   rZ   r[   r\   rN   r   r+   ri   )	rA   rB   rC   rD   rH   rL   rX   rh   r`   r   r@   r:   rJ   rJ   e   s         0 & & & X&
 
 
 
, %):>	P P P P P( %):>	      r@   rJ   N)
__future__r   typingr   r   r   r   r   langchain_core.callbacksr	   #langchain_core.language_models.llmsr
   langchain_core.outputsr   langchain_core.utilsr   r   r   pydanticr   r   r   r   r   rJ   r   r@   r:   <module>ru      s-   " " " " " " 6 6 6 6 6 6 6 6 6 6 6 6 6 6 = = = = = = 3 3 3 3 3 3 2 2 2 2 2 2 V V V V V V V V V V < < < < < < < < < < < <V6 V6 V6 V6 V6 V6 V6 V6rQ Q Q Q Q/ Q Q Q Q Qr@   