j bddlmZddlmZmZmZmZddlmZddl m Z ddl m Z Gdde Z y) ) annotations)AnyIteratorOptionalSequence)Document) BaseLoader)MaxComputeAPIWrappercjeZdZdZddd ddZeddd d dZd dZy) MaxComputeLoaderz+Load from `Alibaba Cloud MaxCompute` table.N)page_content_columnsmetadata_columnsc<||_||_||_||_y)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)query api_wrapperr r)selfrrr rs z/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langchain_community/document_loaders/max_compute.py__init__zMaxComputeLoader.__init__s#$ &$8! 0 access_idsecret_access_keyc Htj||||}|||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)clsrendpointprojectrrkwargsrs rrzMaxComputeLoader.from_params%s22+66 gFW 5+000rc#>K|jj|jD]}|jr3|jDcic]\}}||jvs||}}}n|}dj d|jD}|j r3|jDcic]\}}||j vs||}}}n(|jDcic] \}}||vs ||}}}t ||ycc}}wcc}}wcc}}ww)N c30K|]\}}|d|yw)z: N).0kvs r z-MaxComputeLoader.lazy_load..Ks!$W=VTQs"QC[=Vs) page_contentmetadata)rrr itemsjoinrr)rrowr$r%page_content_datar'r(s r lazy_loadzMaxComputeLoader.lazy_loadCs##))$**5C((%(YY[%%0TQA9R9R4RAqD["%%(!99$W=N=T=T=V$WWL$$-0YY[W[TQAAVAVr<s'"44-@JEIzEIr