dh~SSKrSSKrSSKJrJrJrJr SSKJr SSK J r \R"\ 5r "SS\ 5rg)N)DictListOptionalSequence)Document) BaseLoaderc\rSrSrSrSSSSS.S\S\S\S \\S \\\S \\\S \ S S4Sjjr S \ \ 4Sjr S \ \ 4SjrS \\4SjrSS\S\\S\S \4SjjrSrg) MongodbLoader zLoad MongoDB documents.NT)filter_criteria field_namesmetadata_names!include_db_collection_in_metadataconnection_stringdb_namecollection_namer r rrreturncSSKJn 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 ValueErrorclientrrr r rr get_databasedbget_collection collection) selfrrrr r rrres d/var/www/html/shao/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)rs r loadMongodbLoader.loadJs{{4::<((c# /nURRUR5IShvN nUR5nURR URU5ShvN nUR X@R SS9nUR(a(URURURS.5 URbTUR X@RSS9nUR5Vs/sHn[U5PM nnSRU5n O [U5n UR[!XS95 MGNNs snf [#U5U:wa%[$R'S[#U5SUS 35 U$7f) z0Asynchronously loads data into Document objects.N)default)databaser ) page_contentmetadataz6Only partial collection of documents returned. Loaded z docs, expected .)rcount_documentsr _construct_projectionfind_extract_fieldsrrupdaterrr valuesstrjoinappendrlenloggerwarning) rresult total_docs projectiondocr0fieldsvaluetextstexts r r&MongodbLoader.aloadXsb??::4;O;OPP //1 --d.B.BJO J#++C1D1Db+QH55$(LL&*&:&:+--c3C3CR-P17AUAxx3x MM(H I1Q JBP, v;* $ NNf+&6zl!E   s@+F E :F (E,E -E0B F =E:F  Erds511-@   8 $IJIr)