Merge 'integration_2026-04-02_1133150144002' into 'master'

merge branch integration_2026-04-02_1133150144002 into master

See merge request: !1137

Author: bytestarter

meta.json

@@ -1,4 +1,4 @@
 {
-	"lasted": "5.0.21",
-	"meta_commit": "4d23faddbb490000d3c4c575c97cafd7a4091f59"
+	"lasted": "5.0.22",
+	"meta_commit": "3e0f2fd9c3a0a6f68773d1e56dc888b5dd0ceb40"
 }

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "volcengine-python-sdk"
-version = "5.0.21"
+version = "5.0.22"
 authors = [
     {name = "volc-engine", email = "volc-sdk-team@bytedance.com"},
 ]

setup.py

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

volcenginesdkbilling/models/instance_list_for_list_available_instances_output.py

@@ -41,6 +41,7 @@ class InstanceListForListAvailableInstancesOutput(object):
         'instance_name': 'str',
         'payment_method': 'str',
         'product': 'str',
+        'product_name': 'str',
         'remain_renew_times': 'str',
         'renew_type': 'str',
         'renewal_duration_unit': 'str',
@@ -58,6 +59,7 @@ class InstanceListForListAvailableInstancesOutput(object):
         'instance_name': 'InstanceName',
         'payment_method': 'PaymentMethod',
         'product': 'Product',
+        'product_name': 'ProductName',
         'remain_renew_times': 'RemainRenewTimes',
         'renew_type': 'RenewType',
         'renewal_duration_unit': 'RenewalDurationUnit',
@@ -66,7 +68,7 @@ class InstanceListForListAvailableInstancesOutput(object):
         'sub_status': 'SubStatus'
     }
 
-    def __init__(self, account_id=None, begin_time=None, configuration_code=None, expired_time=None, instance_id=None, instance_name=None, payment_method=None, product=None, remain_renew_times=None, renew_type=None, renewal_duration_unit=None, renewal_times=None, status=None, sub_status=None, _configuration=None):  # noqa: E501
+    def __init__(self, account_id=None, begin_time=None, configuration_code=None, expired_time=None, instance_id=None, instance_name=None, payment_method=None, product=None, product_name=None, remain_renew_times=None, renew_type=None, renewal_duration_unit=None, renewal_times=None, status=None, sub_status=None, _configuration=None):  # noqa: E501
         """InstanceListForListAvailableInstancesOutput - a model defined in Swagger"""  # noqa: E501
         if _configuration is None:
             _configuration = Configuration()
