Ng jddlmZddlmZmZmZmZddlmZddl m Z ddl m Z Gdde Z dS) ) annotations)AnyIteratorOptionalSequence)Document) BaseLoader)MaxComputeAPIWrappercJeZdZdZddddd Zeddd ddZddZdS)MaxComputeLoaderz+Load from `Alibaba Cloud MaxCompute` table.N)page_content_columnsmetadata_columnsquerystr api_wrapperr r Optional[Sequence[str]]rc>||_||_||_||_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. N)rrr r)selfrrr rs l/var/www/html/ai-engine/env/lib/python3.11/site-packages/langchain_community/document_loaders/max_compute.py__init__zMaxComputeLoader.__init__s)$ &$8! 0 access_idsecret_access_keyendpointprojectr Optional[str]rkwargsrreturnc Ftj||||}|||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)clsrrrrrrrs rr!zMaxComputeLoader.from_params%sA2+6 gFW   s5+00000rIterator[Document]c#KjjD]}jr!fd|Dn|ddD}jr!fd|D}n fd|D}t ||VdS)Nc.i|]\}}|jv||S)r .0kvrs r z.MaxComputeLoader.lazy_load..Fs3%%%!QA9R4R4RAq4R4R4Rr c3*K|]\}}|d|VdS)z: Nr&)r(r)r*s r z-MaxComputeLoader.lazy_load..Ks0$W$WTQ[[Q[[$W$W$W$W$W$Wrc.i|]\}}|jv||Sr&)rr's rr+z.MaxComputeLoader.lazy_load..Ms,WWWTQAAV.Os*WWWTQAEVrBs""""""444444444444------@@@@@@JJJJJJEIEIEIEIEIzEIEIEIEIEIr