a bg @s\dZddlmZmZmZddlmZddlmZddl m Z ddl m Z Gddde Z d S) zWrapper around Dria Retriever.)AnyListOptional)CallbackManagerForRetrieverRunDocument) BaseRetriever)DriaAPIWrappercsxeZdZUdZeed<deeeedfdd Z deeeeed d d Z e dd d dZ ee e edddZZS) DriaRetrieverz*`Dria` retriever using the DriaAPIWrapper. api_wrapperN)api_key contract_idkwargsc s&t||d}tjfd|i|dS)z Initialize the DriaRetriever with a DriaAPIWrapper instance. Args: api_key: The API key for Dria. contract_id: The contract ID of the knowledge base to interact with. )r r r N)r super__init__)selfr r rr  __class__w/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/langchain_community/retrievers/dria_index.pyrs zDriaRetriever.__init__ Unspecifiedjina)name descriptioncategory embeddingreturncCs|j||||}|S)awCreate a new knowledge base in Dria. Args: name: The name of the knowledge base. description: The description of the knowledge base. category: The category of the knowledge base. embedding: The embedding model to use for the knowledge base. Returns: The ID of the created knowledge base. )r create_knowledge_base)rrrrrresponserrrrsz#DriaRetriever.create_knowledge_base)textsrcCsdd|D}|j|dS)zAdd texts to the Dria knowledge base. Args: texts: An iterable of texts and metadatas to add to the knowledge base. Returns: List of IDs representing the added texts. cSsg|]}|d|ddqS)textmetadata)r r!r).0r rrr @z+DriaRetriever.add_texts..N)r Z insert_data)rrdatarrr add_texts4s zDriaRetriever.add_texts)query run_managerrcCs|j|}dd|D}|S)a*Retrieve relevant documents from Dria based on a query. Args: query: The query string to search for in the knowledge base. run_manager: Callback manager for the retriever run. Returns: A list of Documents containing the search results. cSs*g|]"}t|d|d|dddqS)r!idscore)r)r*)Z page_contentr!r)r"resultrrrr#Ps z9DriaRetriever._get_relevant_documents..)r search)rr'r(resultsdocsrrr_get_relevant_documentsCs z%DriaRetriever._get_relevant_documents)N)rr)__name__ __module__ __qualname____doc__r __annotations__strrrrrrr&rrr/ __classcell__rrrrr s$   r N)r3typingrrrZlangchain_core.callbacksrZlangchain_core.documentsrZlangchain_core.retrieversrZlangchain_community.utilitiesr r rrrrs