# coding: utf-8 """ aiotvideo 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 AIOTVIDEOApi(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 cancel_stream_template(self, body, **kwargs): # noqa: E501 """cancel_stream_template # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.cancel_stream_template(body, async_req=True) >>> result = thread.get() :param async_req bool :param CancelStreamTemplateRequest body: (required) :return: CancelStreamTemplateResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.cancel_stream_template_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.cancel_stream_template_with_http_info(body, **kwargs) # noqa: E501 return data def cancel_stream_template_with_http_info(self, body, **kwargs): # noqa: E501 """cancel_stream_template # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.cancel_stream_template_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CancelStreamTemplateRequest body: (required) :return: CancelStreamTemplateResponse 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 cancel_stream_template" % 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 `cancel_stream_template`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/CancelStreamTemplate/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CancelStreamTemplateResponse', # 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_device(self, body, **kwargs): # noqa: E501 """create_device # 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_device(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateDeviceRequest body: (required) :return: CreateDeviceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_device_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_device_with_http_info(body, **kwargs) # noqa: E501 return data def create_device_with_http_info(self, body, **kwargs): # noqa: E501 """create_device # 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_device_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateDeviceRequest body: (required) :return: CreateDeviceResponse 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_device" % 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_device`") # 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( '/CreateDevice/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateDeviceResponse', # 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_record_plan(self, body, **kwargs): # noqa: E501 """create_record_plan # 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_record_plan(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateRecordPlanRequest body: (required) :return: CreateRecordPlanResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_record_plan_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_record_plan_with_http_info(body, **kwargs) # noqa: E501 return data def create_record_plan_with_http_info(self, body, **kwargs): # noqa: E501 """create_record_plan # 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_record_plan_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateRecordPlanRequest body: (required) :return: CreateRecordPlanResponse 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_record_plan" % 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_record_plan`") # 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( '/CreateRecordPlan/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateRecordPlanResponse', # 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_stream(self, body, **kwargs): # noqa: E501 """create_stream # 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_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateStreamRequest body: (required) :return: CreateStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.create_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.create_stream_with_http_info(body, **kwargs) # noqa: E501 return data def create_stream_with_http_info(self, body, **kwargs): # noqa: E501 """create_stream # 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_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateStreamRequest body: (required) :return: CreateStreamResponse 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_stream" % 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_stream`") # 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( '/CreateStream/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='CreateStreamResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_device(self, body, **kwargs): # noqa: E501 """delete_device # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_device(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteDeviceRequest body: (required) :return: DeleteDeviceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_device_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_device_with_http_info(body, **kwargs) # noqa: E501 return data def delete_device_with_http_info(self, body, **kwargs): # noqa: E501 """delete_device # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_device_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteDeviceRequest body: (required) :return: DeleteDeviceResponse 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 delete_device" % 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 `delete_device`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteDevice/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteDeviceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_record_plan(self, body, **kwargs): # noqa: E501 """delete_record_plan # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_record_plan(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteRecordPlanRequest body: (required) :return: DeleteRecordPlanResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_record_plan_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_record_plan_with_http_info(body, **kwargs) # noqa: E501 return data def delete_record_plan_with_http_info(self, body, **kwargs): # noqa: E501 """delete_record_plan # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_record_plan_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteRecordPlanRequest body: (required) :return: DeleteRecordPlanResponse 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 delete_record_plan" % 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 `delete_record_plan`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteRecordPlan/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteRecordPlanResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_space(self, body, **kwargs): # noqa: E501 """delete_space # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_space(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteSpaceRequest body: (required) :return: DeleteSpaceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_space_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_space_with_http_info(body, **kwargs) # noqa: E501 return data def delete_space_with_http_info(self, body, **kwargs): # noqa: E501 """delete_space # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_space_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteSpaceRequest body: (required) :return: DeleteSpaceResponse 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 delete_space" % 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 `delete_space`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteSpace/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteSpaceResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_stream(self, body, **kwargs): # noqa: E501 """delete_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteStreamRequest body: (required) :return: DeleteStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_stream_with_http_info(body, **kwargs) # noqa: E501 return data def delete_stream_with_http_info(self, body, **kwargs): # noqa: E501 """delete_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteStreamRequest body: (required) :return: DeleteStreamResponse 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 delete_stream" % 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 `delete_stream`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteStream/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteStreamResponse', # noqa: E501 auth_settings=auth_settings, async_req=params.get('async_req'), _return_http_data_only=params.get('_return_http_data_only'), _preload_content=params.get('_preload_content', True), _request_timeout=params.get('_request_timeout'), collection_formats=collection_formats) def delete_stream_record(self, body, **kwargs): # noqa: E501 """delete_stream_record # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_stream_record(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteStreamRecordRequest body: (required) :return: DeleteStreamRecordResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.delete_stream_record_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.delete_stream_record_with_http_info(body, **kwargs) # noqa: E501 return data def delete_stream_record_with_http_info(self, body, **kwargs): # noqa: E501 """delete_stream_record # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_stream_record_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteStreamRecordRequest body: (required) :return: DeleteStreamRecordResponse 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 delete_stream_record" % 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 `delete_stream_record`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/DeleteStreamRecord/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='DeleteStreamRecordResponse', # 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 fresh_device(self, body, **kwargs): # noqa: E501 """fresh_device # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.fresh_device(body, async_req=True) >>> result = thread.get() :param async_req bool :param FreshDeviceRequest body: (required) :return: FreshDeviceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.fresh_device_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.fresh_device_with_http_info(body, **kwargs) # noqa: E501 return data def fresh_device_with_http_info(self, body, **kwargs): # noqa: E501 """fresh_device # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.fresh_device_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param FreshDeviceRequest body: (required) :return: FreshDeviceResponse 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 fresh_device" % 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 `fresh_device`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/FreshDevice/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='FreshDeviceResponse', # 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 gen_sip_id(self, body, **kwargs): # noqa: E501 """gen_sip_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.gen_sip_id(body, async_req=True) >>> result = thread.get() :param async_req bool :param GenSipIDRequest body: (required) :return: GenSipIDResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.gen_sip_id_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.gen_sip_id_with_http_info(body, **kwargs) # noqa: E501 return data def gen_sip_id_with_http_info(self, body, **kwargs): # noqa: E501 """gen_sip_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.gen_sip_id_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GenSipIDRequest body: (required) :return: GenSipIDResponse 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 gen_sip_id" % 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 `gen_sip_id`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GenSipID/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GenSipIDResponse', # 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_data_project_with_bind_width_and_flow(self, body, **kwargs): # noqa: E501 """get_data_project_with_bind_width_and_flow # 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_data_project_with_bind_width_and_flow(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDataProjectWithBindWidthAndFlowRequest body: (required) :return: GetDataProjectWithBindWidthAndFlowResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_data_project_with_bind_width_and_flow_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_data_project_with_bind_width_and_flow_with_http_info(body, **kwargs) # noqa: E501 return data def get_data_project_with_bind_width_and_flow_with_http_info(self, body, **kwargs): # noqa: E501 """get_data_project_with_bind_width_and_flow # 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_data_project_with_bind_width_and_flow_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDataProjectWithBindWidthAndFlowRequest body: (required) :return: GetDataProjectWithBindWidthAndFlowResponse 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_data_project_with_bind_width_and_flow" % 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_data_project_with_bind_width_and_flow`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetDataProjectWithBindWidthAndFlow/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetDataProjectWithBindWidthAndFlowResponse', # 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_device(self, body, **kwargs): # noqa: E501 """get_device # 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_device(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDeviceRequest body: (required) :return: GetDeviceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_device_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_device_with_http_info(body, **kwargs) # noqa: E501 return data def get_device_with_http_info(self, body, **kwargs): # noqa: E501 """get_device # 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_device_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDeviceRequest body: (required) :return: GetDeviceResponse 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_device" % 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_device`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetDevice/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetDeviceResponse', # 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_device_channels_v2(self, body, **kwargs): # noqa: E501 """get_device_channels_v2 # 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_device_channels_v2(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDeviceChannelsV2Request body: (required) :return: GetDeviceChannelsV2Response If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_device_channels_v2_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_device_channels_v2_with_http_info(body, **kwargs) # noqa: E501 return data def get_device_channels_v2_with_http_info(self, body, **kwargs): # noqa: E501 """get_device_channels_v2 # 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_device_channels_v2_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetDeviceChannelsV2Request body: (required) :return: GetDeviceChannelsV2Response 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_device_channels_v2" % 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_device_channels_v2`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetDeviceChannelsV2/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetDeviceChannelsV2Response', # 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_local_download(self, body, **kwargs): # noqa: E501 """get_local_download # 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_local_download(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetLocalDownloadRequest body: (required) :return: GetLocalDownloadResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_local_download_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_local_download_with_http_info(body, **kwargs) # noqa: E501 return data def get_local_download_with_http_info(self, body, **kwargs): # noqa: E501 """get_local_download # 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_local_download_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetLocalDownloadRequest body: (required) :return: GetLocalDownloadResponse 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_local_download" % 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_local_download`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetLocalDownload/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetLocalDownloadResponse', # 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_push_stream_cnt(self, body, **kwargs): # noqa: E501 """get_push_stream_cnt # 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_push_stream_cnt(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetPushStreamCntRequest body: (required) :return: GetPushStreamCntResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_push_stream_cnt_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_push_stream_cnt_with_http_info(body, **kwargs) # noqa: E501 return data def get_push_stream_cnt_with_http_info(self, body, **kwargs): # noqa: E501 """get_push_stream_cnt # 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_push_stream_cnt_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetPushStreamCntRequest body: (required) :return: GetPushStreamCntResponse 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_push_stream_cnt" % 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_push_stream_cnt`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetPushStreamCnt/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetPushStreamCntResponse', # 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_record_plan(self, body, **kwargs): # noqa: E501 """get_record_plan # 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_record_plan(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetRecordPlanRequest body: (required) :return: GetRecordPlanResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_record_plan_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_record_plan_with_http_info(body, **kwargs) # noqa: E501 return data def get_record_plan_with_http_info(self, body, **kwargs): # noqa: E501 """get_record_plan # 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_record_plan_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetRecordPlanRequest body: (required) :return: GetRecordPlanResponse 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_record_plan" % 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_record_plan`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetRecordPlan/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetRecordPlanResponse', # 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_space(self, body, **kwargs): # noqa: E501 """get_space # 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_space(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetSpaceRequest body: (required) :return: GetSpaceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_space_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_space_with_http_info(body, **kwargs) # noqa: E501 return data def get_space_with_http_info(self, body, **kwargs): # noqa: E501 """get_space # 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_space_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetSpaceRequest body: (required) :return: GetSpaceResponse 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_space" % 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_space`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetSpace/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetSpaceResponse', # 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_stream(self, body, **kwargs): # noqa: E501 """get_stream # 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_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetStreamRequest body: (required) :return: GetStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_stream_with_http_info(body, **kwargs) # noqa: E501 return data def get_stream_with_http_info(self, body, **kwargs): # noqa: E501 """get_stream # 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_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetStreamRequest body: (required) :return: GetStreamResponse 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_stream" % 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_stream`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetStream/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetStreamResponse', # 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_stream_data(self, body, **kwargs): # noqa: E501 """get_stream_data # 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_stream_data(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetStreamDataRequest body: (required) :return: GetStreamDataResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_stream_data_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_stream_data_with_http_info(body, **kwargs) # noqa: E501 return data def get_stream_data_with_http_info(self, body, **kwargs): # noqa: E501 """get_stream_data # 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_stream_data_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetStreamDataRequest body: (required) :return: GetStreamDataResponse 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_stream_data" % 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_stream_data`") # 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( '/GetStreamData/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetStreamDataResponse', # 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_stream_record(self, body, **kwargs): # noqa: E501 """get_stream_record # 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_stream_record(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetStreamRecordRequest body: (required) :return: GetStreamRecordResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_stream_record_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_stream_record_with_http_info(body, **kwargs) # noqa: E501 return data def get_stream_record_with_http_info(self, body, **kwargs): # noqa: E501 """get_stream_record # 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_stream_record_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetStreamRecordRequest body: (required) :return: GetStreamRecordResponse 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_stream_record" % 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_stream_record`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetStreamRecord/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetStreamRecordResponse', # 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_total_data(self, body, **kwargs): # noqa: E501 """get_total_data # 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_total_data(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTotalDataRequest body: (required) :return: GetTotalDataResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.get_total_data_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.get_total_data_with_http_info(body, **kwargs) # noqa: E501 return data def get_total_data_with_http_info(self, body, **kwargs): # noqa: E501 """get_total_data # 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_total_data_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetTotalDataRequest body: (required) :return: GetTotalDataResponse 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_total_data" % 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_total_data`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/GetTotalData/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='GetTotalDataResponse', # 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_devices(self, body, **kwargs): # noqa: E501 """list_devices # 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_devices(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListDevicesRequest body: (required) :return: ListDevicesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_devices_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_devices_with_http_info(body, **kwargs) # noqa: E501 return data def list_devices_with_http_info(self, body, **kwargs): # noqa: E501 """list_devices # 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_devices_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListDevicesRequest body: (required) :return: ListDevicesResponse 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_devices" % 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_devices`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ListDevices/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListDevicesResponse', # 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_record_plan_channels(self, body, **kwargs): # noqa: E501 """list_record_plan_channels # 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_record_plan_channels(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListRecordPlanChannelsRequest body: (required) :return: ListRecordPlanChannelsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_record_plan_channels_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_record_plan_channels_with_http_info(body, **kwargs) # noqa: E501 return data def list_record_plan_channels_with_http_info(self, body, **kwargs): # noqa: E501 """list_record_plan_channels # 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_record_plan_channels_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListRecordPlanChannelsRequest body: (required) :return: ListRecordPlanChannelsResponse 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_record_plan_channels" % 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_record_plan_channels`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ListRecordPlanChannels/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListRecordPlanChannelsResponse', # 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_record_plans(self, body, **kwargs): # noqa: E501 """list_record_plans # 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_record_plans(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListRecordPlansRequest body: (required) :return: ListRecordPlansResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_record_plans_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_record_plans_with_http_info(body, **kwargs) # noqa: E501 return data def list_record_plans_with_http_info(self, body, **kwargs): # noqa: E501 """list_record_plans # 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_record_plans_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListRecordPlansRequest body: (required) :return: ListRecordPlansResponse 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_record_plans" % 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_record_plans`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ListRecordPlans/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListRecordPlansResponse', # 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_spaces(self, body, **kwargs): # noqa: E501 """list_spaces # 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_spaces(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListSpacesRequest body: (required) :return: ListSpacesResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_spaces_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_spaces_with_http_info(body, **kwargs) # noqa: E501 return data def list_spaces_with_http_info(self, body, **kwargs): # noqa: E501 """list_spaces # 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_spaces_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListSpacesRequest body: (required) :return: ListSpacesResponse 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_spaces" % 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_spaces`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ListSpaces/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListSpacesResponse', # 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_streams(self, body, **kwargs): # noqa: E501 """list_streams # 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_streams(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListStreamsRequest body: (required) :return: ListStreamsResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.list_streams_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.list_streams_with_http_info(body, **kwargs) # noqa: E501 return data def list_streams_with_http_info(self, body, **kwargs): # noqa: E501 """list_streams # 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_streams_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ListStreamsRequest body: (required) :return: ListStreamsResponse 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_streams" % 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_streams`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/ListStreams/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='ListStreamsResponse', # 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_stream_template(self, body, **kwargs): # noqa: E501 """set_stream_template # 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_stream_template(body, async_req=True) >>> result = thread.get() :param async_req bool :param SetStreamTemplateRequest body: (required) :return: SetStreamTemplateResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.set_stream_template_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.set_stream_template_with_http_info(body, **kwargs) # noqa: E501 return data def set_stream_template_with_http_info(self, body, **kwargs): # noqa: E501 """set_stream_template # 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_stream_template_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param SetStreamTemplateRequest body: (required) :return: SetStreamTemplateResponse 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_stream_template" % 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_stream_template`") # 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( '/SetStreamTemplate/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='SetStreamTemplateResponse', # 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 start_stream(self, body, **kwargs): # noqa: E501 """start_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartStreamRequest body: (required) :return: StartStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.start_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.start_stream_with_http_info(body, **kwargs) # noqa: E501 return data def start_stream_with_http_info(self, body, **kwargs): # noqa: E501 """start_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartStreamRequest body: (required) :return: StartStreamResponse 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 start_stream" % 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 `start_stream`") # 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( '/StartStream/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StartStreamResponse', # 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 start_voice_talk(self, body, **kwargs): # noqa: E501 """start_voice_talk # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_voice_talk(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartVoiceTalkRequest body: (required) :return: StartVoiceTalkResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.start_voice_talk_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.start_voice_talk_with_http_info(body, **kwargs) # noqa: E501 return data def start_voice_talk_with_http_info(self, body, **kwargs): # noqa: E501 """start_voice_talk # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.start_voice_talk_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StartVoiceTalkRequest body: (required) :return: StartVoiceTalkResponse 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 start_voice_talk" % 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 `start_voice_talk`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StartVoiceTalk/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StartVoiceTalkResponse', # 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 stat_stream(self, body, **kwargs): # noqa: E501 """stat_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stat_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param StatStreamRequest body: (required) :return: StatStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stat_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stat_stream_with_http_info(body, **kwargs) # noqa: E501 return data def stat_stream_with_http_info(self, body, **kwargs): # noqa: E501 """stat_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stat_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StatStreamRequest body: (required) :return: StatStreamResponse 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 stat_stream" % 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 `stat_stream`") # 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( '/StatStream/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StatStreamResponse', # 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 stop_stream(self, body, **kwargs): # noqa: E501 """stop_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopStreamRequest body: (required) :return: StopStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stop_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stop_stream_with_http_info(body, **kwargs) # noqa: E501 return data def stop_stream_with_http_info(self, body, **kwargs): # noqa: E501 """stop_stream # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopStreamRequest body: (required) :return: StopStreamResponse 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 stop_stream" % 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 `stop_stream`") # 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( '/StopStream/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StopStreamResponse', # 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 stop_voice_talk(self, body, **kwargs): # noqa: E501 """stop_voice_talk # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_voice_talk(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopVoiceTalkRequest body: (required) :return: StopVoiceTalkResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stop_voice_talk_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stop_voice_talk_with_http_info(body, **kwargs) # noqa: E501 return data def stop_voice_talk_with_http_info(self, body, **kwargs): # noqa: E501 """stop_voice_talk # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stop_voice_talk_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StopVoiceTalkRequest body: (required) :return: StopVoiceTalkResponse 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 stop_voice_talk" % 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 `stop_voice_talk`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StopVoiceTalk/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StopVoiceTalkResponse', # 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 stream_start_record(self, body, **kwargs): # noqa: E501 """stream_start_record # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stream_start_record(body, async_req=True) >>> result = thread.get() :param async_req bool :param StreamStartRecordRequest body: (required) :return: StreamStartRecordResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stream_start_record_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stream_start_record_with_http_info(body, **kwargs) # noqa: E501 return data def stream_start_record_with_http_info(self, body, **kwargs): # noqa: E501 """stream_start_record # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stream_start_record_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StreamStartRecordRequest body: (required) :return: StreamStartRecordResponse 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 stream_start_record" % 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 `stream_start_record`") # 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( '/StreamStartRecord/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StreamStartRecordResponse', # 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 stream_stop_record(self, body, **kwargs): # noqa: E501 """stream_stop_record # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stream_stop_record(body, async_req=True) >>> result = thread.get() :param async_req bool :param StreamStopRecordRequest body: (required) :return: StreamStopRecordResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.stream_stop_record_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.stream_stop_record_with_http_info(body, **kwargs) # noqa: E501 return data def stream_stop_record_with_http_info(self, body, **kwargs): # noqa: E501 """stream_stop_record # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.stream_stop_record_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param StreamStopRecordRequest body: (required) :return: StreamStopRecordResponse 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 stream_stop_record" % 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 `stream_stop_record`") # 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 ['text/plain']) # noqa: E501 # Authentication setting auth_settings = ['volcengineSign'] # noqa: E501 return self.api_client.call_api( '/StreamStopRecord/2021-01-01/aiotvideo/get/text_plain/', 'GET', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='StreamStopRecordResponse', # 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_device(self, body, **kwargs): # noqa: E501 """update_device # 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_device(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateDeviceRequest body: (required) :return: UpdateDeviceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_device_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_device_with_http_info(body, **kwargs) # noqa: E501 return data def update_device_with_http_info(self, body, **kwargs): # noqa: E501 """update_device # 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_device_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateDeviceRequest body: (required) :return: UpdateDeviceResponse 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_device" % 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_device`") # 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( '/UpdateDevice/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateDeviceResponse', # 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_record_plan(self, body, **kwargs): # noqa: E501 """update_record_plan # 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_record_plan(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateRecordPlanRequest body: (required) :return: UpdateRecordPlanResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_record_plan_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_record_plan_with_http_info(body, **kwargs) # noqa: E501 return data def update_record_plan_with_http_info(self, body, **kwargs): # noqa: E501 """update_record_plan # 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_record_plan_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateRecordPlanRequest body: (required) :return: UpdateRecordPlanResponse 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_record_plan" % 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_record_plan`") # 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( '/UpdateRecordPlan/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateRecordPlanResponse', # 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_space(self, body, **kwargs): # noqa: E501 """update_space # 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_space(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateSpaceRequest body: (required) :return: UpdateSpaceResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_space_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_space_with_http_info(body, **kwargs) # noqa: E501 return data def update_space_with_http_info(self, body, **kwargs): # noqa: E501 """update_space # 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_space_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateSpaceRequest body: (required) :return: UpdateSpaceResponse 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_space" % 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_space`") # 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( '/UpdateSpace/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateSpaceResponse', # 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_stream(self, body, **kwargs): # noqa: E501 """update_stream # 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_stream(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateStreamRequest body: (required) :return: UpdateStreamResponse If the method is called asynchronously, returns the request thread. """ kwargs['_return_http_data_only'] = True if kwargs.get('async_req'): return self.update_stream_with_http_info(body, **kwargs) # noqa: E501 else: (data) = self.update_stream_with_http_info(body, **kwargs) # noqa: E501 return data def update_stream_with_http_info(self, body, **kwargs): # noqa: E501 """update_stream # 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_stream_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param UpdateStreamRequest body: (required) :return: UpdateStreamResponse 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_stream" % 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_stream`") # 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( '/UpdateStream/2021-01-01/aiotvideo/post/application_json/', 'POST', path_params, query_params, header_params, body=body_params, post_params=form_params, files=local_var_files, response_type='UpdateStreamResponse', # 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)