@@ -80,6 +82,7 @@ def __init__(self, account_id=None, begin_time=None, configuration_code=None, ex
         self._instance_name = None
         self._payment_method = None
         self._product = None
+        self._product_name = None
         self._remain_renew_times = None
         self._renew_type = None
         self._renewal_duration_unit = None
@@ -104,6 +107,8 @@ def __init__(self, account_id=None, begin_time=None, configuration_code=None, ex
             self.payment_method = payment_method
         if product is not None:
             self.product = product
+        if product_name is not None:
+            self.product_name = product_name
         if remain_renew_times is not None:
             self.remain_renew_times = remain_renew_times
         if renew_type is not None:
@@ -285,6 +290,27 @@ def product(self, product):
 
         self._product = product
 
+    @property
+    def product_name(self):
+        """Gets the product_name of this InstanceListForListAvailableInstancesOutput.  # noqa: E501
+
+
+        :return: The product_name of this InstanceListForListAvailableInstancesOutput.  # noqa: E501
+        :rtype: str
+        """
+        return self._product_name
+
+    @product_name.setter
+    def product_name(self, product_name):
+        """Sets the product_name of this InstanceListForListAvailableInstancesOutput.
+
+
+        :param product_name: The product_name of this InstanceListForListAvailableInstancesOutput.  # noqa: E501
+        :type: str
+        """
+
+        self._product_name = product_name
+
     @property
     def remain_renew_times(self):
         """Gets the remain_renew_times of this InstanceListForListAvailableInstancesOutput.  # noqa: E501

volcenginesdkcore/api_client.py

@@ -64,7 +64,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/5.0.21'
+        self.user_agent = 'volcstack-python-sdk/5.0.22'
         self.client_side_validation = configuration.client_side_validation
 
         self.interceptor_chain = InterceptorChain()

volcenginesdkcore/configuration.py

@@ -291,7 +291,7 @@ def to_debug_report(self):
                "OS: {env}\n" \
                "Python Version: {pyversion}\n" \
                "Version of the API: 0.1.0\n" \
-               "SDK Package Version: 5.0.21".\
+               "SDK Package Version: 5.0.22".\
             format(env=sys.platform, pyversion=sys.version)
 
     @property

volcenginesdkcore/feature/rds/connect_utils.py

@@ -67,14 +67,22 @@ def build_auth_token(api_client, db_user, instance_id, expires=None):
     request.service = DEFAULT_SERVICE
     request.is_presign = True
 
-    # Create interceptor chain:
-    #   ResolveEndpointInterceptor - resolves endpoint + scheme
-    #   SignRequestInterceptor     - presign URL signing
-    chain = InterceptorChain()
-    chain.append_request_interceptor(ResolveEndpointInterceptor())
-    chain.append_request_interceptor(SignRequestInterceptor())
-
     context = InterceptorContext(request=request)
-    context = chain.execute_request(context)
 
-    return '{url}?{query}'.format(url=context.request.url, query=context.request.signed_query)
+    # Step 1: Resolve endpoint to get host
+    resolve_chain = InterceptorChain()
+    resolve_chain.append_request_interceptor(ResolveEndpointInterceptor())
+    context = resolve_chain.execute_request(context)
+
+    # Step 2: Save resolved host to X-Host query param, then clear host so it won't be signed
+    resolved_host = context.request.host
+    context.request.query_params['X-Host'] = '{scheme}://{host}'.format(
+        scheme=context.request.scheme, host=resolved_host)
+    context.request.host = None
+
+    # Step 3: Sign request (host is None, won't be included in signature)
+    sign_chain = InterceptorChain()
+    sign_chain.append_request_interceptor(SignRequestInterceptor())
+    context = sign_chain.execute_request(context)
+
+    return context.request.signed_query

volcenginesdkfilenas/__init__.py

@@ -43,8 +43,6 @@
 from volcenginesdkfilenas.models.create_permission_group_response import CreatePermissionGroupResponse
 from volcenginesdkfilenas.models.create_pre_signed_url_request import CreatePreSignedUrlRequest
 from volcenginesdkfilenas.models.create_pre_signed_url_response import CreatePreSignedUrlResponse
-from volcenginesdkfilenas.models.create_reserved_capacity_request import CreateReservedCapacityRequest
-from volcenginesdkfilenas.models.create_reserved_capacity_response import CreateReservedCapacityResponse
 from volcenginesdkfilenas.models.create_snapshot_request import CreateSnapshotRequest
 from volcenginesdkfilenas.models.create_snapshot_response import CreateSnapshotResponse
 from volcenginesdkfilenas.models.data_flow_for_describe_data_flows_output import DataFlowForDescribeDataFlowsOutput
@@ -61,6 +59,10 @@
 from volcenginesdkfilenas.models.delete_mount_point_response import DeleteMountPointResponse
 from volcenginesdkfilenas.models.delete_permission_group_request import DeletePermissionGroupRequest
 from volcenginesdkfilenas.models.delete_permission_group_response import DeletePermissionGroupResponse
+from volcenginesdkfilenas.models.delete_policy_for_create_data_flow_task_input import DeletePolicyForCreateDataFlowTaskInput
+from volcenginesdkfilenas.models.delete_policy_for_describe_data_flow_tasks_output import DeletePolicyForDescribeDataFlowTasksOutput
+from volcenginesdkfilenas.models.delete_rule_info_for_create_data_flow_task_input import DeleteRuleInfoForCreateDataFlowTaskInput
+from volcenginesdkfilenas.models.delete_rule_info_for_describe_data_flow_tasks_output import DeleteRuleInfoForDescribeDataFlowTasksOutput
 from volcenginesdkfilenas.models.delete_snapshot_request import DeleteSnapshotRequest
 from volcenginesdkfilenas.models.delete_snapshot_response import DeleteSnapshotResponse
 from volcenginesdkfilenas.models.describe_access_points_request import DescribeAccessPointsRequest
@@ -87,8 +89,6 @@
 from volcenginesdkfilenas.models.describe_permission_rules_response import DescribePermissionRulesResponse
 from volcenginesdkfilenas.models.describe_regions_request import DescribeRegionsRequest
 from volcenginesdkfilenas.models.describe_regions_response import DescribeRegionsResponse
-from volcenginesdkfilenas.models.describe_reserved_capacitys_request import DescribeReservedCapacitysRequest
-from volcenginesdkfilenas.models.describe_reserved_capacitys_response import DescribeReservedCapacitysResponse
 from volcenginesdkfilenas.models.describe_snapshots_request import DescribeSnapshotsRequest
 from volcenginesdkfilenas.models.describe_snapshots_response import DescribeSnapshotsResponse
 from volcenginesdkfilenas.models.describe_zones_request import DescribeZonesRequest
@@ -143,7 +143,6 @@
 from volcenginesdkfilenas.models.posix_user_for_create_access_point_input import PosixUserForCreateAccessPointInput
 from volcenginesdkfilenas.models.posix_user_for_describe_access_points_output import PosixUserForDescribeAccessPointsOutput
 from volcenginesdkfilenas.models.region_for_describe_regions_output import RegionForDescribeRegionsOutput
-from volcenginesdkfilenas.models.reserved_capacity_for_describe_reserved_capacitys_output import ReservedCapacityForDescribeReservedCapacitysOutput
 from volcenginesdkfilenas.models.root_path_permission_for_create_access_point_input import RootPathPermissionForCreateAccessPointInput
 from volcenginesdkfilenas.models.root_path_permission_for_describe_access_points_output import RootPathPermissionForDescribeAccessPointsOutput
 from volcenginesdkfilenas.models.sale_for_describe_zones_output import SaleForDescribeZonesOutput

volcenginesdkfilenas/api/filenas_api.py

@@ -906,103 +906,6 @@ def create_pre_signed_url_with_http_info(self, body, **kwargs):  # noqa: E501
             _request_timeout=params.get('_request_timeout'),
             collection_formats=collection_formats)
 
-    def create_reserved_capacity(self, body, **kwargs):  # noqa: E501
-        """create_reserved_capacity  # 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_reserved_capacity(body, async_req=True)
-        >>> result = thread.get()
-
-        :param async_req bool
-        :param CreateReservedCapacityRequest body: (required)
-        :return: CreateReservedCapacityResponse
-                 If the method is called asynchronously,
-                 returns the request thread.
-        """
-        kwargs['_return_http_data_only'] = True
-        if kwargs.get('async_req'):
-            return self.create_reserved_capacity_with_http_info(body, **kwargs)  # noqa: E501
-        else:
-            (data) = self.create_reserved_capacity_with_http_info(body, **kwargs)  # noqa: E501
-            return data
-
-    def create_reserved_capacity_with_http_info(self, body, **kwargs):  # noqa: E501
-        """create_reserved_capacity  # 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_reserved_capacity_with_http_info(body, async_req=True)
-        >>> result = thread.get()
-
-        :param async_req bool
-        :param CreateReservedCapacityRequest body: (required)
-        :return: CreateReservedCapacityResponse
-                 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_reserved_capacity" % 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_reserved_capacity`")  # 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(
-            '/CreateReservedCapacity/2022-01-01/filenas/post/application_json/', 'POST',
-            path_params,
-            query_params,
-            header_params,
-            body=body_params,
-            post_params=form_params,
-            files=local_var_files,
-            response_type='CreateReservedCapacityResponse',  # 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_snapshot(self, body, **kwargs):  # noqa: E501
         """create_snapshot  # noqa: E501
 
@@ -2943,103 +2846,6 @@ def describe_regions_with_http_info(self, body, **kwargs):  # noqa: E501
             _request_timeout=params.get('_request_timeout'),
             collection_formats=collection_formats)
 
-    def describe_reserved_capacitys(self, body, **kwargs):  # noqa: E501
-        """describe_reserved_capacitys  # noqa: E501
-
-        This method makes a synchronous HTTP request by default. To make an
-        asynchronous HTTP request, please pass async_req=True
-        >>> thread = api.describe_reserved_capacitys(body, async_req=True)
-        >>> result = thread.get()
-
-        :param async_req bool
-        :param DescribeReservedCapacitysRequest body: (required)
-        :return: DescribeReservedCapacitysResponse
-                 If the method is called asynchronously,
-                 returns the request thread.
-        """
-        kwargs['_return_http_data_only'] = True
-        if kwargs.get('async_req'):
-            return self.describe_reserved_capacitys_with_http_info(body, **kwargs)  # noqa: E501
-        else:
-            (data) = self.describe_reserved_capacitys_with_http_info(body, **kwargs)  # noqa: E501
-            return data
-
-    def describe_reserved_capacitys_with_http_info(self, body, **kwargs):  # noqa: E501
-        """describe_reserved_capacitys  # noqa: E501
-
-        This method makes a synchronous HTTP request by default. To make an
-        asynchronous HTTP request, please pass async_req=True
-        >>> thread = api.describe_reserved_capacitys_with_http_info(body, async_req=True)
-        >>> result = thread.get()
-
-        :param async_req bool
-        :param DescribeReservedCapacitysRequest body: (required)
-        :return: DescribeReservedCapacitysResponse
-                 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 describe_reserved_capacitys" % 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 `describe_reserved_capacitys`")  # 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(
-            '/DescribeReservedCapacitys/2022-01-01/filenas/post/application_json/', 'POST',
-            path_params,
-            query_params,
-            header_params,
-            body=body_params,
-            post_params=form_params,
-            files=local_var_files,
-            response_type='DescribeReservedCapacitysResponse',  # 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 describe_snapshots(self, body, **kwargs):  # noqa: E501
         """describe_snapshots  # noqa: E501