# coding: utf-8 """ graph No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen) # noqa: E501 OpenAPI spec version: common-version Generated by: https://github.com/swagger-api/swagger-codegen.git """ from __future__ import absolute_import import re # noqa: F401 # python 2 and python 3 compatibility library import six import volcenginesdkcore class GRAPHApi(object): """NOTE: This class is auto generated by the swagger code generator program. Do not edit the class manually. Ref: https://github.com/swagger-api/swagger-codegen """ def __init__(self, api_client=None): if api_client is None: api_client = volcenginesdkcore.ApiClient() self.api_client = api_client def add_tables(self, body, **kwargs): # noqa: E501 """add_tables # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tables(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTablesRequest body: (required) :return: AddTablesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.add_tables_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.add_tables_with_http_info(body, **kwargs) # noqa: E501 return data def add_tables_with_http_info(self, body, **kwargs): # noqa: E501 """add_tables # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tables_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTablesRequest body: (required) :return: AddTablesResponse 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 add_tables" % 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 `add_tables`") # 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( '/AddTables/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='AddTablesResponse', # 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 alter_table(self, body, **kwargs): # noqa: E501 """alter_table # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.alter_table(body, async_req=True) >>> result = thread.get() :param async_req bool :param AlterTableRequest body: (required) :return: AlterTableResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.alter_table_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.alter_table_with_http_info(body, **kwargs) # noqa: E501 return data def alter_table_with_http_info(self, body, **kwargs): # noqa: E501 """alter_table # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.alter_table_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AlterTableRequest body: (required) :return: AlterTableResponse 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 alter_table" % 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 `alter_table`") # 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( '/AlterTable/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='AlterTableResponse', # 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 calc_table_limits(self, body, **kwargs): # noqa: E501 """calc_table_limits # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.calc_table_limits(body, async_req=True) >>> result = thread.get() :param async_req bool :param CalcTableLimitsRequest body: (required) :return: CalcTableLimitsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.calc_table_limits_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.calc_table_limits_with_http_info(body, **kwargs) # noqa: E501 return data def calc_table_limits_with_http_info(self, body, **kwargs): # noqa: E501 """calc_table_limits # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.calc_table_limits_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CalcTableLimitsRequest body: (required) :return: CalcTableLimitsResponse 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 calc_table_limits" % 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 `calc_table_limits`") # 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( '/CalcTableLimits/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CalcTableLimitsResponse', # 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_instance(self, body, **kwargs): # noqa: E501 """create_instance # 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_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_instance_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_instance_with_http_info(body, **kwargs) # noqa: E501 return data def create_instance_with_http_info(self, body, **kwargs): # noqa: E501 """create_instance # 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_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse 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_instance" % 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_instance`") # 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( '/CreateInstance/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateInstanceResponse', # 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 decode_raw_key(self, body, **kwargs): # noqa: E501 """decode_raw_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.decode_raw_key(body, async_req=True) >>> result = thread.get() :param async_req bool :param DecodeRawKeyRequest body: (required) :return: DecodeRawKeyResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.decode_raw_key_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.decode_raw_key_with_http_info(body, **kwargs) # noqa: E501 return data def decode_raw_key_with_http_info(self, body, **kwargs): # noqa: E501 """decode_raw_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.decode_raw_key_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DecodeRawKeyRequest body: (required) :return: DecodeRawKeyResponse 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 decode_raw_key" % 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 `decode_raw_key`") # 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( '/DecodeRawKey/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DecodeRawKeyResponse', # 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_instance(self, body, **kwargs): # noqa: E501 """describe_instance # 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_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceRequest body: (required) :return: DescribeInstanceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_instance_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_instance_with_http_info(body, **kwargs) # noqa: E501 return data def describe_instance_with_http_info(self, body, **kwargs): # noqa: E501 """describe_instance # 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_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceRequest body: (required) :return: DescribeInstanceResponse 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_instance" % 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_instance`") # 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( '/DescribeInstance/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeInstanceResponse', # 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_vegraph_config_in_k8s(self, body, **kwargs): # noqa: E501 """describe_vegraph_config_in_k8s # 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_vegraph_config_in_k8s(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeVegraphConfigInK8sRequest body: (required) :return: DescribeVegraphConfigInK8sResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_vegraph_config_in_k8s_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_vegraph_config_in_k8s_with_http_info(body, **kwargs) # noqa: E501 return data def describe_vegraph_config_in_k8s_with_http_info(self, body, **kwargs): # noqa: E501 """describe_vegraph_config_in_k8s # 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_vegraph_config_in_k8s_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeVegraphConfigInK8sRequest body: (required) :return: DescribeVegraphConfigInK8sResponse 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_vegraph_config_in_k8s" % 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_vegraph_config_in_k8s`") # 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( '/DescribeVegraphConfigInK8s/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeVegraphConfigInK8sResponse', # 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_vegraph_config_in_metamysql(self, body, **kwargs): # noqa: E501 """describe_vegraph_config_in_metamysql # 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_vegraph_config_in_metamysql(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeVegraphConfigInMetamysqlRequest body: (required) :return: DescribeVegraphConfigInMetamysqlResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_vegraph_config_in_metamysql_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_vegraph_config_in_metamysql_with_http_info(body, **kwargs) # noqa: E501 return data def describe_vegraph_config_in_metamysql_with_http_info(self, body, **kwargs): # noqa: E501 """describe_vegraph_config_in_metamysql # 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_vegraph_config_in_metamysql_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeVegraphConfigInMetamysqlRequest body: (required) :return: DescribeVegraphConfigInMetamysqlResponse 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_vegraph_config_in_metamysql" % 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_vegraph_config_in_metamysql`") # 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( '/DescribeVegraphConfigInMetamysql/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeVegraphConfigInMetamysqlResponse', # 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_zones(self, body, **kwargs): # noqa: E501 """describe_zones # 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_zones(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeZonesRequest body: (required) :return: DescribeZonesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.describe_zones_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.describe_zones_with_http_info(body, **kwargs) # noqa: E501 return data def describe_zones_with_http_info(self, body, **kwargs): # noqa: E501 """describe_zones # 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_zones_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeZonesRequest body: (required) :return: DescribeZonesResponse 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_zones" % 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_zones`") # 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( '/DescribeZones/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DescribeZonesResponse', # 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 destroy_instance(self, body, **kwargs): # noqa: E501 """destroy_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.destroy_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param DestroyInstanceRequest body: (required) :return: DestroyInstanceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.destroy_instance_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.destroy_instance_with_http_info(body, **kwargs) # noqa: E501 return data def destroy_instance_with_http_info(self, body, **kwargs): # noqa: E501 """destroy_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.destroy_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DestroyInstanceRequest body: (required) :return: DestroyInstanceResponse 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 destroy_instance" % 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 `destroy_instance`") # 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( '/DestroyInstance/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DestroyInstanceResponse', # 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 execute_metaservice_cli(self, body, **kwargs): # noqa: E501 """execute_metaservice_cli # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.execute_metaservice_cli(body, async_req=True) >>> result = thread.get() :param async_req bool :param ExecuteMetaserviceCliRequest body: (required) :return: ExecuteMetaserviceCliResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.execute_metaservice_cli_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.execute_metaservice_cli_with_http_info(body, **kwargs) # noqa: E501 return data def execute_metaservice_cli_with_http_info(self, body, **kwargs): # noqa: E501 """execute_metaservice_cli # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.execute_metaservice_cli_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ExecuteMetaserviceCliRequest body: (required) :return: ExecuteMetaserviceCliResponse 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 execute_metaservice_cli" % 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 `execute_metaservice_cli`") # 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( '/ExecuteMetaserviceCli/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ExecuteMetaserviceCliResponse', # 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 execute_query(self, body, **kwargs): # noqa: E501 """execute_query # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.execute_query(body, async_req=True) >>> result = thread.get() :param async_req bool :param ExecuteQueryRequest body: (required) :return: ExecuteQueryResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.execute_query_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.execute_query_with_http_info(body, **kwargs) # noqa: E501 return data def execute_query_with_http_info(self, body, **kwargs): # noqa: E501 """execute_query # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.execute_query_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ExecuteQueryRequest body: (required) :return: ExecuteQueryResponse 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 execute_query" % 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 `execute_query`") # 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( '/ExecuteQuery/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ExecuteQueryResponse', # 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 get_add_tables_ticket_options(self, body, **kwargs): # noqa: E501 """get_add_tables_ticket_options # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_add_tables_ticket_options(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetAddTablesTicketOptionsRequest body: (required) :return: GetAddTablesTicketOptionsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_add_tables_ticket_options_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_add_tables_ticket_options_with_http_info(body, **kwargs) # noqa: E501 return data def get_add_tables_ticket_options_with_http_info(self, body, **kwargs): # noqa: E501 """get_add_tables_ticket_options # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_add_tables_ticket_options_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetAddTablesTicketOptionsRequest body: (required) :return: GetAddTablesTicketOptionsResponse 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 get_add_tables_ticket_options" % 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 `get_add_tables_ticket_options`") # 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( '/GetAddTablesTicketOptions/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetAddTablesTicketOptionsResponse', # 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 get_conf_checker(self, body, **kwargs): # noqa: E501 """get_conf_checker # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_conf_checker(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetConfCheckerRequest body: (required) :return: GetConfCheckerResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_conf_checker_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_conf_checker_with_http_info(body, **kwargs) # noqa: E501 return data def get_conf_checker_with_http_info(self, body, **kwargs): # noqa: E501 """get_conf_checker # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_conf_checker_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetConfCheckerRequest body: (required) :return: GetConfCheckerResponse 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 get_conf_checker" % 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 `get_conf_checker`") # 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( '/GetConfChecker/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetConfCheckerResponse', # 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 get_instance_spec_scope(self, body, **kwargs): # noqa: E501 """get_instance_spec_scope # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_instance_spec_scope(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetInstanceSpecScopeRequest body: (required) :return: GetInstanceSpecScopeResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_instance_spec_scope_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_instance_spec_scope_with_http_info(body, **kwargs) # noqa: E501 return data def get_instance_spec_scope_with_http_info(self, body, **kwargs): # noqa: E501 """get_instance_spec_scope # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_instance_spec_scope_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetInstanceSpecScopeRequest body: (required) :return: GetInstanceSpecScopeResponse 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 get_instance_spec_scope" % 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 `get_instance_spec_scope`") # 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( '/GetInstanceSpecScope/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetInstanceSpecScopeResponse', # 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 get_table(self, body, **kwargs): # noqa: E501 """get_table # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableRequest body: (required) :return: GetTableResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_table_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_table_with_http_info(body, **kwargs) # noqa: E501 return data def get_table_with_http_info(self, body, **kwargs): # noqa: E501 """get_table # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableRequest body: (required) :return: GetTableResponse 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 get_table" % 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 `get_table`") # 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( '/GetTable/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTableResponse', # 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 get_table_config(self, body, **kwargs): # noqa: E501 """get_table_config # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_config(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableConfigRequest body: (required) :return: GetTableConfigResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_table_config_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_table_config_with_http_info(body, **kwargs) # noqa: E501 return data def get_table_config_with_http_info(self, body, **kwargs): # noqa: E501 """get_table_config # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_config_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableConfigRequest body: (required) :return: GetTableConfigResponse 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 get_table_config" % 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 `get_table_config`") # 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( '/GetTableConfig/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTableConfigResponse', # 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 get_table_io_qos_options(self, body, **kwargs): # noqa: E501 """get_table_io_qos_options # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_io_qos_options(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableIOQosOptionsRequest body: (required) :return: GetTableIOQosOptionsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_table_io_qos_options_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_table_io_qos_options_with_http_info(body, **kwargs) # noqa: E501 return data def get_table_io_qos_options_with_http_info(self, body, **kwargs): # noqa: E501 """get_table_io_qos_options # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_io_qos_options_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableIOQosOptionsRequest body: (required) :return: GetTableIOQosOptionsResponse 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 get_table_io_qos_options" % 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 `get_table_io_qos_options`") # 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( '/GetTableIOQosOptions/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTableIOQosOptionsResponse', # 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 get_table_limit(self, body, **kwargs): # noqa: E501 """get_table_limit # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_limit(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableLimitRequest body: (required) :return: GetTableLimitResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_table_limit_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_table_limit_with_http_info(body, **kwargs) # noqa: E501 return data def get_table_limit_with_http_info(self, body, **kwargs): # noqa: E501 """get_table_limit # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_limit_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableLimitRequest body: (required) :return: GetTableLimitResponse 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 get_table_limit" % 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 `get_table_limit`") # 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( '/GetTableLimit/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTableLimitResponse', # 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 get_table_quota(self, body, **kwargs): # noqa: E501 """get_table_quota # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_quota(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableQuotaRequest body: (required) :return: GetTableQuotaResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_table_quota_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_table_quota_with_http_info(body, **kwargs) # noqa: E501 return data def get_table_quota_with_http_info(self, body, **kwargs): # noqa: E501 """get_table_quota # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_quota_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableQuotaRequest body: (required) :return: GetTableQuotaResponse 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 get_table_quota" % 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 `get_table_quota`") # 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( '/GetTableQuota/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTableQuotaResponse', # 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 get_table_schema(self, body, **kwargs): # noqa: E501 """get_table_schema # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_schema(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableSchemaRequest body: (required) :return: GetTableSchemaResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_table_schema_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_table_schema_with_http_info(body, **kwargs) # noqa: E501 return data def get_table_schema_with_http_info(self, body, **kwargs): # noqa: E501 """get_table_schema # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_table_schema_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTableSchemaRequest body: (required) :return: GetTableSchemaResponse 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 get_table_schema" % 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 `get_table_schema`") # 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( '/GetTableSchema/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTableSchemaResponse', # 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 get_vegraph_network_resource(self, body, **kwargs): # noqa: E501 """get_vegraph_network_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_vegraph_network_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetVegraphNetworkResourceRequest body: (required) :return: GetVegraphNetworkResourceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_vegraph_network_resource_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_vegraph_network_resource_with_http_info(body, **kwargs) # noqa: E501 return data def get_vegraph_network_resource_with_http_info(self, body, **kwargs): # noqa: E501 """get_vegraph_network_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_vegraph_network_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetVegraphNetworkResourceRequest body: (required) :return: GetVegraphNetworkResourceResponse 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 get_vegraph_network_resource" % 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 `get_vegraph_network_resource`") # 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( '/GetVegraphNetworkResource/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetVegraphNetworkResourceResponse', # 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 get_vegraph_read_and_write_status(self, body, **kwargs): # noqa: E501 """get_vegraph_read_and_write_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_vegraph_read_and_write_status(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetVegraphReadAndWriteStatusRequest body: (required) :return: GetVegraphReadAndWriteStatusResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_vegraph_read_and_write_status_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_vegraph_read_and_write_status_with_http_info(body, **kwargs) # noqa: E501 return data def get_vegraph_read_and_write_status_with_http_info(self, body, **kwargs): # noqa: E501 """get_vegraph_read_and_write_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_vegraph_read_and_write_status_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetVegraphReadAndWriteStatusRequest body: (required) :return: GetVegraphReadAndWriteStatusResponse 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 get_vegraph_read_and_write_status" % 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 `get_vegraph_read_and_write_status`") # 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( '/GetVegraphReadAndWriteStatus/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetVegraphReadAndWriteStatusResponse', # 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 get_version_set_and_components_info(self, body, **kwargs): # noqa: E501 """get_version_set_and_components_info # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_version_set_and_components_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetVersionSetAndComponentsInfoRequest body: (required) :return: GetVersionSetAndComponentsInfoResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_version_set_and_components_info_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_version_set_and_components_info_with_http_info(body, **kwargs) # noqa: E501 return data def get_version_set_and_components_info_with_http_info(self, body, **kwargs): # noqa: E501 """get_version_set_and_components_info # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_version_set_and_components_info_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetVersionSetAndComponentsInfoRequest body: (required) :return: GetVersionSetAndComponentsInfoResponse 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 get_version_set_and_components_info" % 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 `get_version_set_and_components_info`") # 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( '/GetVersionSetAndComponentsInfo/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetVersionSetAndComponentsInfoResponse', # 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 graphrag_add_knowledge_base(self, body, **kwargs): # noqa: E501 """graphrag_add_knowledge_base # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.graphrag_add_knowledge_base(body, async_req=True) >>> result = thread.get() :param async_req bool :param GraphragAddKnowledgeBaseRequest body: (required) :return: GraphragAddKnowledgeBaseResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.graphrag_add_knowledge_base_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.graphrag_add_knowledge_base_with_http_info(body, **kwargs) # noqa: E501 return data def graphrag_add_knowledge_base_with_http_info(self, body, **kwargs): # noqa: E501 """graphrag_add_knowledge_base # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.graphrag_add_knowledge_base_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GraphragAddKnowledgeBaseRequest body: (required) :return: GraphragAddKnowledgeBaseResponse 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 graphrag_add_knowledge_base" % 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 `graphrag_add_knowledge_base`") # 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( '/GraphragAddKnowledgeBase/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GraphragAddKnowledgeBaseResponse', # 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 list_all_tables(self, body, **kwargs): # noqa: E501 """list_all_tables # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_all_tables(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAllTablesRequest body: (required) :return: ListAllTablesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_all_tables_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_all_tables_with_http_info(body, **kwargs) # noqa: E501 return data def list_all_tables_with_http_info(self, body, **kwargs): # noqa: E501 """list_all_tables # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_all_tables_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListAllTablesRequest body: (required) :return: ListAllTablesResponse 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 list_all_tables" % 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 `list_all_tables`") # 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( '/ListAllTables/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListAllTablesResponse', # 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 list_cluster_tables(self, body, **kwargs): # noqa: E501 """list_cluster_tables # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_cluster_tables(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListClusterTablesRequest body: (required) :return: ListClusterTablesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_cluster_tables_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_cluster_tables_with_http_info(body, **kwargs) # noqa: E501 return data def list_cluster_tables_with_http_info(self, body, **kwargs): # noqa: E501 """list_cluster_tables # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_cluster_tables_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListClusterTablesRequest body: (required) :return: ListClusterTablesResponse 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 list_cluster_tables" % 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 `list_cluster_tables`") # 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( '/ListClusterTables/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListClusterTablesResponse', # 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 list_graph_rag_service(self, body, **kwargs): # noqa: E501 """list_graph_rag_service # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_graph_rag_service(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListGraphRagServiceRequest body: (required) :return: ListGraphRagServiceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_graph_rag_service_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_graph_rag_service_with_http_info(body, **kwargs) # noqa: E501 return data def list_graph_rag_service_with_http_info(self, body, **kwargs): # noqa: E501 """list_graph_rag_service # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_graph_rag_service_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListGraphRagServiceRequest body: (required) :return: ListGraphRagServiceResponse 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 list_graph_rag_service" % 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 `list_graph_rag_service`") # 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( '/ListGraphRagService/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListGraphRagServiceResponse', # 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 list_instance(self, body, **kwargs): # noqa: E501 """list_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListInstanceRequest body: (required) :return: ListInstanceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_instance_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_instance_with_http_info(body, **kwargs) # noqa: E501 return data def list_instance_with_http_info(self, body, **kwargs): # noqa: E501 """list_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListInstanceRequest body: (required) :return: ListInstanceResponse 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 list_instance" % 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 `list_instance`") # 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( '/ListInstance/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListInstanceResponse', # 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 list_tablet_server(self, body, **kwargs): # noqa: E501 """list_tablet_server # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_tablet_server(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListTabletServerRequest body: (required) :return: ListTabletServerResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_tablet_server_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_tablet_server_with_http_info(body, **kwargs) # noqa: E501 return data def list_tablet_server_with_http_info(self, body, **kwargs): # noqa: E501 """list_tablet_server # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_tablet_server_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListTabletServerRequest body: (required) :return: ListTabletServerResponse 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 list_tablet_server" % 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 `list_tablet_server`") # 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( '/ListTabletServer/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListTabletServerResponse', # 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 list_tablet_task(self, body, **kwargs): # noqa: E501 """list_tablet_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.list_tablet_task(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListTabletTaskRequest body: (required) :return: ListTabletTaskResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_tablet_task_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_tablet_task_with_http_info(body, **kwargs) # noqa: E501 return data def list_tablet_task_with_http_info(self, body, **kwargs): # noqa: E501 """list_tablet_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.list_tablet_task_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListTabletTaskRequest body: (required) :return: ListTabletTaskResponse 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 list_tablet_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 `list_tablet_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( '/ListTabletTask/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListTabletTaskResponse', # 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 list_tablets(self, body, **kwargs): # noqa: E501 """list_tablets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_tablets(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListTabletsRequest body: (required) :return: ListTabletsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_tablets_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_tablets_with_http_info(body, **kwargs) # noqa: E501 return data def list_tablets_with_http_info(self, body, **kwargs): # noqa: E501 """list_tablets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.list_tablets_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListTabletsRequest body: (required) :return: ListTabletsResponse 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 list_tablets" % 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 `list_tablets`") # 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( '/ListTablets/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListTabletsResponse', # 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 migrate_tablet_replica(self, body, **kwargs): # noqa: E501 """migrate_tablet_replica # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.migrate_tablet_replica(body, async_req=True) >>> result = thread.get() :param async_req bool :param MigrateTabletReplicaRequest body: (required) :return: MigrateTabletReplicaResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.migrate_tablet_replica_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.migrate_tablet_replica_with_http_info(body, **kwargs) # noqa: E501 return data def migrate_tablet_replica_with_http_info(self, body, **kwargs): # noqa: E501 """migrate_tablet_replica # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.migrate_tablet_replica_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param MigrateTabletReplicaRequest body: (required) :return: MigrateTabletReplicaResponse 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 migrate_tablet_replica" % 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 `migrate_tablet_replica`") # 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( '/MigrateTabletReplica/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='MigrateTabletReplicaResponse', # 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 modify_db_instance_deletion_protection_policy(self, body, **kwargs): # noqa: E501 """modify_db_instance_deletion_protection_policy # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_db_instance_deletion_protection_policy(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyDBInstanceDeletionProtectionPolicyRequest body: (required) :return: ModifyDBInstanceDeletionProtectionPolicyResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_db_instance_deletion_protection_policy_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_db_instance_deletion_protection_policy_with_http_info(body, **kwargs) # noqa: E501 return data def modify_db_instance_deletion_protection_policy_with_http_info(self, body, **kwargs): # noqa: E501 """modify_db_instance_deletion_protection_policy # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_db_instance_deletion_protection_policy_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyDBInstanceDeletionProtectionPolicyRequest body: (required) :return: ModifyDBInstanceDeletionProtectionPolicyResponse 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 modify_db_instance_deletion_protection_policy" % 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 `modify_db_instance_deletion_protection_policy`") # 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( '/ModifyDBInstanceDeletionProtectionPolicy/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifyDBInstanceDeletionProtectionPolicyResponse', # 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 modify_schema(self, body, **kwargs): # noqa: E501 """modify_schema # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_schema(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifySchemaRequest body: (required) :return: ModifySchemaResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.modify_schema_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.modify_schema_with_http_info(body, **kwargs) # noqa: E501 return data def modify_schema_with_http_info(self, body, **kwargs): # noqa: E501 """modify_schema # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_schema_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifySchemaRequest body: (required) :return: ModifySchemaResponse 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 modify_schema" % 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 `modify_schema`") # 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( '/ModifySchema/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ModifySchemaResponse', # 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 set_vegraph_read_and_write_status(self, body, **kwargs): # noqa: E501 """set_vegraph_read_and_write_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.set_vegraph_read_and_write_status(body, async_req=True) >>> result = thread.get() :param async_req bool :param SetVegraphReadAndWriteStatusRequest body: (required) :return: SetVegraphReadAndWriteStatusResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.set_vegraph_read_and_write_status_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.set_vegraph_read_and_write_status_with_http_info(body, **kwargs) # noqa: E501 return data def set_vegraph_read_and_write_status_with_http_info(self, body, **kwargs): # noqa: E501 """set_vegraph_read_and_write_status # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.set_vegraph_read_and_write_status_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SetVegraphReadAndWriteStatusRequest body: (required) :return: SetVegraphReadAndWriteStatusResponse 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 set_vegraph_read_and_write_status" % 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 `set_vegraph_read_and_write_status`") # 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( '/SetVegraphReadAndWriteStatus/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SetVegraphReadAndWriteStatusResponse', # 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 truncate_table(self, body, **kwargs): # noqa: E501 """truncate_table # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.truncate_table(body, async_req=True) >>> result = thread.get() :param async_req bool :param TruncateTableRequest body: (required) :return: TruncateTableResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.truncate_table_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.truncate_table_with_http_info(body, **kwargs) # noqa: E501 return data def truncate_table_with_http_info(self, body, **kwargs): # noqa: E501 """truncate_table # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.truncate_table_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param TruncateTableRequest body: (required) :return: TruncateTableResponse 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 truncate_table" % 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 `truncate_table`") # 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( '/TruncateTable/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='TruncateTableResponse', # 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 update_conf_checker(self, body, **kwargs): # noqa: E501 """update_conf_checker # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_conf_checker(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateConfCheckerRequest body: (required) :return: UpdateConfCheckerResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_conf_checker_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_conf_checker_with_http_info(body, **kwargs) # noqa: E501 return data def update_conf_checker_with_http_info(self, body, **kwargs): # noqa: E501 """update_conf_checker # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_conf_checker_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateConfCheckerRequest body: (required) :return: UpdateConfCheckerResponse 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 update_conf_checker" % 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 `update_conf_checker`") # 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( '/UpdateConfChecker/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateConfCheckerResponse', # 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 update_gremlin_keyword_black_list_conf(self, body, **kwargs): # noqa: E501 """update_gremlin_keyword_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_gremlin_keyword_black_list_conf(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateGremlinKeywordBlackListConfRequest body: (required) :return: UpdateGremlinKeywordBlackListConfResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_gremlin_keyword_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_gremlin_keyword_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 return data def update_gremlin_keyword_black_list_conf_with_http_info(self, body, **kwargs): # noqa: E501 """update_gremlin_keyword_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_gremlin_keyword_black_list_conf_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateGremlinKeywordBlackListConfRequest body: (required) :return: UpdateGremlinKeywordBlackListConfResponse 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 update_gremlin_keyword_black_list_conf" % 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 `update_gremlin_keyword_black_list_conf`") # 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( '/UpdateGremlinKeywordBlackListConf/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateGremlinKeywordBlackListConfResponse', # 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 update_key_black_list_conf(self, body, **kwargs): # noqa: E501 """update_key_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_key_black_list_conf(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateKeyBlackListConfRequest body: (required) :return: UpdateKeyBlackListConfResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_key_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_key_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 return data def update_key_black_list_conf_with_http_info(self, body, **kwargs): # noqa: E501 """update_key_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_key_black_list_conf_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateKeyBlackListConfRequest body: (required) :return: UpdateKeyBlackListConfResponse 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 update_key_black_list_conf" % 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 `update_key_black_list_conf`") # 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( '/UpdateKeyBlackListConf/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateKeyBlackListConfResponse', # 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 update_tablet_read_black_list_conf(self, body, **kwargs): # noqa: E501 """update_tablet_read_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_tablet_read_black_list_conf(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateTabletReadBlackListConfRequest body: (required) :return: UpdateTabletReadBlackListConfResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_tablet_read_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_tablet_read_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 return data def update_tablet_read_black_list_conf_with_http_info(self, body, **kwargs): # noqa: E501 """update_tablet_read_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_tablet_read_black_list_conf_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateTabletReadBlackListConfRequest body: (required) :return: UpdateTabletReadBlackListConfResponse 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 update_tablet_read_black_list_conf" % 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 `update_tablet_read_black_list_conf`") # 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( '/UpdateTabletReadBlackListConf/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateTabletReadBlackListConfResponse', # 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 update_tablet_write_black_list_conf(self, body, **kwargs): # noqa: E501 """update_tablet_write_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_tablet_write_black_list_conf(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateTabletWriteBlackListConfRequest body: (required) :return: UpdateTabletWriteBlackListConfResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_tablet_write_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_tablet_write_black_list_conf_with_http_info(body, **kwargs) # noqa: E501 return data def update_tablet_write_black_list_conf_with_http_info(self, body, **kwargs): # noqa: E501 """update_tablet_write_black_list_conf # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.update_tablet_write_black_list_conf_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateTabletWriteBlackListConfRequest body: (required) :return: UpdateTabletWriteBlackListConfResponse 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 update_tablet_write_black_list_conf" % 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 `update_tablet_write_black_list_conf`") # 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( '/UpdateTabletWriteBlackListConf/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateTabletWriteBlackListConfResponse', # 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 validate_conf_checker(self, body, **kwargs): # noqa: E501 """validate_conf_checker # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.validate_conf_checker(body, async_req=True) >>> result = thread.get() :param async_req bool :param ValidateConfCheckerRequest body: (required) :return: ValidateConfCheckerResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.validate_conf_checker_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.validate_conf_checker_with_http_info(body, **kwargs) # noqa: E501 return data def validate_conf_checker_with_http_info(self, body, **kwargs): # noqa: E501 """validate_conf_checker # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.validate_conf_checker_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ValidateConfCheckerRequest body: (required) :return: ValidateConfCheckerResponse 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 validate_conf_checker" % 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 `validate_conf_checker`") # 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( '/ValidateConfChecker/2018-01-01/graph/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ValidateConfCheckerResponse', # 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)