q121/01
0
1a
2 ���g�3 � @ sZ d dl mZ ddlmZmZ d dlZd dlZd dlm Z m4Z5m Z m Z m
Z
G dd� d�ZdS )� N� )�ChatCompletionRequest�Message)�GoogleAPIError�ResourceExhausted�InternalServerError�ServiceUnavailable�InvalidArgumentc @ s~ e Zd ZddgZed�dd�Zed�dd�Zeeed �d6d �Z e7d �d
d�Z e8d �dd�Z ed�dd�Z
eed�dd��ZdS )� GeminiClientz9gemini-prozgemini-pro-vision��api_keyc C s t j|d� i | _|| _d S )Nr )�genai� configure� model_cacher )�selfr � r �D:\gemini\app\gemini.py�__init__ s zGeminiClient.__init__)�10model_namec C s$ || j vrt�|�| j |< | j | S )N)r r
ZGenerativeModel)r r r r r � get_model s 11zGeminiClient.get_model)r �messages�streamc � s` | � |�}|j| �|�d�}|r*|d jnd}|rJ|j|dd�I d H }|S |j|dd�}|S d S )N)�history������ T�r F)r Z12start_chat�convert_messages�contentZsend_message_async� send_message)r r r r �modelZchatZlast_message_content�responser r r �
_send_message s 13zGeminiClient._send_message)�requestc C sp z:| j |j|jdd�I d H }|2 z3 d H W }|jV q 6 W n0 tttttfyj } z� W Y d }~n14d }~0 0 d S )NTr � r! r r �textr r r r r )r r" r �chunk�er r r � stream_chat s zGeminiClient.stream_chatc C sR z | j |j|jdd�}|jW S tttttfyL } z� W Y d }~n15d }~0 0 d S )NFr r# )r r" r r& r r r �
complete_chat( s16 zGeminiClient.complete_chat)�returnc C sr g }|D ]d}|j dkr.|�dd|jgd�� q|j dkrN|�d|jgd�� q|j dkr|�d|jgd�� q|S )N�systemr �user)�role�parts� assistantr )r, �insertr �append)r r Zgemini_messages�msgr r r r / s 171819z GeminiClient.convert_messagesc 20 C s` z$t j| d� t �� }dd� |D �W S tyZ } z td|� �� g W Y d }~S d }~0 0 d S )Nr c S s g | ]21}|j �qS r )�name)�.0r r r r �22<listcomp>? � z6GeminiClient.list_available_models.<locals>.<listcomp>zError listing models: )r
r � list_models� Exception�print)r �modelsr& r r r �list_available_models: s z"GeminiClient.list_available_modelsN)�__name__�23__module__� __qualname__�AVAILABLE_MODELS�strr r �list�boolr! r r' r( r � staticmethodr: r r r r r24 s r25 )Zgoogle.generativeaiZ generativeair
r9 r r �os�asyncioZgoogle.api_core.exceptionsr r r r r r26 r r r r �<module> s27