3fi NddlmZmZddlmZddlmZddlmZGddeZ y))ListOptional)Document) BaseLoader) OBSFileLoaderc FeZdZdZ d dededeedefdZdee fd Z y) OBSDirectoryLoaderz!Load from `Huawei OBS directory`.Nbucketendpointconfigprefixc4 ddlm}|s t}|j dr||d|_n>||j d|j d|j d | |_||_||_y #t$r tdwxYw) aInitialize the OBSDirectoryLoader with the specified settings. Args: bucket (str): The name of the OBS bucket to be used. endpoint (str): The endpoint URL of your OBS bucket. config (dict): The parameters for connecting to OBS, provided as a dictionary. The dictionary could have the following keys: - "ak" (str, optional): Your OBS access key (required if `get_token_from_ecs` is False and bucket policy is not public read). - "sk" (str, optional): Your OBS secret key (required if `get_token_from_ecs` is False and bucket policy is not public read). - "token" (str, optional): Your security token (required if using temporary credentials). - "get_token_from_ecs" (bool, optional): Whether to retrieve the security token from ECS. Defaults to False if not provided. If set to True, `ak`, `sk`, and `token` will be ignored. prefix (str, optional): The prefix to be added to the OBS key. Defaults to "". Note: Before using this class, make sure you have registered with OBS and have the necessary credentials. The `ak`, `sk`, and `endpoint` values are mandatory unless `get_token_from_ecs` is True or the bucket policy is public read. `token` is required when using temporary credentials. Example: To create a new OBSDirectoryLoader: ``` config = { "ak": "your-access-key", "sk": "your-secret-key" } ``` directory_loader = OBSDirectoryLoader("your-bucket-name", "your-end-endpoint", config, "your-prefix") r) ObsClientzfCould not import esdk-obs-python python package. Please install it with `pip install esdk-obs-python`.get_token_from_ecsECS)serversecurity_provider_policyaksktoken) access_key_idsecret_access_keysecurity_tokenrN)obsr ImportErrordictgetclientr r )selfr r r r rs p/var/www/auto_recruiter/arenv/lib/python3.12/site-packages/langchain_community/document_loaders/obs_directory.py__init__zOBSDirectoryLoader.__init__ s>  % VF ::* +#8eTDK#$jj."(**T"2%zz'2 DK  % H  s BBreturncd}d}g} |jj|j|j||}|jdkr|j j D]M}t|j|j|j}|j|jO|j jdur|j j}n |S)zLoad documents.iNT)r markermax_keysi,)r) r listObjectsr r statusbodycontentsrkeyextendload is_truncated next_marker)rmax_nummarkdocsrespcontentloaders r r,zOBSDirectoryLoader.loadBs;;** DKKw+D{{S #yy11/G*4;; DKKXFKK ./99))T19900D )N) __name__ __module__ __qualname____doc__strrrr!rrr,r5r r r sM+ "& 333 3  3jd8nr5r N) typingrrlangchain_core.documentsr)langchain_community.document_loaders.baser-langchain_community.document_loaders.obs_filerr r<r5r rAs!-@GIIr5