dha SSKJrJrJrJrJr SSKJr SrSr S\4Sjr S\ S\S\4S jr S\4S jr S\ S\S\4S jr"S S \5rg))AnyDictListOptionalSequence) RecordManagerzKCould not import MongoClient. Please install it with `pip install pymongo`.zPCould not import AsyncIOMotorClient. Please install it with `pip install motor`.returncNSSKJn U$![a [[5ef=f)z3Import PyMongo if available, otherwise raise error.r MongoClient)pymongor ImportErrorIMPORT_PYMONGO_ERRORr s e/var/www/html/shao/venv/lib/python3.13/site-packages/langchain_community/indexes/_document_manager.py_import_pymongor s/0'  0.//0 $ mongodb_urlkwargsc p[5nU"U40UD6nU$![an[SUS35eSnAff=f)zPGet MongoClient for sync operations from the mongodb_url, otherwise raise error.z@MongoClient string provided is not in proper format. Got error:  N)r ValueErrorr)rrr clientes r_get_pymongo_clientrsQ !#// M  NqcQR S    505cNSSKJn U$![a [[5ef=f)z1Import Motor if available, otherwise raise error.rAsyncIOMotorClient)motor.motor_asynciorrIMPORT_MOTOR_ASYNCIO_ERRORrs r_import_motor_asyncior!#s/6:  64556rc p[5nU"U40UD6nU$![an[SUS35eSnAff=f)zXGet AsyncIOMotorClient for async operations from the mongodb_url, otherwise raise error.zGAsyncIOMotorClient string provided is not in proper format. Got error: rN)r!rr)rrmotorrrs r_get_motor_clientr$,sU %'{-f- M  A    rc ^\rSrSrSrSS.S\S\S\S\S S 4 U4S jjjrS!S jrS!S jrS S S.S\ \S\ \ \ \S\ \ S S 4Sjjr S S S.S\ \S\ \ \ \S\ \ S S 4Sjjr S \ 4SjrS \ 4SjrS\ \S \\4SjrS\ \S \\4SjrS S S S S.S\ \ S\ \ S\ \ \S\ \S \\4 SjjrS S S S S.S\ \ S\ \ S\ \ \S\ \S \\4 SjjrS\ \S S 4SjrS\ \S S 4SjrS rU=r$)"MongoDocumentManager:z7A MongoDB based implementation of the document manager.documentMetadata)collection_name namespacerdb_namer)r Nc>[TU]US9 [U5UlURUUlURUUl[ U5UlURUUlURUUl g)zInitialize the MongoDocumentManager. Args: namespace: The namespace associated with this document manager. db_name: The name of the database to use. collection_name: The name of the collection to use. Default is 'documentMetadata'. )r*N) super__init__r sync_clientsync_dbsync_collectionr$ async_clientasync_dbasync_collection)selfr*rr+r) __class__s rr.MongoDocumentManager.__init__=su 9-.{;''0 #||O<-k:))'2 $ o >cgz4Create the database schema for the document manager.Nr5s r create_schema"MongoDocumentManager.create_schemaUs r8c # g7fr:r;r<s racreate_schema#MongoDocumentManager.acreate_schemaYs s) group_ids time_at_leastkeysrBrCc UcS/[U5-n[U5[U5:wa [S5e[X5H?upEURR UR US.SXPR 5S.0SS9 MA g)z-Upsert documents into the MongoDB collection.N1Number of keys does not match number of group_idsr*key$setgroup_id updated_atTupsert)lenrzipr1find_one_and_updater*get_time)r5rDrBrCrHrKs rupdateMongoDocumentManager.update]s  T*I t9I &PQ Q 1MC  4 4"nnS9hmmoNO 5 2r8cl# UcS/[U5-n[U5[U5:wa [S5eUR5IShvN nU(aXC:a [S5e[X5H9upVURR UR US.SXdS.0SS9IShvN M; gNdN 7f) z >u E%%**55!*=  '--fsE f---s Bc^# SUR0nU(aSU0US'U(aSU0US'U(aSU0US'U(a-URRUSS05RU5OURRUSS05nUVs/sS hvN owSPMN sn$s snf7f) z[ Asynchronously list documents in the MongoDB collection based on the provided date range. r*rwrLrxrhrKrHriN)r*r4rjrurys r alist_keysMongoDocumentManager.alist_keyss"-dnn = #(&/E,  #(%.E,  !& 2E*   ! ! & &uuaj 9 ? ? F&&++EE1:>  -333SE 333s6BB-B(B$B" B$B("B$$B(%B-cXURRURSU0S.5 g)z-Delete documents from the MongoDB collection.rhrGN)r1 delete_manyr*r5rDs r delete_keys MongoDocumentManager.delete_keyss) ((!^^t}  r8ct# URRURSU0S.5IShvN gN7f)zrs~66:RW  S C C s 3 # # s =s r8