Merge 'integration_2025-05-23_911101987074' into 'master'

merge branch integration_2025-05-23_911101987074 into master

See merge request: !621

Author: bytestarter

meta.json

@@ -1,4 +1,4 @@
 {
-	"lasted": "3.0.3",
-	"meta_commit": "d39d73a1b07d173697dac5f0c8c96321d3ba9a63"
+	"lasted": "3.0.4",
+	"meta_commit": "99e844885b2bdbb368825db1eb393f07405e3e26"
 }

setup.py

@@ -3,7 +3,7 @@
 from setuptools import setup, find_packages  # noqa: H301
 
 NAME = "volcengine-python-sdk"
-VERSION = "3.0.3"
+VERSION = "3.0.4"
 # To install the library, run the following
 #
 # python setup.py install

volcenginesdkcore/api_client.py

@@ -63,7 +63,7 @@ def __init__(self, configuration=None, header_name=None, header_value=None,
             self.default_headers[header_name] = header_value
         self.cookie = cookie
         # Set default User-Agent.
-        self.user_agent = 'volcstack-python-sdk/3.0.3'
+        self.user_agent = 'volcstack-python-sdk/3.0.4'
         self.client_side_validation = configuration.client_side_validation
 
         self.interceptor_chain = InterceptorChain()

volcenginesdkcore/configuration.py

@@ -257,5 +257,5 @@ def to_debug_report(self):
                "OS: {env}\n" \
                "Python Version: {pyversion}\n" \
                "Version of the API: 0.1.0\n" \
-               "SDK Package Version: 3.0.3".\
+               "SDK Package Version: 3.0.4".\
             format(env=sys.platform, pyversion=sys.version)

volcenginesdkvepfs/__init__.py

@@ -24,12 +24,18 @@
 from volcenginesdkvepfs.models.attach_mount_service_to_self_file_system_response import AttachMountServiceToSelfFileSystemResponse
 from volcenginesdkvepfs.models.capacity_info_for_describe_file_system_statistics_output import CapacityInfoForDescribeFileSystemStatisticsOutput
 from volcenginesdkvepfs.models.capacity_info_for_describe_file_systems_output import CapacityInfoForDescribeFileSystemsOutput
+from volcenginesdkvepfs.models.config_data_flow_bandwidth_request import ConfigDataFlowBandwidthRequest
+from volcenginesdkvepfs.models.config_data_flow_bandwidth_response import ConfigDataFlowBandwidthResponse
+from volcenginesdkvepfs.models.create_data_flow_task_request import CreateDataFlowTaskRequest
+from volcenginesdkvepfs.models.create_data_flow_task_response import CreateDataFlowTaskResponse
 from volcenginesdkvepfs.models.create_file_system_request import CreateFileSystemRequest
 from volcenginesdkvepfs.models.create_file_system_response import CreateFileSystemResponse
 from volcenginesdkvepfs.models.create_fileset_request import CreateFilesetRequest
 from volcenginesdkvepfs.models.create_fileset_response import CreateFilesetResponse
 from volcenginesdkvepfs.models.create_mount_service_request import CreateMountServiceRequest
 from volcenginesdkvepfs.models.create_mount_service_response import CreateMountServiceResponse
+from volcenginesdkvepfs.models.create_pre_signed_url_request import CreatePreSignedUrlRequest
+from volcenginesdkvepfs.models.create_pre_signed_url_response import CreatePreSignedUrlResponse
 from volcenginesdkvepfs.models.delete_file_system_request import DeleteFileSystemRequest
 from volcenginesdkvepfs.models.delete_file_system_response import DeleteFileSystemResponse
 from volcenginesdkvepfs.models.delete_fileset_request import DeleteFilesetRequest
@@ -54,6 +60,7 @@
 from volcenginesdkvepfs.models.describe_zones_response import DescribeZonesResponse
 from volcenginesdkvepfs.models.detach_mount_service_from_self_file_system_request import DetachMountServiceFromSelfFileSystemRequest
 from volcenginesdkvepfs.models.detach_mount_service_from_self_file_system_response import DetachMountServiceFromSelfFileSystemResponse
+from volcenginesdkvepfs.models.entry_list_file_info_for_create_data_flow_task_input import EntryListFileInfoForCreateDataFlowTaskInput
 from volcenginesdkvepfs.models.expand_file_system_request import ExpandFileSystemRequest
 from volcenginesdkvepfs.models.expand_file_system_response import ExpandFileSystemResponse
 from volcenginesdkvepfs.models.file_system_for_describe_file_systems_output import FileSystemForDescribeFileSystemsOutput

volcenginesdkvepfs/api/vepfs_api.py

@@ -130,6 +130,200 @@ def attach_mount_service_to_self_file_system_with_http_info(self, body, **kwargs
             _request_timeout=params.get('_request_timeout'),
             collection_formats=collection_formats)
 
+    def config_data_flow_bandwidth(self, body, **kwargs):  # noqa: E501
+        """config_data_flow_bandwidth  # noqa: E501
+
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please pass async_req=True
+        >>> thread = api.config_data_flow_bandwidth(body, async_req=True)
+        >>> result = thread.get()
+
+        :param async_req bool
+        :param ConfigDataFlowBandwidthRequest body: (required)
+        :return: ConfigDataFlowBandwidthResponse
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+        kwargs['_return_http_data_only'] = True
+        if kwargs.get('async_req'):
+            return self.config_data_flow_bandwidth_with_http_info(body, **kwargs)  # noqa: E501
+        else:
+            (data) = self.config_data_flow_bandwidth_with_http_info(body, **kwargs)  # noqa: E501
+            return data
+
+    def config_data_flow_bandwidth_with_http_info(self, body, **kwargs):  # noqa: E501
+        """config_data_flow_bandwidth  # noqa: E501
+
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please pass async_req=True
+        >>> thread = api.config_data_flow_bandwidth_with_http_info(body, async_req=True)
+        >>> result = thread.get()
+
+        :param async_req bool
+        :param ConfigDataFlowBandwidthRequest body: (required)
+        :return: ConfigDataFlowBandwidthResponse
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+
+        all_params = ['body']  # noqa: E501
+        all_params.append('async_req')
+        all_params.append('_return_http_data_only')
+        all_params.append('_preload_content')
+        all_params.append('_request_timeout')
+
+        params = locals()
+        for key, val in six.iteritems(params['kwargs']):
+            if key not in all_params:
+                raise TypeError(
+                    "Got an unexpected keyword argument '%s'"
+                    " to method config_data_flow_bandwidth" % key
+                )
+            params[key] = val
+        del params['kwargs']
+        # verify the required parameter 'body' is set
+        if self.api_client.client_side_validation and ('body' not in params or
+                                                       params['body'] is None):  # noqa: E501
+            raise ValueError("Missing the required parameter `body` when calling `config_data_flow_bandwidth`")  # noqa: E501
+
+        collection_formats = {}
+
+        path_params = {}
+
+        query_params = []
+
+        header_params = {}
+
+        form_params = []
+        local_var_files = {}
+
+        body_params = None
+        if 'body' in params:
+            body_params = params['body']
+        # HTTP header `Accept`
+        header_params['Accept'] = self.api_client.select_header_accept(
+            ['application/json'])  # noqa: E501
+
+        # HTTP header `Content-Type`
+        header_params['Content-Type'] = self.api_client.select_header_content_type(  # noqa: E501
+            ['application/json'])  # noqa: E501
+
+        # Authentication setting
+        auth_settings = ['volcengineSign']  # noqa: E501
+
+        return self.api_client.call_api(
+            '/ConfigDataFlowBandwidth/2022-01-01/vepfs/post/application_json/', 'POST',
+            path_params,
+            query_params,
+            header_params,
+            body=body_params,
+            post_params=form_params,
+            files=local_var_files,
+            response_type='ConfigDataFlowBandwidthResponse',  # noqa: E501
+            auth_settings=auth_settings,
+            async_req=params.get('async_req'),
+            _return_http_data_only=params.get('_return_http_data_only'),
+            _preload_content=params.get('_preload_content', True),
+            _request_timeout=params.get('_request_timeout'),
+            collection_formats=collection_formats)
+
+    def create_data_flow_task(self, body, **kwargs):  # noqa: E501
+        """create_data_flow_task  # noqa: E501
+
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please pass async_req=True
+        >>> thread = api.create_data_flow_task(body, async_req=True)
+        >>> result = thread.get()
+
+        :param async_req bool
+        :param CreateDataFlowTaskRequest body: (required)
+        :return: CreateDataFlowTaskResponse
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+        kwargs['_return_http_data_only'] = True
+        if kwargs.get('async_req'):
+            return self.create_data_flow_task_with_http_info(body, **kwargs)  # noqa: E501
+        else:
+            (data) = self.create_data_flow_task_with_http_info(body, **kwargs)  # noqa: E501
+            return data
+
+    def create_data_flow_task_with_http_info(self, body, **kwargs):  # noqa: E501
+        """create_data_flow_task  # noqa: E501
+
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please pass async_req=True
+        >>> thread = api.create_data_flow_task_with_http_info(body, async_req=True)
+        >>> result = thread.get()
+
+        :param async_req bool
+        :param CreateDataFlowTaskRequest body: (required)
+        :return: CreateDataFlowTaskResponse
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+
+        all_params = ['body']  # noqa: E501
+        all_params.append('async_req')
+        all_params.append('_return_http_data_only')
+        all_params.append('_preload_content')
+        all_params.append('_request_timeout')
+
+        params = locals()
+        for key, val in six.iteritems(params['kwargs']):
+            if key not in all_params:
+                raise TypeError(
+                    "Got an unexpected keyword argument '%s'"
+                    " to method create_data_flow_task" % key
+                )
+            params[key] = val
+        del params['kwargs']
+        # verify the required parameter 'body' is set
+        if self.api_client.client_side_validation and ('body' not in params or
+                                                       params['body'] is None):  # noqa: E501
+            raise ValueError("Missing the required parameter `body` when calling `create_data_flow_task`")  # noqa: E501
+
+        collection_formats = {}
+
+        path_params = {}
+
+        query_params = []
+
+        header_params = {}
+
+        form_params = []
+        local_var_files = {}
+
+        body_params = None
+        if 'body' in params:
+            body_params = params['body']
+        # HTTP header `Accept`
+        header_params['Accept'] = self.api_client.select_header_accept(
+            ['application/json'])  # noqa: E501
+
+        # HTTP header `Content-Type`
+        header_params['Content-Type'] = self.api_client.select_header_content_type(  # noqa: E501
+            ['application/json'])  # noqa: E501
+
+        # Authentication setting
+        auth_settings = ['volcengineSign']  # noqa: E501
+
+        return self.api_client.call_api(
+            '/CreateDataFlowTask/2022-01-01/vepfs/post/application_json/', 'POST',
+            path_params,
+            query_params,
+            header_params,
+            body=body_params,
+            post_params=form_params,
+            files=local_var_files,
+            response_type='CreateDataFlowTaskResponse',  # noqa: E501
+            auth_settings=auth_settings,
+            async_req=params.get('async_req'),
+            _return_http_data_only=params.get('_return_http_data_only'),
+            _preload_content=params.get('_preload_content', True),
+            _request_timeout=params.get('_request_timeout'),
+            collection_formats=collection_formats)
+
     def create_file_system(self, body, **kwargs):  # noqa: E501
         """create_file_system  # noqa: E501
 
@@ -421,6 +615,103 @@ def create_mount_service_with_http_info(self, body, **kwargs):  # noqa: E501
             _request_timeout=params.get('_request_timeout'),
             collection_formats=collection_formats)
 
+    def create_pre_signed_url(self, body, **kwargs):  # noqa: E501
+        """create_pre_signed_url  # noqa: E501
+
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please pass async_req=True
+        >>> thread = api.create_pre_signed_url(body, async_req=True)
+        >>> result = thread.get()
+
+        :param async_req bool
+        :param CreatePreSignedUrlRequest body: (required)
+        :return: CreatePreSignedUrlResponse
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+        kwargs['_return_http_data_only'] = True
+        if kwargs.get('async_req'):
+            return self.create_pre_signed_url_with_http_info(body, **kwargs)  # noqa: E501
+        else:
+            (data) = self.create_pre_signed_url_with_http_info(body, **kwargs)  # noqa: E501
+            return data
+
+    def create_pre_signed_url_with_http_info(self, body, **kwargs):  # noqa: E501
+        """create_pre_signed_url  # noqa: E501
+
+        This method makes a synchronous HTTP request by default. To make an
+        asynchronous HTTP request, please pass async_req=True
+        >>> thread = api.create_pre_signed_url_with_http_info(body, async_req=True)
+        >>> result = thread.get()
+
+        :param async_req bool
+        :param CreatePreSignedUrlRequest body: (required)
+        :return: CreatePreSignedUrlResponse
+                 If the method is called asynchronously,
+                 returns the request thread.
+        """
+
+        all_params = ['body']  # noqa: E501
+        all_params.append('async_req')
+        all_params.append('_return_http_data_only')
+        all_params.append('_preload_content')
+        all_params.append('_request_timeout')
+
+        params = locals()
+        for key, val in six.iteritems(params['kwargs']):
+            if key not in all_params:
+                raise TypeError(
+                    "Got an unexpected keyword argument '%s'"
+                    " to method create_pre_signed_url" % key
+                )
+            params[key] = val
+        del params['kwargs']
+        # verify the required parameter 'body' is set
+        if self.api_client.client_side_validation and ('body' not in params or
+                                                       params['body'] is None):  # noqa: E501
+            raise ValueError("Missing the required parameter `body` when calling `create_pre_signed_url`")  # noqa: E501
+
+        collection_formats = {}
+
+        path_params = {}
+
+        query_params = []
+
+        header_params = {}
+
+        form_params = []
+        local_var_files = {}
+
+        body_params = None
+        if 'body' in params:
+            body_params = params['body']
+        # HTTP header `Accept`
+        header_params['Accept'] = self.api_client.select_header_accept(
+            ['application/json'])  # noqa: E501
+
+        # HTTP header `Content-Type`
+        header_params['Content-Type'] = self.api_client.select_header_content_type(  # noqa: E501
+            ['application/json'])  # noqa: E501
+
+        # Authentication setting
+        auth_settings = ['volcengineSign']  # noqa: E501
+
+        return self.api_client.call_api(
+            '/CreatePreSignedUrl/2022-01-01/vepfs/post/application_json/', 'POST',
+            path_params,
+            query_params,
+            header_params,
+            body=body_params,
+            post_params=form_params,
+            files=local_var_files,
+            response_type='CreatePreSignedUrlResponse',  # noqa: E501
+            auth_settings=auth_settings,
+            async_req=params.get('async_req'),
+            _return_http_data_only=params.get('_return_http_data_only'),
+            _preload_content=params.get('_preload_content', True),
+            _request_timeout=params.get('_request_timeout'),
+            collection_formats=collection_formats)
+
     def delete_file_system(self, body, **kwargs):  # noqa: E501
         """delete_file_system  # noqa: E501
 

volcenginesdkvepfs/models/__init__.py

@@ -20,12 +20,18 @@
 from volcenginesdkvepfs.models.attach_mount_service_to_self_file_system_response import AttachMountServiceToSelfFileSystemResponse
 from volcenginesdkvepfs.models.capacity_info_for_describe_file_system_statistics_output import CapacityInfoForDescribeFileSystemStatisticsOutput
 from volcenginesdkvepfs.models.capacity_info_for_describe_file_systems_output import CapacityInfoForDescribeFileSystemsOutput
+from volcenginesdkvepfs.models.config_data_flow_bandwidth_request import ConfigDataFlowBandwidthRequest
+from volcenginesdkvepfs.models.config_data_flow_bandwidth_response import ConfigDataFlowBandwidthResponse
+from volcenginesdkvepfs.models.create_data_flow_task_request import CreateDataFlowTaskRequest
+from volcenginesdkvepfs.models.create_data_flow_task_response import CreateDataFlowTaskResponse
 from volcenginesdkvepfs.models.create_file_system_request import CreateFileSystemRequest
 from volcenginesdkvepfs.models.create_file_system_response import CreateFileSystemResponse
 from volcenginesdkvepfs.models.create_fileset_request import CreateFilesetRequest
 from volcenginesdkvepfs.models.create_fileset_response import CreateFilesetResponse
 from volcenginesdkvepfs.models.create_mount_service_request import CreateMountServiceRequest
 from volcenginesdkvepfs.models.create_mount_service_response import CreateMountServiceResponse
+from volcenginesdkvepfs.models.create_pre_signed_url_request import CreatePreSignedUrlRequest
+from volcenginesdkvepfs.models.create_pre_signed_url_response import CreatePreSignedUrlResponse
 from volcenginesdkvepfs.models.delete_file_system_request import DeleteFileSystemRequest
 from volcenginesdkvepfs.models.delete_file_system_response import DeleteFileSystemResponse
 from volcenginesdkvepfs.models.delete_fileset_request import DeleteFilesetRequest
@@ -50,6 +56,7 @@
 from volcenginesdkvepfs.models.describe_zones_response import DescribeZonesResponse
 from volcenginesdkvepfs.models.detach_mount_service_from_self_file_system_request import DetachMountServiceFromSelfFileSystemRequest
 from volcenginesdkvepfs.models.detach_mount_service_from_self_file_system_response import DetachMountServiceFromSelfFileSystemResponse
+from volcenginesdkvepfs.models.entry_list_file_info_for_create_data_flow_task_input import EntryListFileInfoForCreateDataFlowTaskInput
 from volcenginesdkvepfs.models.expand_file_system_request import ExpandFileSystemRequest
 from volcenginesdkvepfs.models.expand_file_system_response import ExpandFileSystemResponse
 from volcenginesdkvepfs.models.file_system_for_describe_file_systems_output import FileSystemForDescribeFileSystemsOutput