7|h $ddlmZddlZddlZddlmZddlmZmZm Z m Z m Z m Z ddl mZddlmZddlmZddlmZmZmZdd lmZmZGd d eZy) ) annotationsN)Path)AnyDictListOptionalTupleUnion)CallbackManagerForRetrieverRun)Document) BaseRetriever)convert_to_secret_strget_from_dict_or_envpre_init) ConfigDict SecretStrceZdZUdZded< dZded< edZeddd Z e d dd Z e d dd Z e dd Z d dd ZddZddZddZddZd dZ d!dZd"dZy)#NeuralDBRetrieverz0Document retriever that uses ThirdAI's NeuralDB.r thirdai_keyNrdbforbid)extrac ddlm}tjj d|j |xst jdy#t$r tdwxYw)Nr) licensingzthirdai.neural_db THIRDAI_KEYz{Could not import thirdai python package and neuraldb dependencies. Please install it with `pip install thirdai[neural_db]`.) thirdair importlibutil find_specactivateosgetenv ImportError)rrs n/var/www/html/test/engine/venv/lib/python3.12/site-packages/langchain_community/retrievers/thirdai_neuraldb.py_verify_thirdai_libraryz)NeuralDBRetriever._verify_thirdai_librarys[  ) NN $ $%8 9   {Fbii .F G K  s A AA%c ltj|ddlm}|||jdi|S)a Create a NeuralDBRetriever from scratch. To use, set the ``THIRDAI_KEY`` environment variable with your ThirdAI API key, or pass ``thirdai_key`` as a named parameter. Example: .. code-block:: python from langchain_community.retrievers import NeuralDBRetriever retriever = NeuralDBRetriever.from_scratch( thirdai_key="your-thirdai-key", ) retriever.insert([ "/path/to/doc.pdf", "/path/to/doc.docx", "/path/to/doc.csv", ]) documents = retriever.invoke("AI-driven music therapy") r neural_dbrr)rr%rr(NeuralDB)clsr model_kwargsndbs r$ from_scratchzNeuralDBRetriever.from_scratch*s0: 11+>,{|s||/Kl/KLLc~tj|ddlm}|||jj |S)a! Create a NeuralDBRetriever with a base model from a saved checkpoint To use, set the ``THIRDAI_KEY`` environment variable with your ThirdAI API key, or pass ``thirdai_key`` as a named parameter. Example: .. code-block:: python from langchain_community.retrievers import NeuralDBRetriever retriever = NeuralDBRetriever.from_checkpoint( checkpoint="/path/to/checkpoint.ndb", thirdai_key="your-thirdai-key", ) retriever.insert([ "/path/to/doc.pdf", "/path/to/doc.docx", "/path/to/doc.csv", ]) documents = retriever.invoke("AI-driven music therapy") rr'r))rr%rr(r+from_checkpoint)r, checkpointrr.s r$r2z!NeuralDBRetriever.from_checkpointLs1< 11+>,{s||/K/KJ/WXXr0c8tt|dd|d<|S)z'Validate ThirdAI environment variables.rr)rr)r,valuess r$validate_environmentsz'NeuralDBRetriever.validate_environmentsos+!6  ! } r0c f|j|}|jjd|||d|y)asInserts files / document sources into the retriever. Args: train: When True this means that the underlying model in the NeuralDB will undergo unsupervised pretraining on the inserted files. Defaults to True. fast_mode: Much faster insertion with a slight drop in performance. Defaults to True. )sourcestrainfast_approximationNr*)_preprocess_sourcesrinsert)selfr8r9 fast_modekwargss r$r<zNeuralDBRetriever.insert{s> **73 (   r0c ddlm}|s|Sg}|D]}t|ts|j |%|j j dr!|j |j|e|j j dr!|j |j||j j dr!|j |j|td|d|S)zChecks if the provided sources are string paths. If they are, convert to NeuralDB document objects. Args: sources: list of either string paths to PDF, DOCX or CSV files, or NeuralDB document objects. rr'z.pdfz.docxz.csvzCould not automatically load z. Only files with .pdf, .docx, or .csv extensions can be loaded automatically. For other formats, please use the appropriate document object from the ThirdAI library.) rr( isinstancestrappendlowerendswithPDFDOCXCSV RuntimeError)r=r8r.preprocessed_sourcesdocs r$r;z%NeuralDBRetriever._preprocess_sourcess -N! Cc3'$++C099;''/(// =YY[))'2(// >YY[))&1(// =&7u=PP "$#r0c<|jj||y)a!The retriever upweights the score of a document for a specific query. This is useful for fine-tuning the retriever to user behavior. Args: query: text to associate with `document_id` document_id: id of the document to associate query with. N)rtext_to_result)r=query document_ids r$upvotezNeuralDBRetriever.upvotes uk2r0c:|jj|y)aGiven a batch of (query, document id) pairs, the retriever upweights the scores of the document for the corresponding queries. This is useful for fine-tuning the retriever to user behavior. Args: query_id_pairs: list of (query, document id) pairs. For each pair in this list, the model will upweight the document id for the query. N)rtext_to_result_batch)r=query_id_pairss r$ upvote_batchzNeuralDBRetriever.upvote_batchs $$^4r0c<|jj||y)a=The retriever associates a source phrase with a target phrase. When the retriever sees the source phrase, it will also consider results that are relevant to the target phrase. Args: source: text to associate to `target`. target: text to associate `source` to. N)r associate)r=sourcetargets r$rVzNeuralDBRetriever.associates &&)r0c:|jj|y)a.Given a batch of (source, target) pairs, the retriever associates each source phrase with the corresponding target phrase. Args: text_pairs: list of (source, target) text pairs. For each pair in this list, the source will be associated with the target. N)rassociate_batch)r= text_pairss r$rZz!NeuralDBRetriever.associate_batchs  +r0c v d|vrd|d<|jjd d|i|}|Dcgc]a}t|j|j|j |j |j|j|jddcc}Scc}w#t$r}td||d}~wwxYw) zRetrieve {top_k} contexts with your retriever for a given query Args: query: Query to submit to the model top_k: The max number of context results to retrieve. Defaults to 10. top_k rN)id upvote_idsrWmetadatascorecontext) page_contentrbz"Error while retrieving documents: Nr*) rsearchr textr`rarWrbrcrd Exception ValueError)r=rN run_managerr? referencesrefes r$_get_relevant_documentsz)NeuralDBRetriever._get_relevant_documentss Nf$"$w'>e>v>J& !$!ff&)nn"%**$'LL!$#&;;q>      NA!EFA M Ns)+BA&BBB B8$B33B8c:|jj|y)zSaves a NeuralDB instance to disk. Can be loaded into memory by calling NeuralDB.from_checkpoint(path) Args: path: path on disk to save the NeuralDB instance to. N)rsave)r=paths r$rpzNeuralDBRetriever.saves  Tr0)N)r Optional[str]returnNone)rrrr-dictrsr)r3zUnion[str, Path]rrrrsr)r5rrsr)TT) r8z List[Any]r9boolr>rvr?rursrt)r8listrsrw)rNrBrOintrsrt)rSzList[Tuple[str, int]]rsrt)rWrBrXrBrsrt)r[zList[Tuple[str, str]]rsrt)rNrBrjr r?rrszList[Document])rqrBrsrt)__name__ __module__ __qualname____doc____annotations__rr model_config staticmethodr% classmethodr/r2rr6r<r;rPrTrVrZrnrpr*r0r$rrsK:BNL  &*M"MM  MMB&* Y$ Y# Y  Y YD            0$@3 5 *,NN'ENQTN N<r0r) __future__rrr!pathlibrtypingrrrrr r langchain_core.callbacksr langchain_core.documentsr langchain_core.retrieversr langchain_core.utilsrrrpydanticrrrr*r0r$rs7" ::C-3VV*s sr0