a bg @s\ddlmZddlmZmZmZmZddlmZddl m Z ddl m Z Gddde Z dS) ) annotations)AnyIteratorOptionalSequence)Document) BaseLoader)MaxComputeAPIWrapperc @s`eZdZdZdddddddddd Zeddd dddd d d dd ddZddddZdS)MaxComputeLoaderz+Load from `Alibaba Cloud MaxCompute` table.N)page_content_columnsmetadata_columnsstrr zOptional[Sequence[str]]query api_wrapperr r cCs||_||_||_||_dS)aInitialize Alibaba Cloud MaxCompute document loader. Args: query: SQL query to execute. api_wrapper: MaxCompute API wrapper. page_content_columns: The columns to write into the `page_content` of the Document. If unspecified, all columns will be written to `page_content`. metadata_columns: The columns to write into the `metadata` of the Document. If unspecified, all columns not added to `page_content` will be written. Nr)selfrrr r r~/var/www/html/cobodadashboardai.evdpl.com/venv/lib/python3.9/site-packages/langchain_community/document_loaders/max_compute.py__init__szMaxComputeLoader.__init__ access_idsecret_access_keyz Optional[str]r)rendpointprojectrrkwargsreturncKs$tj||||d}|||fi|S)aConvenience constructor that builds the MaxCompute API wrapper from given parameters. Args: query: SQL query to execute. endpoint: MaxCompute endpoint. project: A project is a basic organizational unit of MaxCompute, which is similar to a database. access_id: MaxCompute access ID. Should be passed in directly or set as the environment variable `MAX_COMPUTE_ACCESS_ID`. secret_access_key: MaxCompute secret access key. Should be passed in directly or set as the environment variable `MAX_COMPUTE_SECRET_ACCESS_KEY`. r)r from_params)clsrrrrrrrrrrr%szMaxComputeLoader.from_paramszIterator[Document])rc#sjjD]}jr0fdd|Dn|dddD}jrjfdd|D}nfdd|D}t||dVqdS) Ncs i|]\}}|jvr||qSr)r .0kvrrr Fsz.MaxComputeLoader.lazy_load.. css |]\}}|d|VqdS)z: Nrrrrr Kz-MaxComputeLoader.lazy_load..cs i|]\}}|jvr||qSr)r rr"rrr#Mr&csi|]\}}|vr||qSrrr)page_content_datarrr#Or&) page_contentmetadata)rrr itemsjoinr r)rrowr(r)r)r'rr lazy_loadCs zMaxComputeLoader.lazy_load)__name__ __module__ __qualname____doc__r classmethodrr-rrrrr s r N) __future__rtypingrrrrZlangchain_core.documentsrZ)langchain_community.document_loaders.baserZ)langchain_community.utilities.max_computer r rrrrs