ih rddlZddlmZmZmZddlmZddlmZeje Z GddeZ y)N)IteratorListOptional)Document) BaseLoadercfeZdZdZddddededededeeed eeed dfd Zd ee fd Z y) CouchbaseLoaderaULoad documents from `Couchbase`. Each document represents one row of the result. The `page_content_fields` are written into the `page_content`of the document. The `metadata_fields` are written into the `metadata` of the document. By default, all columns are written into the `page_content` and none into the `metadata`. N)page_content_fieldsmetadata_fieldsconnection_string db_username db_passwordqueryr r returnc ddlm}ddlm}ddlm} |s td|s td|s td |||} ||| | |_||_ ||_ ||_ y#t $r} t d| d} ~ wwxYw) aInitialize Couchbase document loader. Args: connection_string (str): The connection string to the Couchbase cluster. db_username (str): The username to connect to the Couchbase cluster. db_password (str): The password to connect to the Couchbase cluster. query (str): The SQL++ query to execute. page_content_fields (Optional[List[str]]): The columns to write into the `page_content` field of the document. By default, all columns are written. metadata_fields (Optional[List[str]]): The columns to write into the `metadata` field of the document. By default, no columns are written. r)PasswordAuthenticator)Cluster)ClusterOptionsz]Could not import couchbase package.Please install couchbase SDK with `pip install couchbase`.Nz#connection_string must be provided.zdb_username must be provided.zdb_password must be provided.) couchbase.authrcouchbase.clusterrcouchbase.optionsr ImportError ValueErrorclusterrr r ) selfr r rrr r rrreauths l/var/www/html/dev/engine/venv/lib/python3.12/site-packages/langchain_community/document_loaders/couchbase.py__init__zCouchbaseLoader.__init__s.  < 1 8 !BC C<= =<= =$    !((9>$;O P  #6 .- M  sA.. B7 BBc#Kddlm}|jj|d|jj |j}|D]}|j }|j st|j|sg}|Dcic]}||| }}djfd|jD}t||ycc}ww) z1Load Couchbase data into Document objects lazily.r) timedelta)seconds c3<K|]\}}|vs |d|yw)z: N).0kvr s r z,CouchbaseLoader.lazy_load..\s,! $1qrDs6++-@   8 $UGjUGr=