a bg @s^ddlmZmZmZddlmZddlmZddlm Z ddl m Z m Z Gddde e Z dS) )AnyListOptional)CallbackManagerForRetrieverRun)Document) BaseRetriever) BaseModelFieldc@seZdZUdZdZeeed<edddZ ee ed<edddZ ee ed <dd d d Z e e ed ddZe ee edddZdS)NeedleRetrievera NeedleRetriever retrieves relevant documents or context from a Needle collection based on a search query. Setup: Install the `needle-python` library and set your Needle API key. .. code-block:: bash pip install needle-python export NEEDLE_API_KEY="your-api-key" Key init args: - `needle_api_key` (Optional[str]): The API key for authenticating with Needle. - `collection_id` (str): The ID of the Needle collection to search in. - `client` (Optional[NeedleClient]): An optional instance of the NeedleClient. Usage: .. code-block:: python from langchain_community.retrievers.needle import NeedleRetriever retriever = NeedleRetriever( needle_api_key="your-api-key", collection_id="your-collection-id" ) results = retriever.retrieve("example query") for doc in results: print(doc.page_content) NclientzNeedle API Key) descriptionneedle_api_key.z,The ID of the Needle collection to search in collection_id)returncCsDzddlm}Wnty*tdYn0|js@||jd|_dS)z Initialize the NeedleClient with the provided API key. If a client instance is already provided, this method does nothing. r) NeedleClientz0Please install with `pip install needle-python`.)Zapi_keyN)Z needle.v1r ImportErrorr r )selfrrs/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/langchain_community/retrievers/needle.py_initialize_client1s  z"NeedleRetriever._initialize_client)queryrcCs@||jdurtd|jjj|j|d}dd|D}|S)z Search the Needle collection for relevant documents. Args: query (str): The search query used to find relevant documents. Returns: List[Document]: A list of documents matching the search query. Nz4NeedleClient is not initialized. Provide an API key.)rtextcSsg|]}t|jdqS))Z page_content)rcontent).0resultrrr Pz6NeedleRetriever._search_collection..)rr ValueError collectionssearchr)rrresultsdocsrrr_search_collection?s  z"NeedleRetriever._search_collection)r run_managerrcCs ||S)z Retrieve relevant documents based on the query. Args: query (str): The query string used to search the collection. Returns: List[Document]: A list of documents relevant to the query. )r")rrr#rrr_get_relevant_documentsSs z'NeedleRetriever._get_relevant_documents)__name__ __module__ __qualname____doc__r rr__annotations__r r strrrrrr"rr$rrrrr s  r N)typingrrrZlangchain_core.callbacksrZlangchain_core.documentsrZlangchain_core.retrieversrZpydanticrr r rrrrs