o Zh4@sddlZddlmZmZmZmZddlmZddl m Z ddl m Z ddl mZddlmZddlmZmZdd lmZerDdd lmZerLdd lmZGd d d eZdS) N) TYPE_CHECKINGAnyOptionalSequence) exceptions) Credentials) Callbacks)Document)BaseDocumentCompressor) ConfigDictField)get_client_infodiscoveryengine_v1alphac sVeZdZUdZeddZeed<eddZeed<eddZ eed<ed dZ eed <ed dZ e ed <ed dZ eed<eddZeeed<eddZeeed<eddZeeed<eddZeeed<dZeed<deffdd Zd%ddZdedeedeefddZ d&deededeedeefd d!Zed"d#d$ZZ S)' VertexAIRanka Initializes the Vertex AI Ranker with configurable parameters. Inherits from BaseDocumentCompressor for document processing and validation features, respectively. Attributes: project_id (str): Google Cloud project ID location_id (str): Location ID for the ranking service. ranking_config (str): Required. The name of the rank service config, such as default_config. It is set to default_config by default if unspecified. model (str): The identifier of the model to use. It is one of: - ``semantic-ranker-512@latest``: Semantic ranking model with maximum input token size 512. It is set to ``semantic-ranker-512@latest`` by default if unspecified. top_n (int): The number of results to return. If this is unset or no bigger than zero, returns all results. ignore_record_details_in_response (bool): If true, the response will contain only record ID and score. By default, it is false, the response will contain record details. id_field (Optional[str]): Specifies a unique document metadata field to use as an id. title_field (Optional[str]): Specifies the document metadata field to use as title. credentials (Optional[Credentials]): Google Cloud credentials object. credentials_path (Optional[str]): Path to the Google Cloud service account credentials file. N)default project_idglobal location_idZdefault_configranking_configzsemantic-ranker-512@latestmodel top_nF!ignore_record_details_in_responseid_field title_field credentialscredentials_pathclientkwargsc s6tjdi||d|_|js||_dSdS)z Constructor for VertexAIRanker, allowing for specification of ranking configuration and initialization of Google Cloud services. The parameters accepted are the same as the attributes listed above. rN)super__init__getr_get_rank_service_client)selfr __class__r ]/var/www/html/lang_env/lib/python3.10/site-packages/langchain_google_community/vertex_rank.pyr"Es  zVertexAIRank.__init__return)discoveryengine_v1alpha.RankServiceClientc Cs`zddlm}Wnty}ztd|d}~ww|j|jr(|jp't|jndtdddS)z Returns a RankServiceClient instance for making API calls to the Vertex AI Ranking service. Returns: A RankServiceClient instance. rrzCould not import google-cloud-discoveryengine python package. Please, install vertexaisearch dependency group: `pip install langchain-google-community[vertexaisearch]`Nzvertex-ai-search)module)rZ client_info) google.cloudr ImportErrorZRankServiceClientrrrZfrom_service_account_filer )r%rexcr r r(r$Qs$ z%VertexAIRank._get_rank_service_clientquery documentsc sddlmzfddt|D}Wnty'tdjdYnwdjdjd j }j |j ||j j d }z jj|d }Wn tjym}ztd t|td t||d }~wwfdd|jDS)z Reranks documents based on the provided query. Args: query: The query to use for reranking. documents: The list of documents to rerank. Returns: A list of reranked documents. rrc srg|]5\}}|jsjr|jjrjdjr |jjnt||jdjr3d|jjiniqS))idcontenttitler ) page_contentrmetadatar#Z RankingRecordrstr).0idxdocrr%r r( {s"   z2VertexAIRank._rerank_documents..z id_field 'z!' not found in document metadata.z projects/z /locations/z/rankingConfigs/)rrr/recordsrr)requestz%Error in Vertex AI Ranking API call: NcsDg|]}tjs |jnd|j|jdjrj|jinidqS))r1Zrelevance_score)r4r5)r rr2r1Zscorerr3)r7record)r%r r(r;s )r,r enumerateKeyErrorwarningswarnrrrrZ RankRequestrrrrZrankcore_exceptionsZGoogleAPICallErrorprintr6 RuntimeErrorr<)r%r/r0r<Zranking_config_pathr=responseer r:r(_rerank_documentsks<      zVertexAIRank._rerank_documents callbackscCs |||S)ap Compresses documents using Vertex AI's rerank API. Args: documents: List of Document instances to compress. query: Query string to use for compressing the documents. callbacks: Callbacks to execute during compression (not used here). Returns: A list of Document instances, compressed. )rI)r%r0r/rJr r r(compress_documentss zVertexAIRank.compress_documentsignoreT)extraZarbitrary_types_allowed)r)r*)N)!__name__ __module__ __qualname____doc__r rr6__annotations__rrrrintrboolrrrrrrrrr"r$rr rIrrKr Z model_config __classcell__r r r&r(rsH $   G r)rBtypingrrrrZgoogle.api_corerrDZgoogle.auth.credentialsrZlangchain_core.callbacksrZlangchain_core.documentsr Z#langchain_core.documents.compressorr Zpydanticr r Z!langchain_google_community._utilsr r,rrr r r r(s