-hSSKrSSKrSSKJrJrJrJrJrJr SSK J r SSK J r \R"\5r"SS\ 5rg)N) AsyncIteratorDictIteratorListOptionalSequence)Document) BaseLoaderc \rSrSrSrSSSSS.S\S\S\S \\S \\\S \\\S \ S S4Sjjr S \ \ 4Sjr S \\ 4SjrS \\ 4SjrS \ \ 4SjrS\S \ 4SjrS \\4SjrSS\S\\S\S \4SjjrSrg) MongodbLoader zLoad MongoDB documents.NT)filter_criteria field_namesmetadata_names!include_db_collection_in_metadataconnection_stringdb_namecollection_namerrrrreturncSSKJn U(d [S5eU(d [S5eU(d [S5eU"U5UlX lX0lU=(d /UlU=(d 0UlU=(d /Ul Xpl URRU5Ul URRU5Ulg![an [S5U eSn A ff=f)a! Initializes the MongoDB loader with necessary database connection details and configurations. Args: connection_string (str): MongoDB connection URI. db_name (str):Name of the database to connect to. collection_name (str): Name of the collection to fetch documents from. filter_criteria (Optional[Dict]): MongoDB filter criteria for querying documents. field_names (Optional[Sequence[str]]): List of field names to retrieve from documents. metadata_names (Optional[Sequence[str]]): Additional metadata fields to extract from documents. include_db_collection_in_metadata (bool): Flag to include database and collection names in metadata. Raises: ImportError: If the motor library is not installed. ValueError: If any necessary argument is missing. r)AsyncIOMotorClientzBCannot import from motor, please install with `pip install motor`.Nz#connection_string must be provided.zdb_name must be provided.z!collection_name must be provided.)motor.motor_asyncior ImportError ValueErrorclientrrrrrr get_databasedbget_collection collection) selfrrrrrrrres \/root/34ku/venv/lib/python3.13/site-packages/langchain_community/document_loaders/mongodb.py__init__MongodbLoader.__init__s@  > !BC C89 9@A A():;  .&,".4",21R.++**73''00A/ T  sC C) C$$C)cJ[R"UR55$)aOLoad data into Document objects. Attention: This implementation starts an asyncio event loop which will only work if running in a sync env. In an async env, it should fail since there is already an event loop running. This code should be updated to kick off the event loop from a separate thread if running within an async context. )asynciorunaload)r s r"loadMongodbLoader.loadJs{{4::<((c#:# [R"5nUR 5nUR UR55nUv M&![a. [R"5n[R"U5 Nnf=f![a gf=f7f)aA lazy loader for MongoDB documents. Attention: This implementation starts an asyncio event loop which will only work if running in a sync env. In an async env, it should fail since there is already an event loop running. This code should be updated to kick off the event loop from a separate thread if running within an async context. Yields: Document: A document from the MongoDB collection. N) r&get_running_loop RuntimeErrornew_event_loopset_event_loop alazy_loadrun_until_complete __anext__StopAsyncIteration)r event_loopasync_generatordocuments r" lazy_loadMongodbLoader.lazy_loadXs / 113J //+ %889R9R9TU  / //1J  " ": . /&  sJBAB#B B5BBBB BBBBc# UR5nURRURU5ShvN nUR U57v MN g7f)zuAsynchronously yields Document objects one at a time. Yields: Document: A document from the MongoDB collection. N)_construct_projectionrfindr_process_document)r projectiondocs r"r1MongodbLoader.alazy_loadvsO //1 --d.B.BJO .#((- - .Os&7AAAAAAAc# /nURRUR5IShvN nUR5nURR URU5ShvN nUR UR U55 M+NeN( [U5U:wa%[RS[U5SUS35 U$7f)z0Asynchronously loads data into Document objects.Nz6Only partial collection of documents returned. Loaded z docs, expected .) rcount_documentsrr;r<appendr=lenloggerwarning)r result total_docsr>r?s r"r(MongodbLoader.aloads??::4;O;OPP //1 --d.B.BJO 7# MM$005 6 Q 7O v;* $ NNf+&6zl!E   s3+CB:C(B,B-B0$CB7Cr?cURXRSS9nUR(a(URURUR S.5 UR bUURXR SS9nUR5Vs/sHn[U5PM nnSRU5nO [U5n[XbS9$s snf)zProcess a single MongoDB document into a Document object. Args: doc: The MongoDB document dictionary to process into a Document object. )default)databaser ) page_contentmetadata) _extract_fieldsrrupdaterrrvaluesstrjoinr )r r?rQfieldsvaluetextstexts r"r=MongodbLoader._process_documents ''-@-@"'M  1 1 OO $ "&"6"6     '))#/?/?)LF-3]]_=_ESZ_E=88E?Ds8DT== >s C c[UR5=(d /n[UR5=(d /nX-nU(aUVs0sHoDS_M sn$S$s snf)zmConstructs the projection dictionary for MongoDB query based on the specified field names and metadata names.N)listrr)r rr all_fieldsfields r"r;#MongodbLoader._construct_projectionsW4++,2 d1128b 1 5?j1jUqj1ITI1s Ar7rWrMc0nU=(d /HKnUnURS5HnURXs5nXc:XdM O URSS5nXdU'MM U$)zAExtracts and returns values for specified fields from a document.rB_)splitgetreplace) r r7rWrM extractedr`rXkeynew_field_names r"rRMongodbLoader._extract_fieldssj \r\EE{{3' #/#(#]]34N(-n %"r+) rrrrrrrrr)rL)__name__ __module__ __qualname____firstlineno____doc__rUrrrboolr#rr r)rr8rr1r(r=r;rR__static_attributes__r+r"r r s&!+//326269B9B9B 9B "$ 9Bhsm,9B!#/9B,09B 9Bv )d8n )8H-< .-"9 .T(^$>T>h>6Jx~J     r+r )r&loggingtypingrrrrrrlangchain_core.documentsr )langchain_community.document_loaders.baser getLoggerrkrFr rrr+r"rxs5JJ-@   8 $zJzr+