How to use request_headers method in Splinter

Best Python code snippet using splinter

thing_park_integration_controller_api.py

Source:thing_park_integration_controller_api.py Github

copy

Full Screen

1# coding: utf-82"""3 Thingsboard REST API4 For instructions how to authorize requests please visit <a href='http://thingsboard.io/docs/reference/rest-api/'>REST API documentation page</a>. # noqa: E5015 OpenAPI spec version: 2.06 Contact: info@thingsboard.io7 Generated by: https://github.com/swagger-api/swagger-codegen.git8"""9from __future__ import absolute_import10import re # noqa: F40111# python 2 and python 3 compatibility library12import six13from pyTB.api_client import ApiClient14class ThingParkIntegrationControllerApi(object):15 """NOTE: This class is auto generated by the swagger code generator program.16 Do not edit the class manually.17 Ref: https://github.com/swagger-api/swagger-codegen18 """19 def __init__(self, api_client=None):20 if api_client is None:21 api_client = ApiClient()22 self.api_client = api_client23 def process_request_tpe_using_delete(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E50124 """processRequestTPE # noqa: E50125 This method makes a synchronous HTTP request by default. To make an26 asynchronous HTTP request, please pass async_req=True27 >>> thread = api.process_request_tpe_using_delete(body, request_headers, all_request_params, routing_key, async_req=True)28 >>> result = thread.get()29 :param async_req bool30 :param str body: msg (required)31 :param Object request_headers: requestHeaders (required)32 :param Object all_request_params: allRequestParams (required)33 :param str routing_key: routingKey (required)34 :return: DeferredResultResponseEntity35 If the method is called asynchronously,36 returns the request thread.37 """38 kwargs['_return_http_data_only'] = True39 if kwargs.get('async_req'):40 return self.process_request_tpe_using_delete_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E50141 else:42 (data) = self.process_request_tpe_using_delete_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E50143 return data44 def process_request_tpe_using_delete_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E50145 """processRequestTPE # noqa: E50146 This method makes a synchronous HTTP request by default. To make an47 asynchronous HTTP request, please pass async_req=True48 >>> thread = api.process_request_tpe_using_delete_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)49 >>> result = thread.get()50 :param async_req bool51 :param str body: msg (required)52 :param Object request_headers: requestHeaders (required)53 :param Object all_request_params: allRequestParams (required)54 :param str routing_key: routingKey (required)55 :return: DeferredResultResponseEntity56 If the method is called asynchronously,57 returns the request thread.58 """59 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E50160 all_params.append('async_req')61 all_params.append('_return_http_data_only')62 all_params.append('_preload_content')63 all_params.append('_request_timeout')64 params = locals()65 for key, val in six.iteritems(params['kwargs']):66 if key not in all_params:67 raise TypeError(68 "Got an unexpected keyword argument '%s'"69 " to method process_request_tpe_using_delete" % key70 )71 params[key] = val72 del params['kwargs']73 # verify the required parameter 'body' is set74 if ('body' not in params or75 params['body'] is None):76 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_delete`") # noqa: E50177 # verify the required parameter 'request_headers' is set78 if ('request_headers' not in params or79 params['request_headers'] is None):80 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_delete`") # noqa: E50181 # verify the required parameter 'all_request_params' is set82 if ('all_request_params' not in params or83 params['all_request_params'] is None):84 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_delete`") # noqa: E50185 # verify the required parameter 'routing_key' is set86 if ('routing_key' not in params or87 params['routing_key'] is None):88 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_delete`") # noqa: E50189 collection_formats = {}90 path_params = {}91 if 'routing_key' in params:92 path_params['routingKey'] = params['routing_key'] # noqa: E50193 query_params = []94 if 'all_request_params' in params:95 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E50196 header_params = {}97 if 'request_headers' in params:98 header_params['requestHeaders'] = params['request_headers'] # noqa: E50199 form_params = []100 local_var_files = {}101 body_params = None102 if 'body' in params:103 body_params = params['body']104 # HTTP header `Accept`105 header_params['Accept'] = self.api_client.select_header_accept(106 ['*/*']) # noqa: E501107 # HTTP header `Content-Type`108 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501109 ['application/json']) # noqa: E501110 # Authentication setting111 auth_settings = ['X-Authorization'] # noqa: E501112 return self.api_client.call_api(113 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'DELETE',114 path_params,115 query_params,116 header_params,117 body=body_params,118 post_params=form_params,119 files=local_var_files,120 response_type='DeferredResultResponseEntity', # noqa: E501121 auth_settings=auth_settings,122 async_req=params.get('async_req'),123 _return_http_data_only=params.get('_return_http_data_only'),124 _preload_content=params.get('_preload_content', True),125 _request_timeout=params.get('_request_timeout'),126 collection_formats=collection_formats)127 def process_request_tpe_using_get(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501128 """processRequestTPE # noqa: E501129 This method makes a synchronous HTTP request by default. To make an130 asynchronous HTTP request, please pass async_req=True131 >>> thread = api.process_request_tpe_using_get(body, request_headers, all_request_params, routing_key, async_req=True)132 >>> result = thread.get()133 :param async_req bool134 :param str body: msg (required)135 :param Object request_headers: requestHeaders (required)136 :param Object all_request_params: allRequestParams (required)137 :param str routing_key: routingKey (required)138 :return: DeferredResultResponseEntity139 If the method is called asynchronously,140 returns the request thread.141 """142 kwargs['_return_http_data_only'] = True143 if kwargs.get('async_req'):144 return self.process_request_tpe_using_get_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501145 else:146 (data) = self.process_request_tpe_using_get_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501147 return data148 def process_request_tpe_using_get_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501149 """processRequestTPE # noqa: E501150 This method makes a synchronous HTTP request by default. To make an151 asynchronous HTTP request, please pass async_req=True152 >>> thread = api.process_request_tpe_using_get_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)153 >>> result = thread.get()154 :param async_req bool155 :param str body: msg (required)156 :param Object request_headers: requestHeaders (required)157 :param Object all_request_params: allRequestParams (required)158 :param str routing_key: routingKey (required)159 :return: DeferredResultResponseEntity160 If the method is called asynchronously,161 returns the request thread.162 """163 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501164 all_params.append('async_req')165 all_params.append('_return_http_data_only')166 all_params.append('_preload_content')167 all_params.append('_request_timeout')168 params = locals()169 for key, val in six.iteritems(params['kwargs']):170 if key not in all_params:171 raise TypeError(172 "Got an unexpected keyword argument '%s'"173 " to method process_request_tpe_using_get" % key174 )175 params[key] = val176 del params['kwargs']177 # verify the required parameter 'body' is set178 if ('body' not in params or179 params['body'] is None):180 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_get`") # noqa: E501181 # verify the required parameter 'request_headers' is set182 if ('request_headers' not in params or183 params['request_headers'] is None):184 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_get`") # noqa: E501185 # verify the required parameter 'all_request_params' is set186 if ('all_request_params' not in params or187 params['all_request_params'] is None):188 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_get`") # noqa: E501189 # verify the required parameter 'routing_key' is set190 if ('routing_key' not in params or191 params['routing_key'] is None):192 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_get`") # noqa: E501193 collection_formats = {}194 path_params = {}195 if 'routing_key' in params:196 path_params['routingKey'] = params['routing_key'] # noqa: E501197 query_params = []198 if 'all_request_params' in params:199 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501200 header_params = {}201 if 'request_headers' in params:202 header_params['requestHeaders'] = params['request_headers'] # noqa: E501203 form_params = []204 local_var_files = {}205 body_params = None206 if 'body' in params:207 body_params = params['body']208 # HTTP header `Accept`209 header_params['Accept'] = self.api_client.select_header_accept(210 ['*/*']) # noqa: E501211 # HTTP header `Content-Type`212 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501213 ['application/json']) # noqa: E501214 # Authentication setting215 auth_settings = ['X-Authorization'] # noqa: E501216 return self.api_client.call_api(217 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'GET',218 path_params,219 query_params,220 header_params,221 body=body_params,222 post_params=form_params,223 files=local_var_files,224 response_type='DeferredResultResponseEntity', # noqa: E501225 auth_settings=auth_settings,226 async_req=params.get('async_req'),227 _return_http_data_only=params.get('_return_http_data_only'),228 _preload_content=params.get('_preload_content', True),229 _request_timeout=params.get('_request_timeout'),230 collection_formats=collection_formats)231 def process_request_tpe_using_head(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501232 """processRequestTPE # noqa: E501233 This method makes a synchronous HTTP request by default. To make an234 asynchronous HTTP request, please pass async_req=True235 >>> thread = api.process_request_tpe_using_head(body, request_headers, all_request_params, routing_key, async_req=True)236 >>> result = thread.get()237 :param async_req bool238 :param str body: msg (required)239 :param Object request_headers: requestHeaders (required)240 :param Object all_request_params: allRequestParams (required)241 :param str routing_key: routingKey (required)242 :return: DeferredResultResponseEntity243 If the method is called asynchronously,244 returns the request thread.245 """246 kwargs['_return_http_data_only'] = True247 if kwargs.get('async_req'):248 return self.process_request_tpe_using_head_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501249 else:250 (data) = self.process_request_tpe_using_head_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501251 return data252 def process_request_tpe_using_head_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501253 """processRequestTPE # noqa: E501254 This method makes a synchronous HTTP request by default. To make an255 asynchronous HTTP request, please pass async_req=True256 >>> thread = api.process_request_tpe_using_head_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)257 >>> result = thread.get()258 :param async_req bool259 :param str body: msg (required)260 :param Object request_headers: requestHeaders (required)261 :param Object all_request_params: allRequestParams (required)262 :param str routing_key: routingKey (required)263 :return: DeferredResultResponseEntity264 If the method is called asynchronously,265 returns the request thread.266 """267 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501268 all_params.append('async_req')269 all_params.append('_return_http_data_only')270 all_params.append('_preload_content')271 all_params.append('_request_timeout')272 params = locals()273 for key, val in six.iteritems(params['kwargs']):274 if key not in all_params:275 raise TypeError(276 "Got an unexpected keyword argument '%s'"277 " to method process_request_tpe_using_head" % key278 )279 params[key] = val280 del params['kwargs']281 # verify the required parameter 'body' is set282 if ('body' not in params or283 params['body'] is None):284 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_head`") # noqa: E501285 # verify the required parameter 'request_headers' is set286 if ('request_headers' not in params or287 params['request_headers'] is None):288 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_head`") # noqa: E501289 # verify the required parameter 'all_request_params' is set290 if ('all_request_params' not in params or291 params['all_request_params'] is None):292 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_head`") # noqa: E501293 # verify the required parameter 'routing_key' is set294 if ('routing_key' not in params or295 params['routing_key'] is None):296 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_head`") # noqa: E501297 collection_formats = {}298 path_params = {}299 if 'routing_key' in params:300 path_params['routingKey'] = params['routing_key'] # noqa: E501301 query_params = []302 if 'all_request_params' in params:303 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501304 header_params = {}305 if 'request_headers' in params:306 header_params['requestHeaders'] = params['request_headers'] # noqa: E501307 form_params = []308 local_var_files = {}309 body_params = None310 if 'body' in params:311 body_params = params['body']312 # HTTP header `Accept`313 header_params['Accept'] = self.api_client.select_header_accept(314 ['*/*']) # noqa: E501315 # HTTP header `Content-Type`316 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501317 ['application/json']) # noqa: E501318 # Authentication setting319 auth_settings = ['X-Authorization'] # noqa: E501320 return self.api_client.call_api(321 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'HEAD',322 path_params,323 query_params,324 header_params,325 body=body_params,326 post_params=form_params,327 files=local_var_files,328 response_type='DeferredResultResponseEntity', # noqa: E501329 auth_settings=auth_settings,330 async_req=params.get('async_req'),331 _return_http_data_only=params.get('_return_http_data_only'),332 _preload_content=params.get('_preload_content', True),333 _request_timeout=params.get('_request_timeout'),334 collection_formats=collection_formats)335 def process_request_tpe_using_options(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501336 """processRequestTPE # noqa: E501337 This method makes a synchronous HTTP request by default. To make an338 asynchronous HTTP request, please pass async_req=True339 >>> thread = api.process_request_tpe_using_options(body, request_headers, all_request_params, routing_key, async_req=True)340 >>> result = thread.get()341 :param async_req bool342 :param str body: msg (required)343 :param Object request_headers: requestHeaders (required)344 :param Object all_request_params: allRequestParams (required)345 :param str routing_key: routingKey (required)346 :return: DeferredResultResponseEntity347 If the method is called asynchronously,348 returns the request thread.349 """350 kwargs['_return_http_data_only'] = True351 if kwargs.get('async_req'):352 return self.process_request_tpe_using_options_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501353 else:354 (data) = self.process_request_tpe_using_options_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501355 return data356 def process_request_tpe_using_options_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501357 """processRequestTPE # noqa: E501358 This method makes a synchronous HTTP request by default. To make an359 asynchronous HTTP request, please pass async_req=True360 >>> thread = api.process_request_tpe_using_options_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)361 >>> result = thread.get()362 :param async_req bool363 :param str body: msg (required)364 :param Object request_headers: requestHeaders (required)365 :param Object all_request_params: allRequestParams (required)366 :param str routing_key: routingKey (required)367 :return: DeferredResultResponseEntity368 If the method is called asynchronously,369 returns the request thread.370 """371 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501372 all_params.append('async_req')373 all_params.append('_return_http_data_only')374 all_params.append('_preload_content')375 all_params.append('_request_timeout')376 params = locals()377 for key, val in six.iteritems(params['kwargs']):378 if key not in all_params:379 raise TypeError(380 "Got an unexpected keyword argument '%s'"381 " to method process_request_tpe_using_options" % key382 )383 params[key] = val384 del params['kwargs']385 # verify the required parameter 'body' is set386 if ('body' not in params or387 params['body'] is None):388 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_options`") # noqa: E501389 # verify the required parameter 'request_headers' is set390 if ('request_headers' not in params or391 params['request_headers'] is None):392 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_options`") # noqa: E501393 # verify the required parameter 'all_request_params' is set394 if ('all_request_params' not in params or395 params['all_request_params'] is None):396 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_options`") # noqa: E501397 # verify the required parameter 'routing_key' is set398 if ('routing_key' not in params or399 params['routing_key'] is None):400 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_options`") # noqa: E501401 collection_formats = {}402 path_params = {}403 if 'routing_key' in params:404 path_params['routingKey'] = params['routing_key'] # noqa: E501405 query_params = []406 if 'all_request_params' in params:407 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501408 header_params = {}409 if 'request_headers' in params:410 header_params['requestHeaders'] = params['request_headers'] # noqa: E501411 form_params = []412 local_var_files = {}413 body_params = None414 if 'body' in params:415 body_params = params['body']416 # HTTP header `Accept`417 header_params['Accept'] = self.api_client.select_header_accept(418 ['*/*']) # noqa: E501419 # HTTP header `Content-Type`420 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501421 ['application/json']) # noqa: E501422 # Authentication setting423 auth_settings = ['X-Authorization'] # noqa: E501424 return self.api_client.call_api(425 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'OPTIONS',426 path_params,427 query_params,428 header_params,429 body=body_params,430 post_params=form_params,431 files=local_var_files,432 response_type='DeferredResultResponseEntity', # noqa: E501433 auth_settings=auth_settings,434 async_req=params.get('async_req'),435 _return_http_data_only=params.get('_return_http_data_only'),436 _preload_content=params.get('_preload_content', True),437 _request_timeout=params.get('_request_timeout'),438 collection_formats=collection_formats)439 def process_request_tpe_using_patch(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501440 """processRequestTPE # noqa: E501441 This method makes a synchronous HTTP request by default. To make an442 asynchronous HTTP request, please pass async_req=True443 >>> thread = api.process_request_tpe_using_patch(body, request_headers, all_request_params, routing_key, async_req=True)444 >>> result = thread.get()445 :param async_req bool446 :param str body: msg (required)447 :param Object request_headers: requestHeaders (required)448 :param Object all_request_params: allRequestParams (required)449 :param str routing_key: routingKey (required)450 :return: DeferredResultResponseEntity451 If the method is called asynchronously,452 returns the request thread.453 """454 kwargs['_return_http_data_only'] = True455 if kwargs.get('async_req'):456 return self.process_request_tpe_using_patch_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501457 else:458 (data) = self.process_request_tpe_using_patch_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501459 return data460 def process_request_tpe_using_patch_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501461 """processRequestTPE # noqa: E501462 This method makes a synchronous HTTP request by default. To make an463 asynchronous HTTP request, please pass async_req=True464 >>> thread = api.process_request_tpe_using_patch_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)465 >>> result = thread.get()466 :param async_req bool467 :param str body: msg (required)468 :param Object request_headers: requestHeaders (required)469 :param Object all_request_params: allRequestParams (required)470 :param str routing_key: routingKey (required)471 :return: DeferredResultResponseEntity472 If the method is called asynchronously,473 returns the request thread.474 """475 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501476 all_params.append('async_req')477 all_params.append('_return_http_data_only')478 all_params.append('_preload_content')479 all_params.append('_request_timeout')480 params = locals()481 for key, val in six.iteritems(params['kwargs']):482 if key not in all_params:483 raise TypeError(484 "Got an unexpected keyword argument '%s'"485 " to method process_request_tpe_using_patch" % key486 )487 params[key] = val488 del params['kwargs']489 # verify the required parameter 'body' is set490 if ('body' not in params or491 params['body'] is None):492 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_patch`") # noqa: E501493 # verify the required parameter 'request_headers' is set494 if ('request_headers' not in params or495 params['request_headers'] is None):496 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_patch`") # noqa: E501497 # verify the required parameter 'all_request_params' is set498 if ('all_request_params' not in params or499 params['all_request_params'] is None):500 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_patch`") # noqa: E501501 # verify the required parameter 'routing_key' is set502 if ('routing_key' not in params or503 params['routing_key'] is None):504 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_patch`") # noqa: E501505 collection_formats = {}506 path_params = {}507 if 'routing_key' in params:508 path_params['routingKey'] = params['routing_key'] # noqa: E501509 query_params = []510 if 'all_request_params' in params:511 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501512 header_params = {}513 if 'request_headers' in params:514 header_params['requestHeaders'] = params['request_headers'] # noqa: E501515 form_params = []516 local_var_files = {}517 body_params = None518 if 'body' in params:519 body_params = params['body']520 # HTTP header `Accept`521 header_params['Accept'] = self.api_client.select_header_accept(522 ['*/*']) # noqa: E501523 # HTTP header `Content-Type`524 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501525 ['application/json']) # noqa: E501526 # Authentication setting527 auth_settings = ['X-Authorization'] # noqa: E501528 return self.api_client.call_api(529 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'PATCH',530 path_params,531 query_params,532 header_params,533 body=body_params,534 post_params=form_params,535 files=local_var_files,536 response_type='DeferredResultResponseEntity', # noqa: E501537 auth_settings=auth_settings,538 async_req=params.get('async_req'),539 _return_http_data_only=params.get('_return_http_data_only'),540 _preload_content=params.get('_preload_content', True),541 _request_timeout=params.get('_request_timeout'),542 collection_formats=collection_formats)543 def process_request_tpe_using_post(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501544 """processRequestTPE # noqa: E501545 This method makes a synchronous HTTP request by default. To make an546 asynchronous HTTP request, please pass async_req=True547 >>> thread = api.process_request_tpe_using_post(body, request_headers, all_request_params, routing_key, async_req=True)548 >>> result = thread.get()549 :param async_req bool550 :param str body: msg (required)551 :param Object request_headers: requestHeaders (required)552 :param Object all_request_params: allRequestParams (required)553 :param str routing_key: routingKey (required)554 :return: DeferredResultResponseEntity555 If the method is called asynchronously,556 returns the request thread.557 """558 kwargs['_return_http_data_only'] = True559 if kwargs.get('async_req'):560 return self.process_request_tpe_using_post_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501561 else:562 (data) = self.process_request_tpe_using_post_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501563 return data564 def process_request_tpe_using_post_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501565 """processRequestTPE # noqa: E501566 This method makes a synchronous HTTP request by default. To make an567 asynchronous HTTP request, please pass async_req=True568 >>> thread = api.process_request_tpe_using_post_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)569 >>> result = thread.get()570 :param async_req bool571 :param str body: msg (required)572 :param Object request_headers: requestHeaders (required)573 :param Object all_request_params: allRequestParams (required)574 :param str routing_key: routingKey (required)575 :return: DeferredResultResponseEntity576 If the method is called asynchronously,577 returns the request thread.578 """579 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501580 all_params.append('async_req')581 all_params.append('_return_http_data_only')582 all_params.append('_preload_content')583 all_params.append('_request_timeout')584 params = locals()585 for key, val in six.iteritems(params['kwargs']):586 if key not in all_params:587 raise TypeError(588 "Got an unexpected keyword argument '%s'"589 " to method process_request_tpe_using_post" % key590 )591 params[key] = val592 del params['kwargs']593 # verify the required parameter 'body' is set594 if ('body' not in params or595 params['body'] is None):596 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_post`") # noqa: E501597 # verify the required parameter 'request_headers' is set598 if ('request_headers' not in params or599 params['request_headers'] is None):600 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_post`") # noqa: E501601 # verify the required parameter 'all_request_params' is set602 if ('all_request_params' not in params or603 params['all_request_params'] is None):604 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_post`") # noqa: E501605 # verify the required parameter 'routing_key' is set606 if ('routing_key' not in params or607 params['routing_key'] is None):608 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_post`") # noqa: E501609 collection_formats = {}610 path_params = {}611 if 'routing_key' in params:612 path_params['routingKey'] = params['routing_key'] # noqa: E501613 query_params = []614 if 'all_request_params' in params:615 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501616 header_params = {}617 if 'request_headers' in params:618 header_params['requestHeaders'] = params['request_headers'] # noqa: E501619 form_params = []620 local_var_files = {}621 body_params = None622 if 'body' in params:623 body_params = params['body']624 # HTTP header `Accept`625 header_params['Accept'] = self.api_client.select_header_accept(626 ['*/*']) # noqa: E501627 # HTTP header `Content-Type`628 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501629 ['application/json']) # noqa: E501630 # Authentication setting631 auth_settings = ['X-Authorization'] # noqa: E501632 return self.api_client.call_api(633 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'POST',634 path_params,635 query_params,636 header_params,637 body=body_params,638 post_params=form_params,639 files=local_var_files,640 response_type='DeferredResultResponseEntity', # noqa: E501641 auth_settings=auth_settings,642 async_req=params.get('async_req'),643 _return_http_data_only=params.get('_return_http_data_only'),644 _preload_content=params.get('_preload_content', True),645 _request_timeout=params.get('_request_timeout'),646 collection_formats=collection_formats)647 def process_request_tpe_using_put(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501648 """processRequestTPE # noqa: E501649 This method makes a synchronous HTTP request by default. To make an650 asynchronous HTTP request, please pass async_req=True651 >>> thread = api.process_request_tpe_using_put(body, request_headers, all_request_params, routing_key, async_req=True)652 >>> result = thread.get()653 :param async_req bool654 :param str body: msg (required)655 :param Object request_headers: requestHeaders (required)656 :param Object all_request_params: allRequestParams (required)657 :param str routing_key: routingKey (required)658 :return: DeferredResultResponseEntity659 If the method is called asynchronously,660 returns the request thread.661 """662 kwargs['_return_http_data_only'] = True663 if kwargs.get('async_req'):664 return self.process_request_tpe_using_put_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501665 else:666 (data) = self.process_request_tpe_using_put_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501667 return data668 def process_request_tpe_using_put_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501669 """processRequestTPE # noqa: E501670 This method makes a synchronous HTTP request by default. To make an671 asynchronous HTTP request, please pass async_req=True672 >>> thread = api.process_request_tpe_using_put_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)673 >>> result = thread.get()674 :param async_req bool675 :param str body: msg (required)676 :param Object request_headers: requestHeaders (required)677 :param Object all_request_params: allRequestParams (required)678 :param str routing_key: routingKey (required)679 :return: DeferredResultResponseEntity680 If the method is called asynchronously,681 returns the request thread.682 """683 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501684 all_params.append('async_req')685 all_params.append('_return_http_data_only')686 all_params.append('_preload_content')687 all_params.append('_request_timeout')688 params = locals()689 for key, val in six.iteritems(params['kwargs']):690 if key not in all_params:691 raise TypeError(692 "Got an unexpected keyword argument '%s'"693 " to method process_request_tpe_using_put" % key694 )695 params[key] = val696 del params['kwargs']697 # verify the required parameter 'body' is set698 if ('body' not in params or699 params['body'] is None):700 raise ValueError("Missing the required parameter `body` when calling `process_request_tpe_using_put`") # noqa: E501701 # verify the required parameter 'request_headers' is set702 if ('request_headers' not in params or703 params['request_headers'] is None):704 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_tpe_using_put`") # noqa: E501705 # verify the required parameter 'all_request_params' is set706 if ('all_request_params' not in params or707 params['all_request_params'] is None):708 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_tpe_using_put`") # noqa: E501709 # verify the required parameter 'routing_key' is set710 if ('routing_key' not in params or711 params['routing_key'] is None):712 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_tpe_using_put`") # noqa: E501713 collection_formats = {}714 path_params = {}715 if 'routing_key' in params:716 path_params['routingKey'] = params['routing_key'] # noqa: E501717 query_params = []718 if 'all_request_params' in params:719 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501720 header_params = {}721 if 'request_headers' in params:722 header_params['requestHeaders'] = params['request_headers'] # noqa: E501723 form_params = []724 local_var_files = {}725 body_params = None726 if 'body' in params:727 body_params = params['body']728 # HTTP header `Accept`729 header_params['Accept'] = self.api_client.select_header_accept(730 ['*/*']) # noqa: E501731 # HTTP header `Content-Type`732 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501733 ['application/json']) # noqa: E501734 # Authentication setting735 auth_settings = ['X-Authorization'] # noqa: E501736 return self.api_client.call_api(737 '/api/v1/integrations/tpe/{routingKey}{?allRequestParams}', 'PUT',738 path_params,739 query_params,740 header_params,741 body=body_params,742 post_params=form_params,743 files=local_var_files,744 response_type='DeferredResultResponseEntity', # noqa: E501745 auth_settings=auth_settings,746 async_req=params.get('async_req'),747 _return_http_data_only=params.get('_return_http_data_only'),748 _preload_content=params.get('_preload_content', True),749 _request_timeout=params.get('_request_timeout'),750 collection_formats=collection_formats)751 def process_request_using_delete3(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501752 """processRequest # noqa: E501753 This method makes a synchronous HTTP request by default. To make an754 asynchronous HTTP request, please pass async_req=True755 >>> thread = api.process_request_using_delete3(body, request_headers, all_request_params, routing_key, async_req=True)756 >>> result = thread.get()757 :param async_req bool758 :param str body: msg (required)759 :param Object request_headers: requestHeaders (required)760 :param Object all_request_params: allRequestParams (required)761 :param str routing_key: routingKey (required)762 :return: DeferredResultResponseEntity763 If the method is called asynchronously,764 returns the request thread.765 """766 kwargs['_return_http_data_only'] = True767 if kwargs.get('async_req'):768 return self.process_request_using_delete3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501769 else:770 (data) = self.process_request_using_delete3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501771 return data772 def process_request_using_delete3_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501773 """processRequest # noqa: E501774 This method makes a synchronous HTTP request by default. To make an775 asynchronous HTTP request, please pass async_req=True776 >>> thread = api.process_request_using_delete3_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)777 >>> result = thread.get()778 :param async_req bool779 :param str body: msg (required)780 :param Object request_headers: requestHeaders (required)781 :param Object all_request_params: allRequestParams (required)782 :param str routing_key: routingKey (required)783 :return: DeferredResultResponseEntity784 If the method is called asynchronously,785 returns the request thread.786 """787 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501788 all_params.append('async_req')789 all_params.append('_return_http_data_only')790 all_params.append('_preload_content')791 all_params.append('_request_timeout')792 params = locals()793 for key, val in six.iteritems(params['kwargs']):794 if key not in all_params:795 raise TypeError(796 "Got an unexpected keyword argument '%s'"797 " to method process_request_using_delete3" % key798 )799 params[key] = val800 del params['kwargs']801 # verify the required parameter 'body' is set802 if ('body' not in params or803 params['body'] is None):804 raise ValueError("Missing the required parameter `body` when calling `process_request_using_delete3`") # noqa: E501805 # verify the required parameter 'request_headers' is set806 if ('request_headers' not in params or807 params['request_headers'] is None):808 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_delete3`") # noqa: E501809 # verify the required parameter 'all_request_params' is set810 if ('all_request_params' not in params or811 params['all_request_params'] is None):812 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_delete3`") # noqa: E501813 # verify the required parameter 'routing_key' is set814 if ('routing_key' not in params or815 params['routing_key'] is None):816 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_delete3`") # noqa: E501817 collection_formats = {}818 path_params = {}819 if 'routing_key' in params:820 path_params['routingKey'] = params['routing_key'] # noqa: E501821 query_params = []822 if 'all_request_params' in params:823 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501824 header_params = {}825 if 'request_headers' in params:826 header_params['requestHeaders'] = params['request_headers'] # noqa: E501827 form_params = []828 local_var_files = {}829 body_params = None830 if 'body' in params:831 body_params = params['body']832 # HTTP header `Accept`833 header_params['Accept'] = self.api_client.select_header_accept(834 ['*/*']) # noqa: E501835 # HTTP header `Content-Type`836 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501837 ['application/json']) # noqa: E501838 # Authentication setting839 auth_settings = ['X-Authorization'] # noqa: E501840 return self.api_client.call_api(841 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'DELETE',842 path_params,843 query_params,844 header_params,845 body=body_params,846 post_params=form_params,847 files=local_var_files,848 response_type='DeferredResultResponseEntity', # noqa: E501849 auth_settings=auth_settings,850 async_req=params.get('async_req'),851 _return_http_data_only=params.get('_return_http_data_only'),852 _preload_content=params.get('_preload_content', True),853 _request_timeout=params.get('_request_timeout'),854 collection_formats=collection_formats)855 def process_request_using_get3(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501856 """processRequest # noqa: E501857 This method makes a synchronous HTTP request by default. To make an858 asynchronous HTTP request, please pass async_req=True859 >>> thread = api.process_request_using_get3(body, request_headers, all_request_params, routing_key, async_req=True)860 >>> result = thread.get()861 :param async_req bool862 :param str body: msg (required)863 :param Object request_headers: requestHeaders (required)864 :param Object all_request_params: allRequestParams (required)865 :param str routing_key: routingKey (required)866 :return: DeferredResultResponseEntity867 If the method is called asynchronously,868 returns the request thread.869 """870 kwargs['_return_http_data_only'] = True871 if kwargs.get('async_req'):872 return self.process_request_using_get3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501873 else:874 (data) = self.process_request_using_get3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501875 return data876 def process_request_using_get3_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501877 """processRequest # noqa: E501878 This method makes a synchronous HTTP request by default. To make an879 asynchronous HTTP request, please pass async_req=True880 >>> thread = api.process_request_using_get3_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)881 >>> result = thread.get()882 :param async_req bool883 :param str body: msg (required)884 :param Object request_headers: requestHeaders (required)885 :param Object all_request_params: allRequestParams (required)886 :param str routing_key: routingKey (required)887 :return: DeferredResultResponseEntity888 If the method is called asynchronously,889 returns the request thread.890 """891 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501892 all_params.append('async_req')893 all_params.append('_return_http_data_only')894 all_params.append('_preload_content')895 all_params.append('_request_timeout')896 params = locals()897 for key, val in six.iteritems(params['kwargs']):898 if key not in all_params:899 raise TypeError(900 "Got an unexpected keyword argument '%s'"901 " to method process_request_using_get3" % key902 )903 params[key] = val904 del params['kwargs']905 # verify the required parameter 'body' is set906 if ('body' not in params or907 params['body'] is None):908 raise ValueError("Missing the required parameter `body` when calling `process_request_using_get3`") # noqa: E501909 # verify the required parameter 'request_headers' is set910 if ('request_headers' not in params or911 params['request_headers'] is None):912 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_get3`") # noqa: E501913 # verify the required parameter 'all_request_params' is set914 if ('all_request_params' not in params or915 params['all_request_params'] is None):916 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_get3`") # noqa: E501917 # verify the required parameter 'routing_key' is set918 if ('routing_key' not in params or919 params['routing_key'] is None):920 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_get3`") # noqa: E501921 collection_formats = {}922 path_params = {}923 if 'routing_key' in params:924 path_params['routingKey'] = params['routing_key'] # noqa: E501925 query_params = []926 if 'all_request_params' in params:927 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E501928 header_params = {}929 if 'request_headers' in params:930 header_params['requestHeaders'] = params['request_headers'] # noqa: E501931 form_params = []932 local_var_files = {}933 body_params = None934 if 'body' in params:935 body_params = params['body']936 # HTTP header `Accept`937 header_params['Accept'] = self.api_client.select_header_accept(938 ['*/*']) # noqa: E501939 # HTTP header `Content-Type`940 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501941 ['application/json']) # noqa: E501942 # Authentication setting943 auth_settings = ['X-Authorization'] # noqa: E501944 return self.api_client.call_api(945 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'GET',946 path_params,947 query_params,948 header_params,949 body=body_params,950 post_params=form_params,951 files=local_var_files,952 response_type='DeferredResultResponseEntity', # noqa: E501953 auth_settings=auth_settings,954 async_req=params.get('async_req'),955 _return_http_data_only=params.get('_return_http_data_only'),956 _preload_content=params.get('_preload_content', True),957 _request_timeout=params.get('_request_timeout'),958 collection_formats=collection_formats)959 def process_request_using_head3(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501960 """processRequest # noqa: E501961 This method makes a synchronous HTTP request by default. To make an962 asynchronous HTTP request, please pass async_req=True963 >>> thread = api.process_request_using_head3(body, request_headers, all_request_params, routing_key, async_req=True)964 >>> result = thread.get()965 :param async_req bool966 :param str body: msg (required)967 :param Object request_headers: requestHeaders (required)968 :param Object all_request_params: allRequestParams (required)969 :param str routing_key: routingKey (required)970 :return: DeferredResultResponseEntity971 If the method is called asynchronously,972 returns the request thread.973 """974 kwargs['_return_http_data_only'] = True975 if kwargs.get('async_req'):976 return self.process_request_using_head3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501977 else:978 (data) = self.process_request_using_head3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E501979 return data980 def process_request_using_head3_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E501981 """processRequest # noqa: E501982 This method makes a synchronous HTTP request by default. To make an983 asynchronous HTTP request, please pass async_req=True984 >>> thread = api.process_request_using_head3_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)985 >>> result = thread.get()986 :param async_req bool987 :param str body: msg (required)988 :param Object request_headers: requestHeaders (required)989 :param Object all_request_params: allRequestParams (required)990 :param str routing_key: routingKey (required)991 :return: DeferredResultResponseEntity992 If the method is called asynchronously,993 returns the request thread.994 """995 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E501996 all_params.append('async_req')997 all_params.append('_return_http_data_only')998 all_params.append('_preload_content')999 all_params.append('_request_timeout')1000 params = locals()1001 for key, val in six.iteritems(params['kwargs']):1002 if key not in all_params:1003 raise TypeError(1004 "Got an unexpected keyword argument '%s'"1005 " to method process_request_using_head3" % key1006 )1007 params[key] = val1008 del params['kwargs']1009 # verify the required parameter 'body' is set1010 if ('body' not in params or1011 params['body'] is None):1012 raise ValueError("Missing the required parameter `body` when calling `process_request_using_head3`") # noqa: E5011013 # verify the required parameter 'request_headers' is set1014 if ('request_headers' not in params or1015 params['request_headers'] is None):1016 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_head3`") # noqa: E5011017 # verify the required parameter 'all_request_params' is set1018 if ('all_request_params' not in params or1019 params['all_request_params'] is None):1020 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_head3`") # noqa: E5011021 # verify the required parameter 'routing_key' is set1022 if ('routing_key' not in params or1023 params['routing_key'] is None):1024 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_head3`") # noqa: E5011025 collection_formats = {}1026 path_params = {}1027 if 'routing_key' in params:1028 path_params['routingKey'] = params['routing_key'] # noqa: E5011029 query_params = []1030 if 'all_request_params' in params:1031 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E5011032 header_params = {}1033 if 'request_headers' in params:1034 header_params['requestHeaders'] = params['request_headers'] # noqa: E5011035 form_params = []1036 local_var_files = {}1037 body_params = None1038 if 'body' in params:1039 body_params = params['body']1040 # HTTP header `Accept`1041 header_params['Accept'] = self.api_client.select_header_accept(1042 ['*/*']) # noqa: E5011043 # HTTP header `Content-Type`1044 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E5011045 ['application/json']) # noqa: E5011046 # Authentication setting1047 auth_settings = ['X-Authorization'] # noqa: E5011048 return self.api_client.call_api(1049 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'HEAD',1050 path_params,1051 query_params,1052 header_params,1053 body=body_params,1054 post_params=form_params,1055 files=local_var_files,1056 response_type='DeferredResultResponseEntity', # noqa: E5011057 auth_settings=auth_settings,1058 async_req=params.get('async_req'),1059 _return_http_data_only=params.get('_return_http_data_only'),1060 _preload_content=params.get('_preload_content', True),1061 _request_timeout=params.get('_request_timeout'),1062 collection_formats=collection_formats)1063 def process_request_using_options3(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011064 """processRequest # noqa: E5011065 This method makes a synchronous HTTP request by default. To make an1066 asynchronous HTTP request, please pass async_req=True1067 >>> thread = api.process_request_using_options3(body, request_headers, all_request_params, routing_key, async_req=True)1068 >>> result = thread.get()1069 :param async_req bool1070 :param str body: msg (required)1071 :param Object request_headers: requestHeaders (required)1072 :param Object all_request_params: allRequestParams (required)1073 :param str routing_key: routingKey (required)1074 :return: DeferredResultResponseEntity1075 If the method is called asynchronously,1076 returns the request thread.1077 """1078 kwargs['_return_http_data_only'] = True1079 if kwargs.get('async_req'):1080 return self.process_request_using_options3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011081 else:1082 (data) = self.process_request_using_options3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011083 return data1084 def process_request_using_options3_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011085 """processRequest # noqa: E5011086 This method makes a synchronous HTTP request by default. To make an1087 asynchronous HTTP request, please pass async_req=True1088 >>> thread = api.process_request_using_options3_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)1089 >>> result = thread.get()1090 :param async_req bool1091 :param str body: msg (required)1092 :param Object request_headers: requestHeaders (required)1093 :param Object all_request_params: allRequestParams (required)1094 :param str routing_key: routingKey (required)1095 :return: DeferredResultResponseEntity1096 If the method is called asynchronously,1097 returns the request thread.1098 """1099 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E5011100 all_params.append('async_req')1101 all_params.append('_return_http_data_only')1102 all_params.append('_preload_content')1103 all_params.append('_request_timeout')1104 params = locals()1105 for key, val in six.iteritems(params['kwargs']):1106 if key not in all_params:1107 raise TypeError(1108 "Got an unexpected keyword argument '%s'"1109 " to method process_request_using_options3" % key1110 )1111 params[key] = val1112 del params['kwargs']1113 # verify the required parameter 'body' is set1114 if ('body' not in params or1115 params['body'] is None):1116 raise ValueError("Missing the required parameter `body` when calling `process_request_using_options3`") # noqa: E5011117 # verify the required parameter 'request_headers' is set1118 if ('request_headers' not in params or1119 params['request_headers'] is None):1120 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_options3`") # noqa: E5011121 # verify the required parameter 'all_request_params' is set1122 if ('all_request_params' not in params or1123 params['all_request_params'] is None):1124 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_options3`") # noqa: E5011125 # verify the required parameter 'routing_key' is set1126 if ('routing_key' not in params or1127 params['routing_key'] is None):1128 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_options3`") # noqa: E5011129 collection_formats = {}1130 path_params = {}1131 if 'routing_key' in params:1132 path_params['routingKey'] = params['routing_key'] # noqa: E5011133 query_params = []1134 if 'all_request_params' in params:1135 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E5011136 header_params = {}1137 if 'request_headers' in params:1138 header_params['requestHeaders'] = params['request_headers'] # noqa: E5011139 form_params = []1140 local_var_files = {}1141 body_params = None1142 if 'body' in params:1143 body_params = params['body']1144 # HTTP header `Accept`1145 header_params['Accept'] = self.api_client.select_header_accept(1146 ['*/*']) # noqa: E5011147 # HTTP header `Content-Type`1148 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E5011149 ['application/json']) # noqa: E5011150 # Authentication setting1151 auth_settings = ['X-Authorization'] # noqa: E5011152 return self.api_client.call_api(1153 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'OPTIONS',1154 path_params,1155 query_params,1156 header_params,1157 body=body_params,1158 post_params=form_params,1159 files=local_var_files,1160 response_type='DeferredResultResponseEntity', # noqa: E5011161 auth_settings=auth_settings,1162 async_req=params.get('async_req'),1163 _return_http_data_only=params.get('_return_http_data_only'),1164 _preload_content=params.get('_preload_content', True),1165 _request_timeout=params.get('_request_timeout'),1166 collection_formats=collection_formats)1167 def process_request_using_patch3(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011168 """processRequest # noqa: E5011169 This method makes a synchronous HTTP request by default. To make an1170 asynchronous HTTP request, please pass async_req=True1171 >>> thread = api.process_request_using_patch3(body, request_headers, all_request_params, routing_key, async_req=True)1172 >>> result = thread.get()1173 :param async_req bool1174 :param str body: msg (required)1175 :param Object request_headers: requestHeaders (required)1176 :param Object all_request_params: allRequestParams (required)1177 :param str routing_key: routingKey (required)1178 :return: DeferredResultResponseEntity1179 If the method is called asynchronously,1180 returns the request thread.1181 """1182 kwargs['_return_http_data_only'] = True1183 if kwargs.get('async_req'):1184 return self.process_request_using_patch3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011185 else:1186 (data) = self.process_request_using_patch3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011187 return data1188 def process_request_using_patch3_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011189 """processRequest # noqa: E5011190 This method makes a synchronous HTTP request by default. To make an1191 asynchronous HTTP request, please pass async_req=True1192 >>> thread = api.process_request_using_patch3_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)1193 >>> result = thread.get()1194 :param async_req bool1195 :param str body: msg (required)1196 :param Object request_headers: requestHeaders (required)1197 :param Object all_request_params: allRequestParams (required)1198 :param str routing_key: routingKey (required)1199 :return: DeferredResultResponseEntity1200 If the method is called asynchronously,1201 returns the request thread.1202 """1203 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E5011204 all_params.append('async_req')1205 all_params.append('_return_http_data_only')1206 all_params.append('_preload_content')1207 all_params.append('_request_timeout')1208 params = locals()1209 for key, val in six.iteritems(params['kwargs']):1210 if key not in all_params:1211 raise TypeError(1212 "Got an unexpected keyword argument '%s'"1213 " to method process_request_using_patch3" % key1214 )1215 params[key] = val1216 del params['kwargs']1217 # verify the required parameter 'body' is set1218 if ('body' not in params or1219 params['body'] is None):1220 raise ValueError("Missing the required parameter `body` when calling `process_request_using_patch3`") # noqa: E5011221 # verify the required parameter 'request_headers' is set1222 if ('request_headers' not in params or1223 params['request_headers'] is None):1224 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_patch3`") # noqa: E5011225 # verify the required parameter 'all_request_params' is set1226 if ('all_request_params' not in params or1227 params['all_request_params'] is None):1228 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_patch3`") # noqa: E5011229 # verify the required parameter 'routing_key' is set1230 if ('routing_key' not in params or1231 params['routing_key'] is None):1232 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_patch3`") # noqa: E5011233 collection_formats = {}1234 path_params = {}1235 if 'routing_key' in params:1236 path_params['routingKey'] = params['routing_key'] # noqa: E5011237 query_params = []1238 if 'all_request_params' in params:1239 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E5011240 header_params = {}1241 if 'request_headers' in params:1242 header_params['requestHeaders'] = params['request_headers'] # noqa: E5011243 form_params = []1244 local_var_files = {}1245 body_params = None1246 if 'body' in params:1247 body_params = params['body']1248 # HTTP header `Accept`1249 header_params['Accept'] = self.api_client.select_header_accept(1250 ['*/*']) # noqa: E5011251 # HTTP header `Content-Type`1252 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E5011253 ['application/json']) # noqa: E5011254 # Authentication setting1255 auth_settings = ['X-Authorization'] # noqa: E5011256 return self.api_client.call_api(1257 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'PATCH',1258 path_params,1259 query_params,1260 header_params,1261 body=body_params,1262 post_params=form_params,1263 files=local_var_files,1264 response_type='DeferredResultResponseEntity', # noqa: E5011265 auth_settings=auth_settings,1266 async_req=params.get('async_req'),1267 _return_http_data_only=params.get('_return_http_data_only'),1268 _preload_content=params.get('_preload_content', True),1269 _request_timeout=params.get('_request_timeout'),1270 collection_formats=collection_formats)1271 def process_request_using_post5(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011272 """processRequest # noqa: E5011273 This method makes a synchronous HTTP request by default. To make an1274 asynchronous HTTP request, please pass async_req=True1275 >>> thread = api.process_request_using_post5(body, request_headers, all_request_params, routing_key, async_req=True)1276 >>> result = thread.get()1277 :param async_req bool1278 :param str body: msg (required)1279 :param Object request_headers: requestHeaders (required)1280 :param Object all_request_params: allRequestParams (required)1281 :param str routing_key: routingKey (required)1282 :return: DeferredResultResponseEntity1283 If the method is called asynchronously,1284 returns the request thread.1285 """1286 kwargs['_return_http_data_only'] = True1287 if kwargs.get('async_req'):1288 return self.process_request_using_post5_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011289 else:1290 (data) = self.process_request_using_post5_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011291 return data1292 def process_request_using_post5_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011293 """processRequest # noqa: E5011294 This method makes a synchronous HTTP request by default. To make an1295 asynchronous HTTP request, please pass async_req=True1296 >>> thread = api.process_request_using_post5_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)1297 >>> result = thread.get()1298 :param async_req bool1299 :param str body: msg (required)1300 :param Object request_headers: requestHeaders (required)1301 :param Object all_request_params: allRequestParams (required)1302 :param str routing_key: routingKey (required)1303 :return: DeferredResultResponseEntity1304 If the method is called asynchronously,1305 returns the request thread.1306 """1307 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E5011308 all_params.append('async_req')1309 all_params.append('_return_http_data_only')1310 all_params.append('_preload_content')1311 all_params.append('_request_timeout')1312 params = locals()1313 for key, val in six.iteritems(params['kwargs']):1314 if key not in all_params:1315 raise TypeError(1316 "Got an unexpected keyword argument '%s'"1317 " to method process_request_using_post5" % key1318 )1319 params[key] = val1320 del params['kwargs']1321 # verify the required parameter 'body' is set1322 if ('body' not in params or1323 params['body'] is None):1324 raise ValueError("Missing the required parameter `body` when calling `process_request_using_post5`") # noqa: E5011325 # verify the required parameter 'request_headers' is set1326 if ('request_headers' not in params or1327 params['request_headers'] is None):1328 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_post5`") # noqa: E5011329 # verify the required parameter 'all_request_params' is set1330 if ('all_request_params' not in params or1331 params['all_request_params'] is None):1332 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_post5`") # noqa: E5011333 # verify the required parameter 'routing_key' is set1334 if ('routing_key' not in params or1335 params['routing_key'] is None):1336 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_post5`") # noqa: E5011337 collection_formats = {}1338 path_params = {}1339 if 'routing_key' in params:1340 path_params['routingKey'] = params['routing_key'] # noqa: E5011341 query_params = []1342 if 'all_request_params' in params:1343 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E5011344 header_params = {}1345 if 'request_headers' in params:1346 header_params['requestHeaders'] = params['request_headers'] # noqa: E5011347 form_params = []1348 local_var_files = {}1349 body_params = None1350 if 'body' in params:1351 body_params = params['body']1352 # HTTP header `Accept`1353 header_params['Accept'] = self.api_client.select_header_accept(1354 ['*/*']) # noqa: E5011355 # HTTP header `Content-Type`1356 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E5011357 ['application/json']) # noqa: E5011358 # Authentication setting1359 auth_settings = ['X-Authorization'] # noqa: E5011360 return self.api_client.call_api(1361 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'POST',1362 path_params,1363 query_params,1364 header_params,1365 body=body_params,1366 post_params=form_params,1367 files=local_var_files,1368 response_type='DeferredResultResponseEntity', # noqa: E5011369 auth_settings=auth_settings,1370 async_req=params.get('async_req'),1371 _return_http_data_only=params.get('_return_http_data_only'),1372 _preload_content=params.get('_preload_content', True),1373 _request_timeout=params.get('_request_timeout'),1374 collection_formats=collection_formats)1375 def process_request_using_put3(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011376 """processRequest # noqa: E5011377 This method makes a synchronous HTTP request by default. To make an1378 asynchronous HTTP request, please pass async_req=True1379 >>> thread = api.process_request_using_put3(body, request_headers, all_request_params, routing_key, async_req=True)1380 >>> result = thread.get()1381 :param async_req bool1382 :param str body: msg (required)1383 :param Object request_headers: requestHeaders (required)1384 :param Object all_request_params: allRequestParams (required)1385 :param str routing_key: routingKey (required)1386 :return: DeferredResultResponseEntity1387 If the method is called asynchronously,1388 returns the request thread.1389 """1390 kwargs['_return_http_data_only'] = True1391 if kwargs.get('async_req'):1392 return self.process_request_using_put3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011393 else:1394 (data) = self.process_request_using_put3_with_http_info(body, request_headers, all_request_params, routing_key, **kwargs) # noqa: E5011395 return data1396 def process_request_using_put3_with_http_info(self, body, request_headers, all_request_params, routing_key, **kwargs): # noqa: E5011397 """processRequest # noqa: E5011398 This method makes a synchronous HTTP request by default. To make an1399 asynchronous HTTP request, please pass async_req=True1400 >>> thread = api.process_request_using_put3_with_http_info(body, request_headers, all_request_params, routing_key, async_req=True)1401 >>> result = thread.get()1402 :param async_req bool1403 :param str body: msg (required)1404 :param Object request_headers: requestHeaders (required)1405 :param Object all_request_params: allRequestParams (required)1406 :param str routing_key: routingKey (required)1407 :return: DeferredResultResponseEntity1408 If the method is called asynchronously,1409 returns the request thread.1410 """1411 all_params = ['body', 'request_headers', 'all_request_params', 'routing_key'] # noqa: E5011412 all_params.append('async_req')1413 all_params.append('_return_http_data_only')1414 all_params.append('_preload_content')1415 all_params.append('_request_timeout')1416 params = locals()1417 for key, val in six.iteritems(params['kwargs']):1418 if key not in all_params:1419 raise TypeError(1420 "Got an unexpected keyword argument '%s'"1421 " to method process_request_using_put3" % key1422 )1423 params[key] = val1424 del params['kwargs']1425 # verify the required parameter 'body' is set1426 if ('body' not in params or1427 params['body'] is None):1428 raise ValueError("Missing the required parameter `body` when calling `process_request_using_put3`") # noqa: E5011429 # verify the required parameter 'request_headers' is set1430 if ('request_headers' not in params or1431 params['request_headers'] is None):1432 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_put3`") # noqa: E5011433 # verify the required parameter 'all_request_params' is set1434 if ('all_request_params' not in params or1435 params['all_request_params'] is None):1436 raise ValueError("Missing the required parameter `all_request_params` when calling `process_request_using_put3`") # noqa: E5011437 # verify the required parameter 'routing_key' is set1438 if ('routing_key' not in params or1439 params['routing_key'] is None):1440 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_put3`") # noqa: E5011441 collection_formats = {}1442 path_params = {}1443 if 'routing_key' in params:1444 path_params['routingKey'] = params['routing_key'] # noqa: E5011445 query_params = []1446 if 'all_request_params' in params:1447 query_params.append(('allRequestParams', params['all_request_params'])) # noqa: E5011448 header_params = {}1449 if 'request_headers' in params:1450 header_params['requestHeaders'] = params['request_headers'] # noqa: E5011451 form_params = []1452 local_var_files = {}1453 body_params = None1454 if 'body' in params:1455 body_params = params['body']1456 # HTTP header `Accept`1457 header_params['Accept'] = self.api_client.select_header_accept(1458 ['*/*']) # noqa: E5011459 # HTTP header `Content-Type`1460 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E5011461 ['application/json']) # noqa: E5011462 # Authentication setting1463 auth_settings = ['X-Authorization'] # noqa: E5011464 return self.api_client.call_api(1465 '/api/v1/integrations/thingpark/{routingKey}{?allRequestParams}', 'PUT',1466 path_params,1467 query_params,1468 header_params,1469 body=body_params,1470 post_params=form_params,1471 files=local_var_files,1472 response_type='DeferredResultResponseEntity', # noqa: E5011473 auth_settings=auth_settings,1474 async_req=params.get('async_req'),1475 _return_http_data_only=params.get('_return_http_data_only'),1476 _preload_content=params.get('_preload_content', True),1477 _request_timeout=params.get('_request_timeout'),...

Full Screen

Full Screen

t_mobile_iot_cdp_integration_controller_api.py

Source:t_mobile_iot_cdp_integration_controller_api.py Github

copy

Full Screen

1# coding: utf-82"""3 Thingsboard REST API4 For instructions how to authorize requests please visit <a href='http://thingsboard.io/docs/reference/rest-api/'>REST API documentation page</a>. # noqa: E5015 OpenAPI spec version: 2.06 Contact: info@thingsboard.io7 Generated by: https://github.com/swagger-api/swagger-codegen.git8"""9from __future__ import absolute_import10import re # noqa: F40111# python 2 and python 3 compatibility library12import six13from pyTB.api_client import ApiClient14class TMobileIotCdpIntegrationControllerApi(object):15 """NOTE: This class is auto generated by the swagger code generator program.16 Do not edit the class manually.17 Ref: https://github.com/swagger-api/swagger-codegen18 """19 def __init__(self, api_client=None):20 if api_client is None:21 api_client = ApiClient()22 self.api_client = api_client23 def process_request_using_delete2(self, body, request_headers, routing_key, **kwargs): # noqa: E50124 """processRequest # noqa: E50125 This method makes a synchronous HTTP request by default. To make an26 asynchronous HTTP request, please pass async_req=True27 >>> thread = api.process_request_using_delete2(body, request_headers, routing_key, async_req=True)28 >>> result = thread.get()29 :param async_req bool30 :param str body: msg (required)31 :param Object request_headers: requestHeaders (required)32 :param str routing_key: routingKey (required)33 :return: DeferredResultResponseEntity34 If the method is called asynchronously,35 returns the request thread.36 """37 kwargs['_return_http_data_only'] = True38 if kwargs.get('async_req'):39 return self.process_request_using_delete2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E50140 else:41 (data) = self.process_request_using_delete2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E50142 return data43 def process_request_using_delete2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E50144 """processRequest # noqa: E50145 This method makes a synchronous HTTP request by default. To make an46 asynchronous HTTP request, please pass async_req=True47 >>> thread = api.process_request_using_delete2_with_http_info(body, request_headers, routing_key, async_req=True)48 >>> result = thread.get()49 :param async_req bool50 :param str body: msg (required)51 :param Object request_headers: requestHeaders (required)52 :param str routing_key: routingKey (required)53 :return: DeferredResultResponseEntity54 If the method is called asynchronously,55 returns the request thread.56 """57 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E50158 all_params.append('async_req')59 all_params.append('_return_http_data_only')60 all_params.append('_preload_content')61 all_params.append('_request_timeout')62 params = locals()63 for key, val in six.iteritems(params['kwargs']):64 if key not in all_params:65 raise TypeError(66 "Got an unexpected keyword argument '%s'"67 " to method process_request_using_delete2" % key68 )69 params[key] = val70 del params['kwargs']71 # verify the required parameter 'body' is set72 if ('body' not in params or73 params['body'] is None):74 raise ValueError("Missing the required parameter `body` when calling `process_request_using_delete2`") # noqa: E50175 # verify the required parameter 'request_headers' is set76 if ('request_headers' not in params or77 params['request_headers'] is None):78 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_delete2`") # noqa: E50179 # verify the required parameter 'routing_key' is set80 if ('routing_key' not in params or81 params['routing_key'] is None):82 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_delete2`") # noqa: E50183 collection_formats = {}84 path_params = {}85 if 'routing_key' in params:86 path_params['routingKey'] = params['routing_key'] # noqa: E50187 query_params = []88 header_params = {}89 if 'request_headers' in params:90 header_params['requestHeaders'] = params['request_headers'] # noqa: E50191 form_params = []92 local_var_files = {}93 body_params = None94 if 'body' in params:95 body_params = params['body']96 # HTTP header `Accept`97 header_params['Accept'] = self.api_client.select_header_accept(98 ['*/*']) # noqa: E50199 # HTTP header `Content-Type`100 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501101 ['application/json']) # noqa: E501102 # Authentication setting103 auth_settings = ['X-Authorization'] # noqa: E501104 return self.api_client.call_api(105 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'DELETE',106 path_params,107 query_params,108 header_params,109 body=body_params,110 post_params=form_params,111 files=local_var_files,112 response_type='DeferredResultResponseEntity', # noqa: E501113 auth_settings=auth_settings,114 async_req=params.get('async_req'),115 _return_http_data_only=params.get('_return_http_data_only'),116 _preload_content=params.get('_preload_content', True),117 _request_timeout=params.get('_request_timeout'),118 collection_formats=collection_formats)119 def process_request_using_get2(self, body, request_headers, routing_key, **kwargs): # noqa: E501120 """processRequest # noqa: E501121 This method makes a synchronous HTTP request by default. To make an122 asynchronous HTTP request, please pass async_req=True123 >>> thread = api.process_request_using_get2(body, request_headers, routing_key, async_req=True)124 >>> result = thread.get()125 :param async_req bool126 :param str body: msg (required)127 :param Object request_headers: requestHeaders (required)128 :param str routing_key: routingKey (required)129 :return: DeferredResultResponseEntity130 If the method is called asynchronously,131 returns the request thread.132 """133 kwargs['_return_http_data_only'] = True134 if kwargs.get('async_req'):135 return self.process_request_using_get2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501136 else:137 (data) = self.process_request_using_get2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501138 return data139 def process_request_using_get2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501140 """processRequest # noqa: E501141 This method makes a synchronous HTTP request by default. To make an142 asynchronous HTTP request, please pass async_req=True143 >>> thread = api.process_request_using_get2_with_http_info(body, request_headers, routing_key, async_req=True)144 >>> result = thread.get()145 :param async_req bool146 :param str body: msg (required)147 :param Object request_headers: requestHeaders (required)148 :param str routing_key: routingKey (required)149 :return: DeferredResultResponseEntity150 If the method is called asynchronously,151 returns the request thread.152 """153 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501154 all_params.append('async_req')155 all_params.append('_return_http_data_only')156 all_params.append('_preload_content')157 all_params.append('_request_timeout')158 params = locals()159 for key, val in six.iteritems(params['kwargs']):160 if key not in all_params:161 raise TypeError(162 "Got an unexpected keyword argument '%s'"163 " to method process_request_using_get2" % key164 )165 params[key] = val166 del params['kwargs']167 # verify the required parameter 'body' is set168 if ('body' not in params or169 params['body'] is None):170 raise ValueError("Missing the required parameter `body` when calling `process_request_using_get2`") # noqa: E501171 # verify the required parameter 'request_headers' is set172 if ('request_headers' not in params or173 params['request_headers'] is None):174 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_get2`") # noqa: E501175 # verify the required parameter 'routing_key' is set176 if ('routing_key' not in params or177 params['routing_key'] is None):178 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_get2`") # noqa: E501179 collection_formats = {}180 path_params = {}181 if 'routing_key' in params:182 path_params['routingKey'] = params['routing_key'] # noqa: E501183 query_params = []184 header_params = {}185 if 'request_headers' in params:186 header_params['requestHeaders'] = params['request_headers'] # noqa: E501187 form_params = []188 local_var_files = {}189 body_params = None190 if 'body' in params:191 body_params = params['body']192 # HTTP header `Accept`193 header_params['Accept'] = self.api_client.select_header_accept(194 ['*/*']) # noqa: E501195 # HTTP header `Content-Type`196 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501197 ['application/json']) # noqa: E501198 # Authentication setting199 auth_settings = ['X-Authorization'] # noqa: E501200 return self.api_client.call_api(201 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'GET',202 path_params,203 query_params,204 header_params,205 body=body_params,206 post_params=form_params,207 files=local_var_files,208 response_type='DeferredResultResponseEntity', # noqa: E501209 auth_settings=auth_settings,210 async_req=params.get('async_req'),211 _return_http_data_only=params.get('_return_http_data_only'),212 _preload_content=params.get('_preload_content', True),213 _request_timeout=params.get('_request_timeout'),214 collection_formats=collection_formats)215 def process_request_using_head2(self, body, request_headers, routing_key, **kwargs): # noqa: E501216 """processRequest # noqa: E501217 This method makes a synchronous HTTP request by default. To make an218 asynchronous HTTP request, please pass async_req=True219 >>> thread = api.process_request_using_head2(body, request_headers, routing_key, async_req=True)220 >>> result = thread.get()221 :param async_req bool222 :param str body: msg (required)223 :param Object request_headers: requestHeaders (required)224 :param str routing_key: routingKey (required)225 :return: DeferredResultResponseEntity226 If the method is called asynchronously,227 returns the request thread.228 """229 kwargs['_return_http_data_only'] = True230 if kwargs.get('async_req'):231 return self.process_request_using_head2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501232 else:233 (data) = self.process_request_using_head2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501234 return data235 def process_request_using_head2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501236 """processRequest # noqa: E501237 This method makes a synchronous HTTP request by default. To make an238 asynchronous HTTP request, please pass async_req=True239 >>> thread = api.process_request_using_head2_with_http_info(body, request_headers, routing_key, async_req=True)240 >>> result = thread.get()241 :param async_req bool242 :param str body: msg (required)243 :param Object request_headers: requestHeaders (required)244 :param str routing_key: routingKey (required)245 :return: DeferredResultResponseEntity246 If the method is called asynchronously,247 returns the request thread.248 """249 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501250 all_params.append('async_req')251 all_params.append('_return_http_data_only')252 all_params.append('_preload_content')253 all_params.append('_request_timeout')254 params = locals()255 for key, val in six.iteritems(params['kwargs']):256 if key not in all_params:257 raise TypeError(258 "Got an unexpected keyword argument '%s'"259 " to method process_request_using_head2" % key260 )261 params[key] = val262 del params['kwargs']263 # verify the required parameter 'body' is set264 if ('body' not in params or265 params['body'] is None):266 raise ValueError("Missing the required parameter `body` when calling `process_request_using_head2`") # noqa: E501267 # verify the required parameter 'request_headers' is set268 if ('request_headers' not in params or269 params['request_headers'] is None):270 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_head2`") # noqa: E501271 # verify the required parameter 'routing_key' is set272 if ('routing_key' not in params or273 params['routing_key'] is None):274 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_head2`") # noqa: E501275 collection_formats = {}276 path_params = {}277 if 'routing_key' in params:278 path_params['routingKey'] = params['routing_key'] # noqa: E501279 query_params = []280 header_params = {}281 if 'request_headers' in params:282 header_params['requestHeaders'] = params['request_headers'] # noqa: E501283 form_params = []284 local_var_files = {}285 body_params = None286 if 'body' in params:287 body_params = params['body']288 # HTTP header `Accept`289 header_params['Accept'] = self.api_client.select_header_accept(290 ['*/*']) # noqa: E501291 # HTTP header `Content-Type`292 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501293 ['application/json']) # noqa: E501294 # Authentication setting295 auth_settings = ['X-Authorization'] # noqa: E501296 return self.api_client.call_api(297 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'HEAD',298 path_params,299 query_params,300 header_params,301 body=body_params,302 post_params=form_params,303 files=local_var_files,304 response_type='DeferredResultResponseEntity', # noqa: E501305 auth_settings=auth_settings,306 async_req=params.get('async_req'),307 _return_http_data_only=params.get('_return_http_data_only'),308 _preload_content=params.get('_preload_content', True),309 _request_timeout=params.get('_request_timeout'),310 collection_formats=collection_formats)311 def process_request_using_options2(self, body, request_headers, routing_key, **kwargs): # noqa: E501312 """processRequest # noqa: E501313 This method makes a synchronous HTTP request by default. To make an314 asynchronous HTTP request, please pass async_req=True315 >>> thread = api.process_request_using_options2(body, request_headers, routing_key, async_req=True)316 >>> result = thread.get()317 :param async_req bool318 :param str body: msg (required)319 :param Object request_headers: requestHeaders (required)320 :param str routing_key: routingKey (required)321 :return: DeferredResultResponseEntity322 If the method is called asynchronously,323 returns the request thread.324 """325 kwargs['_return_http_data_only'] = True326 if kwargs.get('async_req'):327 return self.process_request_using_options2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501328 else:329 (data) = self.process_request_using_options2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501330 return data331 def process_request_using_options2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501332 """processRequest # noqa: E501333 This method makes a synchronous HTTP request by default. To make an334 asynchronous HTTP request, please pass async_req=True335 >>> thread = api.process_request_using_options2_with_http_info(body, request_headers, routing_key, async_req=True)336 >>> result = thread.get()337 :param async_req bool338 :param str body: msg (required)339 :param Object request_headers: requestHeaders (required)340 :param str routing_key: routingKey (required)341 :return: DeferredResultResponseEntity342 If the method is called asynchronously,343 returns the request thread.344 """345 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501346 all_params.append('async_req')347 all_params.append('_return_http_data_only')348 all_params.append('_preload_content')349 all_params.append('_request_timeout')350 params = locals()351 for key, val in six.iteritems(params['kwargs']):352 if key not in all_params:353 raise TypeError(354 "Got an unexpected keyword argument '%s'"355 " to method process_request_using_options2" % key356 )357 params[key] = val358 del params['kwargs']359 # verify the required parameter 'body' is set360 if ('body' not in params or361 params['body'] is None):362 raise ValueError("Missing the required parameter `body` when calling `process_request_using_options2`") # noqa: E501363 # verify the required parameter 'request_headers' is set364 if ('request_headers' not in params or365 params['request_headers'] is None):366 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_options2`") # noqa: E501367 # verify the required parameter 'routing_key' is set368 if ('routing_key' not in params or369 params['routing_key'] is None):370 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_options2`") # noqa: E501371 collection_formats = {}372 path_params = {}373 if 'routing_key' in params:374 path_params['routingKey'] = params['routing_key'] # noqa: E501375 query_params = []376 header_params = {}377 if 'request_headers' in params:378 header_params['requestHeaders'] = params['request_headers'] # noqa: E501379 form_params = []380 local_var_files = {}381 body_params = None382 if 'body' in params:383 body_params = params['body']384 # HTTP header `Accept`385 header_params['Accept'] = self.api_client.select_header_accept(386 ['*/*']) # noqa: E501387 # HTTP header `Content-Type`388 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501389 ['application/json']) # noqa: E501390 # Authentication setting391 auth_settings = ['X-Authorization'] # noqa: E501392 return self.api_client.call_api(393 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'OPTIONS',394 path_params,395 query_params,396 header_params,397 body=body_params,398 post_params=form_params,399 files=local_var_files,400 response_type='DeferredResultResponseEntity', # noqa: E501401 auth_settings=auth_settings,402 async_req=params.get('async_req'),403 _return_http_data_only=params.get('_return_http_data_only'),404 _preload_content=params.get('_preload_content', True),405 _request_timeout=params.get('_request_timeout'),406 collection_formats=collection_formats)407 def process_request_using_patch2(self, body, request_headers, routing_key, **kwargs): # noqa: E501408 """processRequest # noqa: E501409 This method makes a synchronous HTTP request by default. To make an410 asynchronous HTTP request, please pass async_req=True411 >>> thread = api.process_request_using_patch2(body, request_headers, routing_key, async_req=True)412 >>> result = thread.get()413 :param async_req bool414 :param str body: msg (required)415 :param Object request_headers: requestHeaders (required)416 :param str routing_key: routingKey (required)417 :return: DeferredResultResponseEntity418 If the method is called asynchronously,419 returns the request thread.420 """421 kwargs['_return_http_data_only'] = True422 if kwargs.get('async_req'):423 return self.process_request_using_patch2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501424 else:425 (data) = self.process_request_using_patch2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501426 return data427 def process_request_using_patch2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501428 """processRequest # noqa: E501429 This method makes a synchronous HTTP request by default. To make an430 asynchronous HTTP request, please pass async_req=True431 >>> thread = api.process_request_using_patch2_with_http_info(body, request_headers, routing_key, async_req=True)432 >>> result = thread.get()433 :param async_req bool434 :param str body: msg (required)435 :param Object request_headers: requestHeaders (required)436 :param str routing_key: routingKey (required)437 :return: DeferredResultResponseEntity438 If the method is called asynchronously,439 returns the request thread.440 """441 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501442 all_params.append('async_req')443 all_params.append('_return_http_data_only')444 all_params.append('_preload_content')445 all_params.append('_request_timeout')446 params = locals()447 for key, val in six.iteritems(params['kwargs']):448 if key not in all_params:449 raise TypeError(450 "Got an unexpected keyword argument '%s'"451 " to method process_request_using_patch2" % key452 )453 params[key] = val454 del params['kwargs']455 # verify the required parameter 'body' is set456 if ('body' not in params or457 params['body'] is None):458 raise ValueError("Missing the required parameter `body` when calling `process_request_using_patch2`") # noqa: E501459 # verify the required parameter 'request_headers' is set460 if ('request_headers' not in params or461 params['request_headers'] is None):462 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_patch2`") # noqa: E501463 # verify the required parameter 'routing_key' is set464 if ('routing_key' not in params or465 params['routing_key'] is None):466 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_patch2`") # noqa: E501467 collection_formats = {}468 path_params = {}469 if 'routing_key' in params:470 path_params['routingKey'] = params['routing_key'] # noqa: E501471 query_params = []472 header_params = {}473 if 'request_headers' in params:474 header_params['requestHeaders'] = params['request_headers'] # noqa: E501475 form_params = []476 local_var_files = {}477 body_params = None478 if 'body' in params:479 body_params = params['body']480 # HTTP header `Accept`481 header_params['Accept'] = self.api_client.select_header_accept(482 ['*/*']) # noqa: E501483 # HTTP header `Content-Type`484 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501485 ['application/json']) # noqa: E501486 # Authentication setting487 auth_settings = ['X-Authorization'] # noqa: E501488 return self.api_client.call_api(489 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'PATCH',490 path_params,491 query_params,492 header_params,493 body=body_params,494 post_params=form_params,495 files=local_var_files,496 response_type='DeferredResultResponseEntity', # noqa: E501497 auth_settings=auth_settings,498 async_req=params.get('async_req'),499 _return_http_data_only=params.get('_return_http_data_only'),500 _preload_content=params.get('_preload_content', True),501 _request_timeout=params.get('_request_timeout'),502 collection_formats=collection_formats)503 def process_request_using_post4(self, body, request_headers, routing_key, **kwargs): # noqa: E501504 """processRequest # noqa: E501505 This method makes a synchronous HTTP request by default. To make an506 asynchronous HTTP request, please pass async_req=True507 >>> thread = api.process_request_using_post4(body, request_headers, routing_key, async_req=True)508 >>> result = thread.get()509 :param async_req bool510 :param str body: msg (required)511 :param Object request_headers: requestHeaders (required)512 :param str routing_key: routingKey (required)513 :return: DeferredResultResponseEntity514 If the method is called asynchronously,515 returns the request thread.516 """517 kwargs['_return_http_data_only'] = True518 if kwargs.get('async_req'):519 return self.process_request_using_post4_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501520 else:521 (data) = self.process_request_using_post4_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501522 return data523 def process_request_using_post4_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501524 """processRequest # noqa: E501525 This method makes a synchronous HTTP request by default. To make an526 asynchronous HTTP request, please pass async_req=True527 >>> thread = api.process_request_using_post4_with_http_info(body, request_headers, routing_key, async_req=True)528 >>> result = thread.get()529 :param async_req bool530 :param str body: msg (required)531 :param Object request_headers: requestHeaders (required)532 :param str routing_key: routingKey (required)533 :return: DeferredResultResponseEntity534 If the method is called asynchronously,535 returns the request thread.536 """537 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501538 all_params.append('async_req')539 all_params.append('_return_http_data_only')540 all_params.append('_preload_content')541 all_params.append('_request_timeout')542 params = locals()543 for key, val in six.iteritems(params['kwargs']):544 if key not in all_params:545 raise TypeError(546 "Got an unexpected keyword argument '%s'"547 " to method process_request_using_post4" % key548 )549 params[key] = val550 del params['kwargs']551 # verify the required parameter 'body' is set552 if ('body' not in params or553 params['body'] is None):554 raise ValueError("Missing the required parameter `body` when calling `process_request_using_post4`") # noqa: E501555 # verify the required parameter 'request_headers' is set556 if ('request_headers' not in params or557 params['request_headers'] is None):558 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_post4`") # noqa: E501559 # verify the required parameter 'routing_key' is set560 if ('routing_key' not in params or561 params['routing_key'] is None):562 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_post4`") # noqa: E501563 collection_formats = {}564 path_params = {}565 if 'routing_key' in params:566 path_params['routingKey'] = params['routing_key'] # noqa: E501567 query_params = []568 header_params = {}569 if 'request_headers' in params:570 header_params['requestHeaders'] = params['request_headers'] # noqa: E501571 form_params = []572 local_var_files = {}573 body_params = None574 if 'body' in params:575 body_params = params['body']576 # HTTP header `Accept`577 header_params['Accept'] = self.api_client.select_header_accept(578 ['*/*']) # noqa: E501579 # HTTP header `Content-Type`580 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501581 ['application/json']) # noqa: E501582 # Authentication setting583 auth_settings = ['X-Authorization'] # noqa: E501584 return self.api_client.call_api(585 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'POST',586 path_params,587 query_params,588 header_params,589 body=body_params,590 post_params=form_params,591 files=local_var_files,592 response_type='DeferredResultResponseEntity', # noqa: E501593 auth_settings=auth_settings,594 async_req=params.get('async_req'),595 _return_http_data_only=params.get('_return_http_data_only'),596 _preload_content=params.get('_preload_content', True),597 _request_timeout=params.get('_request_timeout'),598 collection_formats=collection_formats)599 def process_request_using_put2(self, body, request_headers, routing_key, **kwargs): # noqa: E501600 """processRequest # noqa: E501601 This method makes a synchronous HTTP request by default. To make an602 asynchronous HTTP request, please pass async_req=True603 >>> thread = api.process_request_using_put2(body, request_headers, routing_key, async_req=True)604 >>> result = thread.get()605 :param async_req bool606 :param str body: msg (required)607 :param Object request_headers: requestHeaders (required)608 :param str routing_key: routingKey (required)609 :return: DeferredResultResponseEntity610 If the method is called asynchronously,611 returns the request thread.612 """613 kwargs['_return_http_data_only'] = True614 if kwargs.get('async_req'):615 return self.process_request_using_put2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501616 else:617 (data) = self.process_request_using_put2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501618 return data619 def process_request_using_put2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501620 """processRequest # noqa: E501621 This method makes a synchronous HTTP request by default. To make an622 asynchronous HTTP request, please pass async_req=True623 >>> thread = api.process_request_using_put2_with_http_info(body, request_headers, routing_key, async_req=True)624 >>> result = thread.get()625 :param async_req bool626 :param str body: msg (required)627 :param Object request_headers: requestHeaders (required)628 :param str routing_key: routingKey (required)629 :return: DeferredResultResponseEntity630 If the method is called asynchronously,631 returns the request thread.632 """633 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501634 all_params.append('async_req')635 all_params.append('_return_http_data_only')636 all_params.append('_preload_content')637 all_params.append('_request_timeout')638 params = locals()639 for key, val in six.iteritems(params['kwargs']):640 if key not in all_params:641 raise TypeError(642 "Got an unexpected keyword argument '%s'"643 " to method process_request_using_put2" % key644 )645 params[key] = val646 del params['kwargs']647 # verify the required parameter 'body' is set648 if ('body' not in params or649 params['body'] is None):650 raise ValueError("Missing the required parameter `body` when calling `process_request_using_put2`") # noqa: E501651 # verify the required parameter 'request_headers' is set652 if ('request_headers' not in params or653 params['request_headers'] is None):654 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_put2`") # noqa: E501655 # verify the required parameter 'routing_key' is set656 if ('routing_key' not in params or657 params['routing_key'] is None):658 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_put2`") # noqa: E501659 collection_formats = {}660 path_params = {}661 if 'routing_key' in params:662 path_params['routingKey'] = params['routing_key'] # noqa: E501663 query_params = []664 header_params = {}665 if 'request_headers' in params:666 header_params['requestHeaders'] = params['request_headers'] # noqa: E501667 form_params = []668 local_var_files = {}669 body_params = None670 if 'body' in params:671 body_params = params['body']672 # HTTP header `Accept`673 header_params['Accept'] = self.api_client.select_header_accept(674 ['*/*']) # noqa: E501675 # HTTP header `Content-Type`676 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501677 ['application/json']) # noqa: E501678 # Authentication setting679 auth_settings = ['X-Authorization'] # noqa: E501680 return self.api_client.call_api(681 '/api/v1/integrations/tmobile_iot_cdp/{routingKey}', 'PUT',682 path_params,683 query_params,684 header_params,685 body=body_params,686 post_params=form_params,687 files=local_var_files,688 response_type='DeferredResultResponseEntity', # noqa: E501689 auth_settings=auth_settings,690 async_req=params.get('async_req'),691 _return_http_data_only=params.get('_return_http_data_only'),692 _preload_content=params.get('_preload_content', True),693 _request_timeout=params.get('_request_timeout'),...

Full Screen

Full Screen

sig_fox_integration_controller_api.py

Source:sig_fox_integration_controller_api.py Github

copy

Full Screen

1# coding: utf-82"""3 Thingsboard REST API4 For instructions how to authorize requests please visit <a href='http://thingsboard.io/docs/reference/rest-api/'>REST API documentation page</a>. # noqa: E5015 OpenAPI spec version: 2.06 Contact: info@thingsboard.io7 Generated by: https://github.com/swagger-api/swagger-codegen.git8"""9from __future__ import absolute_import10import re # noqa: F40111# python 2 and python 3 compatibility library12import six13from pyTB.api_client import ApiClient14class SigFoxIntegrationControllerApi(object):15 """NOTE: This class is auto generated by the swagger code generator program.16 Do not edit the class manually.17 Ref: https://github.com/swagger-api/swagger-codegen18 """19 def __init__(self, api_client=None):20 if api_client is None:21 api_client = ApiClient()22 self.api_client = api_client23 def process_request_using_delete1(self, body, request_headers, routing_key, **kwargs): # noqa: E50124 """processRequest # noqa: E50125 This method makes a synchronous HTTP request by default. To make an26 asynchronous HTTP request, please pass async_req=True27 >>> thread = api.process_request_using_delete1(body, request_headers, routing_key, async_req=True)28 >>> result = thread.get()29 :param async_req bool30 :param str body: msg (required)31 :param Object request_headers: requestHeaders (required)32 :param str routing_key: routingKey (required)33 :return: DeferredResultResponseEntity34 If the method is called asynchronously,35 returns the request thread.36 """37 kwargs['_return_http_data_only'] = True38 if kwargs.get('async_req'):39 return self.process_request_using_delete1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E50140 else:41 (data) = self.process_request_using_delete1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E50142 return data43 def process_request_using_delete1_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E50144 """processRequest # noqa: E50145 This method makes a synchronous HTTP request by default. To make an46 asynchronous HTTP request, please pass async_req=True47 >>> thread = api.process_request_using_delete1_with_http_info(body, request_headers, routing_key, async_req=True)48 >>> result = thread.get()49 :param async_req bool50 :param str body: msg (required)51 :param Object request_headers: requestHeaders (required)52 :param str routing_key: routingKey (required)53 :return: DeferredResultResponseEntity54 If the method is called asynchronously,55 returns the request thread.56 """57 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E50158 all_params.append('async_req')59 all_params.append('_return_http_data_only')60 all_params.append('_preload_content')61 all_params.append('_request_timeout')62 params = locals()63 for key, val in six.iteritems(params['kwargs']):64 if key not in all_params:65 raise TypeError(66 "Got an unexpected keyword argument '%s'"67 " to method process_request_using_delete1" % key68 )69 params[key] = val70 del params['kwargs']71 # verify the required parameter 'body' is set72 if ('body' not in params or73 params['body'] is None):74 raise ValueError("Missing the required parameter `body` when calling `process_request_using_delete1`") # noqa: E50175 # verify the required parameter 'request_headers' is set76 if ('request_headers' not in params or77 params['request_headers'] is None):78 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_delete1`") # noqa: E50179 # verify the required parameter 'routing_key' is set80 if ('routing_key' not in params or81 params['routing_key'] is None):82 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_delete1`") # noqa: E50183 collection_formats = {}84 path_params = {}85 if 'routing_key' in params:86 path_params['routingKey'] = params['routing_key'] # noqa: E50187 query_params = []88 header_params = {}89 if 'request_headers' in params:90 header_params['requestHeaders'] = params['request_headers'] # noqa: E50191 form_params = []92 local_var_files = {}93 body_params = None94 if 'body' in params:95 body_params = params['body']96 # HTTP header `Accept`97 header_params['Accept'] = self.api_client.select_header_accept(98 ['*/*']) # noqa: E50199 # HTTP header `Content-Type`100 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501101 ['application/json']) # noqa: E501102 # Authentication setting103 auth_settings = ['X-Authorization'] # noqa: E501104 return self.api_client.call_api(105 '/api/v1/integrations/sigfox/{routingKey}', 'DELETE',106 path_params,107 query_params,108 header_params,109 body=body_params,110 post_params=form_params,111 files=local_var_files,112 response_type='DeferredResultResponseEntity', # noqa: E501113 auth_settings=auth_settings,114 async_req=params.get('async_req'),115 _return_http_data_only=params.get('_return_http_data_only'),116 _preload_content=params.get('_preload_content', True),117 _request_timeout=params.get('_request_timeout'),118 collection_formats=collection_formats)119 def process_request_using_get1(self, body, request_headers, routing_key, **kwargs): # noqa: E501120 """processRequest # noqa: E501121 This method makes a synchronous HTTP request by default. To make an122 asynchronous HTTP request, please pass async_req=True123 >>> thread = api.process_request_using_get1(body, request_headers, routing_key, async_req=True)124 >>> result = thread.get()125 :param async_req bool126 :param str body: msg (required)127 :param Object request_headers: requestHeaders (required)128 :param str routing_key: routingKey (required)129 :return: DeferredResultResponseEntity130 If the method is called asynchronously,131 returns the request thread.132 """133 kwargs['_return_http_data_only'] = True134 if kwargs.get('async_req'):135 return self.process_request_using_get1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501136 else:137 (data) = self.process_request_using_get1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501138 return data139 def process_request_using_get1_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501140 """processRequest # noqa: E501141 This method makes a synchronous HTTP request by default. To make an142 asynchronous HTTP request, please pass async_req=True143 >>> thread = api.process_request_using_get1_with_http_info(body, request_headers, routing_key, async_req=True)144 >>> result = thread.get()145 :param async_req bool146 :param str body: msg (required)147 :param Object request_headers: requestHeaders (required)148 :param str routing_key: routingKey (required)149 :return: DeferredResultResponseEntity150 If the method is called asynchronously,151 returns the request thread.152 """153 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501154 all_params.append('async_req')155 all_params.append('_return_http_data_only')156 all_params.append('_preload_content')157 all_params.append('_request_timeout')158 params = locals()159 for key, val in six.iteritems(params['kwargs']):160 if key not in all_params:161 raise TypeError(162 "Got an unexpected keyword argument '%s'"163 " to method process_request_using_get1" % key164 )165 params[key] = val166 del params['kwargs']167 # verify the required parameter 'body' is set168 if ('body' not in params or169 params['body'] is None):170 raise ValueError("Missing the required parameter `body` when calling `process_request_using_get1`") # noqa: E501171 # verify the required parameter 'request_headers' is set172 if ('request_headers' not in params or173 params['request_headers'] is None):174 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_get1`") # noqa: E501175 # verify the required parameter 'routing_key' is set176 if ('routing_key' not in params or177 params['routing_key'] is None):178 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_get1`") # noqa: E501179 collection_formats = {}180 path_params = {}181 if 'routing_key' in params:182 path_params['routingKey'] = params['routing_key'] # noqa: E501183 query_params = []184 header_params = {}185 if 'request_headers' in params:186 header_params['requestHeaders'] = params['request_headers'] # noqa: E501187 form_params = []188 local_var_files = {}189 body_params = None190 if 'body' in params:191 body_params = params['body']192 # HTTP header `Accept`193 header_params['Accept'] = self.api_client.select_header_accept(194 ['*/*']) # noqa: E501195 # HTTP header `Content-Type`196 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501197 ['application/json']) # noqa: E501198 # Authentication setting199 auth_settings = ['X-Authorization'] # noqa: E501200 return self.api_client.call_api(201 '/api/v1/integrations/sigfox/{routingKey}', 'GET',202 path_params,203 query_params,204 header_params,205 body=body_params,206 post_params=form_params,207 files=local_var_files,208 response_type='DeferredResultResponseEntity', # noqa: E501209 auth_settings=auth_settings,210 async_req=params.get('async_req'),211 _return_http_data_only=params.get('_return_http_data_only'),212 _preload_content=params.get('_preload_content', True),213 _request_timeout=params.get('_request_timeout'),214 collection_formats=collection_formats)215 def process_request_using_head1(self, body, request_headers, routing_key, **kwargs): # noqa: E501216 """processRequest # noqa: E501217 This method makes a synchronous HTTP request by default. To make an218 asynchronous HTTP request, please pass async_req=True219 >>> thread = api.process_request_using_head1(body, request_headers, routing_key, async_req=True)220 >>> result = thread.get()221 :param async_req bool222 :param str body: msg (required)223 :param Object request_headers: requestHeaders (required)224 :param str routing_key: routingKey (required)225 :return: DeferredResultResponseEntity226 If the method is called asynchronously,227 returns the request thread.228 """229 kwargs['_return_http_data_only'] = True230 if kwargs.get('async_req'):231 return self.process_request_using_head1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501232 else:233 (data) = self.process_request_using_head1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501234 return data235 def process_request_using_head1_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501236 """processRequest # noqa: E501237 This method makes a synchronous HTTP request by default. To make an238 asynchronous HTTP request, please pass async_req=True239 >>> thread = api.process_request_using_head1_with_http_info(body, request_headers, routing_key, async_req=True)240 >>> result = thread.get()241 :param async_req bool242 :param str body: msg (required)243 :param Object request_headers: requestHeaders (required)244 :param str routing_key: routingKey (required)245 :return: DeferredResultResponseEntity246 If the method is called asynchronously,247 returns the request thread.248 """249 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501250 all_params.append('async_req')251 all_params.append('_return_http_data_only')252 all_params.append('_preload_content')253 all_params.append('_request_timeout')254 params = locals()255 for key, val in six.iteritems(params['kwargs']):256 if key not in all_params:257 raise TypeError(258 "Got an unexpected keyword argument '%s'"259 " to method process_request_using_head1" % key260 )261 params[key] = val262 del params['kwargs']263 # verify the required parameter 'body' is set264 if ('body' not in params or265 params['body'] is None):266 raise ValueError("Missing the required parameter `body` when calling `process_request_using_head1`") # noqa: E501267 # verify the required parameter 'request_headers' is set268 if ('request_headers' not in params or269 params['request_headers'] is None):270 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_head1`") # noqa: E501271 # verify the required parameter 'routing_key' is set272 if ('routing_key' not in params or273 params['routing_key'] is None):274 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_head1`") # noqa: E501275 collection_formats = {}276 path_params = {}277 if 'routing_key' in params:278 path_params['routingKey'] = params['routing_key'] # noqa: E501279 query_params = []280 header_params = {}281 if 'request_headers' in params:282 header_params['requestHeaders'] = params['request_headers'] # noqa: E501283 form_params = []284 local_var_files = {}285 body_params = None286 if 'body' in params:287 body_params = params['body']288 # HTTP header `Accept`289 header_params['Accept'] = self.api_client.select_header_accept(290 ['*/*']) # noqa: E501291 # HTTP header `Content-Type`292 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501293 ['application/json']) # noqa: E501294 # Authentication setting295 auth_settings = ['X-Authorization'] # noqa: E501296 return self.api_client.call_api(297 '/api/v1/integrations/sigfox/{routingKey}', 'HEAD',298 path_params,299 query_params,300 header_params,301 body=body_params,302 post_params=form_params,303 files=local_var_files,304 response_type='DeferredResultResponseEntity', # noqa: E501305 auth_settings=auth_settings,306 async_req=params.get('async_req'),307 _return_http_data_only=params.get('_return_http_data_only'),308 _preload_content=params.get('_preload_content', True),309 _request_timeout=params.get('_request_timeout'),310 collection_formats=collection_formats)311 def process_request_using_options1(self, body, request_headers, routing_key, **kwargs): # noqa: E501312 """processRequest # noqa: E501313 This method makes a synchronous HTTP request by default. To make an314 asynchronous HTTP request, please pass async_req=True315 >>> thread = api.process_request_using_options1(body, request_headers, routing_key, async_req=True)316 >>> result = thread.get()317 :param async_req bool318 :param str body: msg (required)319 :param Object request_headers: requestHeaders (required)320 :param str routing_key: routingKey (required)321 :return: DeferredResultResponseEntity322 If the method is called asynchronously,323 returns the request thread.324 """325 kwargs['_return_http_data_only'] = True326 if kwargs.get('async_req'):327 return self.process_request_using_options1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501328 else:329 (data) = self.process_request_using_options1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501330 return data331 def process_request_using_options1_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501332 """processRequest # noqa: E501333 This method makes a synchronous HTTP request by default. To make an334 asynchronous HTTP request, please pass async_req=True335 >>> thread = api.process_request_using_options1_with_http_info(body, request_headers, routing_key, async_req=True)336 >>> result = thread.get()337 :param async_req bool338 :param str body: msg (required)339 :param Object request_headers: requestHeaders (required)340 :param str routing_key: routingKey (required)341 :return: DeferredResultResponseEntity342 If the method is called asynchronously,343 returns the request thread.344 """345 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501346 all_params.append('async_req')347 all_params.append('_return_http_data_only')348 all_params.append('_preload_content')349 all_params.append('_request_timeout')350 params = locals()351 for key, val in six.iteritems(params['kwargs']):352 if key not in all_params:353 raise TypeError(354 "Got an unexpected keyword argument '%s'"355 " to method process_request_using_options1" % key356 )357 params[key] = val358 del params['kwargs']359 # verify the required parameter 'body' is set360 if ('body' not in params or361 params['body'] is None):362 raise ValueError("Missing the required parameter `body` when calling `process_request_using_options1`") # noqa: E501363 # verify the required parameter 'request_headers' is set364 if ('request_headers' not in params or365 params['request_headers'] is None):366 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_options1`") # noqa: E501367 # verify the required parameter 'routing_key' is set368 if ('routing_key' not in params or369 params['routing_key'] is None):370 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_options1`") # noqa: E501371 collection_formats = {}372 path_params = {}373 if 'routing_key' in params:374 path_params['routingKey'] = params['routing_key'] # noqa: E501375 query_params = []376 header_params = {}377 if 'request_headers' in params:378 header_params['requestHeaders'] = params['request_headers'] # noqa: E501379 form_params = []380 local_var_files = {}381 body_params = None382 if 'body' in params:383 body_params = params['body']384 # HTTP header `Accept`385 header_params['Accept'] = self.api_client.select_header_accept(386 ['*/*']) # noqa: E501387 # HTTP header `Content-Type`388 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501389 ['application/json']) # noqa: E501390 # Authentication setting391 auth_settings = ['X-Authorization'] # noqa: E501392 return self.api_client.call_api(393 '/api/v1/integrations/sigfox/{routingKey}', 'OPTIONS',394 path_params,395 query_params,396 header_params,397 body=body_params,398 post_params=form_params,399 files=local_var_files,400 response_type='DeferredResultResponseEntity', # noqa: E501401 auth_settings=auth_settings,402 async_req=params.get('async_req'),403 _return_http_data_only=params.get('_return_http_data_only'),404 _preload_content=params.get('_preload_content', True),405 _request_timeout=params.get('_request_timeout'),406 collection_formats=collection_formats)407 def process_request_using_patch1(self, body, request_headers, routing_key, **kwargs): # noqa: E501408 """processRequest # noqa: E501409 This method makes a synchronous HTTP request by default. To make an410 asynchronous HTTP request, please pass async_req=True411 >>> thread = api.process_request_using_patch1(body, request_headers, routing_key, async_req=True)412 >>> result = thread.get()413 :param async_req bool414 :param str body: msg (required)415 :param Object request_headers: requestHeaders (required)416 :param str routing_key: routingKey (required)417 :return: DeferredResultResponseEntity418 If the method is called asynchronously,419 returns the request thread.420 """421 kwargs['_return_http_data_only'] = True422 if kwargs.get('async_req'):423 return self.process_request_using_patch1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501424 else:425 (data) = self.process_request_using_patch1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501426 return data427 def process_request_using_patch1_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501428 """processRequest # noqa: E501429 This method makes a synchronous HTTP request by default. To make an430 asynchronous HTTP request, please pass async_req=True431 >>> thread = api.process_request_using_patch1_with_http_info(body, request_headers, routing_key, async_req=True)432 >>> result = thread.get()433 :param async_req bool434 :param str body: msg (required)435 :param Object request_headers: requestHeaders (required)436 :param str routing_key: routingKey (required)437 :return: DeferredResultResponseEntity438 If the method is called asynchronously,439 returns the request thread.440 """441 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501442 all_params.append('async_req')443 all_params.append('_return_http_data_only')444 all_params.append('_preload_content')445 all_params.append('_request_timeout')446 params = locals()447 for key, val in six.iteritems(params['kwargs']):448 if key not in all_params:449 raise TypeError(450 "Got an unexpected keyword argument '%s'"451 " to method process_request_using_patch1" % key452 )453 params[key] = val454 del params['kwargs']455 # verify the required parameter 'body' is set456 if ('body' not in params or457 params['body'] is None):458 raise ValueError("Missing the required parameter `body` when calling `process_request_using_patch1`") # noqa: E501459 # verify the required parameter 'request_headers' is set460 if ('request_headers' not in params or461 params['request_headers'] is None):462 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_patch1`") # noqa: E501463 # verify the required parameter 'routing_key' is set464 if ('routing_key' not in params or465 params['routing_key'] is None):466 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_patch1`") # noqa: E501467 collection_formats = {}468 path_params = {}469 if 'routing_key' in params:470 path_params['routingKey'] = params['routing_key'] # noqa: E501471 query_params = []472 header_params = {}473 if 'request_headers' in params:474 header_params['requestHeaders'] = params['request_headers'] # noqa: E501475 form_params = []476 local_var_files = {}477 body_params = None478 if 'body' in params:479 body_params = params['body']480 # HTTP header `Accept`481 header_params['Accept'] = self.api_client.select_header_accept(482 ['*/*']) # noqa: E501483 # HTTP header `Content-Type`484 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501485 ['application/json']) # noqa: E501486 # Authentication setting487 auth_settings = ['X-Authorization'] # noqa: E501488 return self.api_client.call_api(489 '/api/v1/integrations/sigfox/{routingKey}', 'PATCH',490 path_params,491 query_params,492 header_params,493 body=body_params,494 post_params=form_params,495 files=local_var_files,496 response_type='DeferredResultResponseEntity', # noqa: E501497 auth_settings=auth_settings,498 async_req=params.get('async_req'),499 _return_http_data_only=params.get('_return_http_data_only'),500 _preload_content=params.get('_preload_content', True),501 _request_timeout=params.get('_request_timeout'),502 collection_formats=collection_formats)503 def process_request_using_post3(self, body, request_headers, routing_key, **kwargs): # noqa: E501504 """processRequest # noqa: E501505 This method makes a synchronous HTTP request by default. To make an506 asynchronous HTTP request, please pass async_req=True507 >>> thread = api.process_request_using_post3(body, request_headers, routing_key, async_req=True)508 >>> result = thread.get()509 :param async_req bool510 :param str body: msg (required)511 :param Object request_headers: requestHeaders (required)512 :param str routing_key: routingKey (required)513 :return: DeferredResultResponseEntity514 If the method is called asynchronously,515 returns the request thread.516 """517 kwargs['_return_http_data_only'] = True518 if kwargs.get('async_req'):519 return self.process_request_using_post3_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501520 else:521 (data) = self.process_request_using_post3_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501522 return data523 def process_request_using_post3_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501524 """processRequest # noqa: E501525 This method makes a synchronous HTTP request by default. To make an526 asynchronous HTTP request, please pass async_req=True527 >>> thread = api.process_request_using_post3_with_http_info(body, request_headers, routing_key, async_req=True)528 >>> result = thread.get()529 :param async_req bool530 :param str body: msg (required)531 :param Object request_headers: requestHeaders (required)532 :param str routing_key: routingKey (required)533 :return: DeferredResultResponseEntity534 If the method is called asynchronously,535 returns the request thread.536 """537 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501538 all_params.append('async_req')539 all_params.append('_return_http_data_only')540 all_params.append('_preload_content')541 all_params.append('_request_timeout')542 params = locals()543 for key, val in six.iteritems(params['kwargs']):544 if key not in all_params:545 raise TypeError(546 "Got an unexpected keyword argument '%s'"547 " to method process_request_using_post3" % key548 )549 params[key] = val550 del params['kwargs']551 # verify the required parameter 'body' is set552 if ('body' not in params or553 params['body'] is None):554 raise ValueError("Missing the required parameter `body` when calling `process_request_using_post3`") # noqa: E501555 # verify the required parameter 'request_headers' is set556 if ('request_headers' not in params or557 params['request_headers'] is None):558 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_post3`") # noqa: E501559 # verify the required parameter 'routing_key' is set560 if ('routing_key' not in params or561 params['routing_key'] is None):562 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_post3`") # noqa: E501563 collection_formats = {}564 path_params = {}565 if 'routing_key' in params:566 path_params['routingKey'] = params['routing_key'] # noqa: E501567 query_params = []568 header_params = {}569 if 'request_headers' in params:570 header_params['requestHeaders'] = params['request_headers'] # noqa: E501571 form_params = []572 local_var_files = {}573 body_params = None574 if 'body' in params:575 body_params = params['body']576 # HTTP header `Accept`577 header_params['Accept'] = self.api_client.select_header_accept(578 ['*/*']) # noqa: E501579 # HTTP header `Content-Type`580 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501581 ['application/json']) # noqa: E501582 # Authentication setting583 auth_settings = ['X-Authorization'] # noqa: E501584 return self.api_client.call_api(585 '/api/v1/integrations/sigfox/{routingKey}', 'POST',586 path_params,587 query_params,588 header_params,589 body=body_params,590 post_params=form_params,591 files=local_var_files,592 response_type='DeferredResultResponseEntity', # noqa: E501593 auth_settings=auth_settings,594 async_req=params.get('async_req'),595 _return_http_data_only=params.get('_return_http_data_only'),596 _preload_content=params.get('_preload_content', True),597 _request_timeout=params.get('_request_timeout'),598 collection_formats=collection_formats)599 def process_request_using_put1(self, body, request_headers, routing_key, **kwargs): # noqa: E501600 """processRequest # noqa: E501601 This method makes a synchronous HTTP request by default. To make an602 asynchronous HTTP request, please pass async_req=True603 >>> thread = api.process_request_using_put1(body, request_headers, routing_key, async_req=True)604 >>> result = thread.get()605 :param async_req bool606 :param str body: msg (required)607 :param Object request_headers: requestHeaders (required)608 :param str routing_key: routingKey (required)609 :return: DeferredResultResponseEntity610 If the method is called asynchronously,611 returns the request thread.612 """613 kwargs['_return_http_data_only'] = True614 if kwargs.get('async_req'):615 return self.process_request_using_put1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501616 else:617 (data) = self.process_request_using_put1_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501618 return data619 def process_request_using_put1_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501620 """processRequest # noqa: E501621 This method makes a synchronous HTTP request by default. To make an622 asynchronous HTTP request, please pass async_req=True623 >>> thread = api.process_request_using_put1_with_http_info(body, request_headers, routing_key, async_req=True)624 >>> result = thread.get()625 :param async_req bool626 :param str body: msg (required)627 :param Object request_headers: requestHeaders (required)628 :param str routing_key: routingKey (required)629 :return: DeferredResultResponseEntity630 If the method is called asynchronously,631 returns the request thread.632 """633 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501634 all_params.append('async_req')635 all_params.append('_return_http_data_only')636 all_params.append('_preload_content')637 all_params.append('_request_timeout')638 params = locals()639 for key, val in six.iteritems(params['kwargs']):640 if key not in all_params:641 raise TypeError(642 "Got an unexpected keyword argument '%s'"643 " to method process_request_using_put1" % key644 )645 params[key] = val646 del params['kwargs']647 # verify the required parameter 'body' is set648 if ('body' not in params or649 params['body'] is None):650 raise ValueError("Missing the required parameter `body` when calling `process_request_using_put1`") # noqa: E501651 # verify the required parameter 'request_headers' is set652 if ('request_headers' not in params or653 params['request_headers'] is None):654 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_put1`") # noqa: E501655 # verify the required parameter 'routing_key' is set656 if ('routing_key' not in params or657 params['routing_key'] is None):658 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_put1`") # noqa: E501659 collection_formats = {}660 path_params = {}661 if 'routing_key' in params:662 path_params['routingKey'] = params['routing_key'] # noqa: E501663 query_params = []664 header_params = {}665 if 'request_headers' in params:666 header_params['requestHeaders'] = params['request_headers'] # noqa: E501667 form_params = []668 local_var_files = {}669 body_params = None670 if 'body' in params:671 body_params = params['body']672 # HTTP header `Accept`673 header_params['Accept'] = self.api_client.select_header_accept(674 ['*/*']) # noqa: E501675 # HTTP header `Content-Type`676 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501677 ['application/json']) # noqa: E501678 # Authentication setting679 auth_settings = ['X-Authorization'] # noqa: E501680 return self.api_client.call_api(681 '/api/v1/integrations/sigfox/{routingKey}', 'PUT',682 path_params,683 query_params,684 header_params,685 body=body_params,686 post_params=form_params,687 files=local_var_files,688 response_type='DeferredResultResponseEntity', # noqa: E501689 auth_settings=auth_settings,690 async_req=params.get('async_req'),691 _return_http_data_only=params.get('_return_http_data_only'),692 _preload_content=params.get('_preload_content', True),693 _request_timeout=params.get('_request_timeout'),...

Full Screen

Full Screen

ocean_connect_integration_controller_api.py

Source:ocean_connect_integration_controller_api.py Github

copy

Full Screen

1# coding: utf-82"""3 Thingsboard REST API4 For instructions how to authorize requests please visit <a href='http://thingsboard.io/docs/reference/rest-api/'>REST API documentation page</a>. # noqa: E5015 OpenAPI spec version: 2.06 Contact: info@thingsboard.io7 Generated by: https://github.com/swagger-api/swagger-codegen.git8"""9from __future__ import absolute_import10import re # noqa: F40111# python 2 and python 3 compatibility library12import six13from pyTB.api_client import ApiClient14class OceanConnectIntegrationControllerApi(object):15 """NOTE: This class is auto generated by the swagger code generator program.16 Do not edit the class manually.17 Ref: https://github.com/swagger-api/swagger-codegen18 """19 def __init__(self, api_client=None):20 if api_client is None:21 api_client = ApiClient()22 self.api_client = api_client23 def process_request_using_delete(self, body, request_headers, routing_key, **kwargs): # noqa: E50124 """processRequest # noqa: E50125 This method makes a synchronous HTTP request by default. To make an26 asynchronous HTTP request, please pass async_req=True27 >>> thread = api.process_request_using_delete(body, request_headers, routing_key, async_req=True)28 >>> result = thread.get()29 :param async_req bool30 :param str body: msg (required)31 :param Object request_headers: requestHeaders (required)32 :param str routing_key: routingKey (required)33 :return: DeferredResultResponseEntity34 If the method is called asynchronously,35 returns the request thread.36 """37 kwargs['_return_http_data_only'] = True38 if kwargs.get('async_req'):39 return self.process_request_using_delete_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E50140 else:41 (data) = self.process_request_using_delete_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E50142 return data43 def process_request_using_delete_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E50144 """processRequest # noqa: E50145 This method makes a synchronous HTTP request by default. To make an46 asynchronous HTTP request, please pass async_req=True47 >>> thread = api.process_request_using_delete_with_http_info(body, request_headers, routing_key, async_req=True)48 >>> result = thread.get()49 :param async_req bool50 :param str body: msg (required)51 :param Object request_headers: requestHeaders (required)52 :param str routing_key: routingKey (required)53 :return: DeferredResultResponseEntity54 If the method is called asynchronously,55 returns the request thread.56 """57 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E50158 all_params.append('async_req')59 all_params.append('_return_http_data_only')60 all_params.append('_preload_content')61 all_params.append('_request_timeout')62 params = locals()63 for key, val in six.iteritems(params['kwargs']):64 if key not in all_params:65 raise TypeError(66 "Got an unexpected keyword argument '%s'"67 " to method process_request_using_delete" % key68 )69 params[key] = val70 del params['kwargs']71 # verify the required parameter 'body' is set72 if ('body' not in params or73 params['body'] is None):74 raise ValueError("Missing the required parameter `body` when calling `process_request_using_delete`") # noqa: E50175 # verify the required parameter 'request_headers' is set76 if ('request_headers' not in params or77 params['request_headers'] is None):78 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_delete`") # noqa: E50179 # verify the required parameter 'routing_key' is set80 if ('routing_key' not in params or81 params['routing_key'] is None):82 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_delete`") # noqa: E50183 collection_formats = {}84 path_params = {}85 if 'routing_key' in params:86 path_params['routingKey'] = params['routing_key'] # noqa: E50187 query_params = []88 header_params = {}89 if 'request_headers' in params:90 header_params['requestHeaders'] = params['request_headers'] # noqa: E50191 form_params = []92 local_var_files = {}93 body_params = None94 if 'body' in params:95 body_params = params['body']96 # HTTP header `Accept`97 header_params['Accept'] = self.api_client.select_header_accept(98 ['*/*']) # noqa: E50199 # HTTP header `Content-Type`100 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501101 ['application/json']) # noqa: E501102 # Authentication setting103 auth_settings = ['X-Authorization'] # noqa: E501104 return self.api_client.call_api(105 '/api/v1/integrations/oceanconnect/{routingKey}', 'DELETE',106 path_params,107 query_params,108 header_params,109 body=body_params,110 post_params=form_params,111 files=local_var_files,112 response_type='DeferredResultResponseEntity', # noqa: E501113 auth_settings=auth_settings,114 async_req=params.get('async_req'),115 _return_http_data_only=params.get('_return_http_data_only'),116 _preload_content=params.get('_preload_content', True),117 _request_timeout=params.get('_request_timeout'),118 collection_formats=collection_formats)119 def process_request_using_get(self, body, request_headers, routing_key, **kwargs): # noqa: E501120 """processRequest # noqa: E501121 This method makes a synchronous HTTP request by default. To make an122 asynchronous HTTP request, please pass async_req=True123 >>> thread = api.process_request_using_get(body, request_headers, routing_key, async_req=True)124 >>> result = thread.get()125 :param async_req bool126 :param str body: msg (required)127 :param Object request_headers: requestHeaders (required)128 :param str routing_key: routingKey (required)129 :return: DeferredResultResponseEntity130 If the method is called asynchronously,131 returns the request thread.132 """133 kwargs['_return_http_data_only'] = True134 if kwargs.get('async_req'):135 return self.process_request_using_get_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501136 else:137 (data) = self.process_request_using_get_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501138 return data139 def process_request_using_get_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501140 """processRequest # noqa: E501141 This method makes a synchronous HTTP request by default. To make an142 asynchronous HTTP request, please pass async_req=True143 >>> thread = api.process_request_using_get_with_http_info(body, request_headers, routing_key, async_req=True)144 >>> result = thread.get()145 :param async_req bool146 :param str body: msg (required)147 :param Object request_headers: requestHeaders (required)148 :param str routing_key: routingKey (required)149 :return: DeferredResultResponseEntity150 If the method is called asynchronously,151 returns the request thread.152 """153 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501154 all_params.append('async_req')155 all_params.append('_return_http_data_only')156 all_params.append('_preload_content')157 all_params.append('_request_timeout')158 params = locals()159 for key, val in six.iteritems(params['kwargs']):160 if key not in all_params:161 raise TypeError(162 "Got an unexpected keyword argument '%s'"163 " to method process_request_using_get" % key164 )165 params[key] = val166 del params['kwargs']167 # verify the required parameter 'body' is set168 if ('body' not in params or169 params['body'] is None):170 raise ValueError("Missing the required parameter `body` when calling `process_request_using_get`") # noqa: E501171 # verify the required parameter 'request_headers' is set172 if ('request_headers' not in params or173 params['request_headers'] is None):174 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_get`") # noqa: E501175 # verify the required parameter 'routing_key' is set176 if ('routing_key' not in params or177 params['routing_key'] is None):178 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_get`") # noqa: E501179 collection_formats = {}180 path_params = {}181 if 'routing_key' in params:182 path_params['routingKey'] = params['routing_key'] # noqa: E501183 query_params = []184 header_params = {}185 if 'request_headers' in params:186 header_params['requestHeaders'] = params['request_headers'] # noqa: E501187 form_params = []188 local_var_files = {}189 body_params = None190 if 'body' in params:191 body_params = params['body']192 # HTTP header `Accept`193 header_params['Accept'] = self.api_client.select_header_accept(194 ['*/*']) # noqa: E501195 # HTTP header `Content-Type`196 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501197 ['application/json']) # noqa: E501198 # Authentication setting199 auth_settings = ['X-Authorization'] # noqa: E501200 return self.api_client.call_api(201 '/api/v1/integrations/oceanconnect/{routingKey}', 'GET',202 path_params,203 query_params,204 header_params,205 body=body_params,206 post_params=form_params,207 files=local_var_files,208 response_type='DeferredResultResponseEntity', # noqa: E501209 auth_settings=auth_settings,210 async_req=params.get('async_req'),211 _return_http_data_only=params.get('_return_http_data_only'),212 _preload_content=params.get('_preload_content', True),213 _request_timeout=params.get('_request_timeout'),214 collection_formats=collection_formats)215 def process_request_using_head(self, body, request_headers, routing_key, **kwargs): # noqa: E501216 """processRequest # noqa: E501217 This method makes a synchronous HTTP request by default. To make an218 asynchronous HTTP request, please pass async_req=True219 >>> thread = api.process_request_using_head(body, request_headers, routing_key, async_req=True)220 >>> result = thread.get()221 :param async_req bool222 :param str body: msg (required)223 :param Object request_headers: requestHeaders (required)224 :param str routing_key: routingKey (required)225 :return: DeferredResultResponseEntity226 If the method is called asynchronously,227 returns the request thread.228 """229 kwargs['_return_http_data_only'] = True230 if kwargs.get('async_req'):231 return self.process_request_using_head_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501232 else:233 (data) = self.process_request_using_head_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501234 return data235 def process_request_using_head_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501236 """processRequest # noqa: E501237 This method makes a synchronous HTTP request by default. To make an238 asynchronous HTTP request, please pass async_req=True239 >>> thread = api.process_request_using_head_with_http_info(body, request_headers, routing_key, async_req=True)240 >>> result = thread.get()241 :param async_req bool242 :param str body: msg (required)243 :param Object request_headers: requestHeaders (required)244 :param str routing_key: routingKey (required)245 :return: DeferredResultResponseEntity246 If the method is called asynchronously,247 returns the request thread.248 """249 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501250 all_params.append('async_req')251 all_params.append('_return_http_data_only')252 all_params.append('_preload_content')253 all_params.append('_request_timeout')254 params = locals()255 for key, val in six.iteritems(params['kwargs']):256 if key not in all_params:257 raise TypeError(258 "Got an unexpected keyword argument '%s'"259 " to method process_request_using_head" % key260 )261 params[key] = val262 del params['kwargs']263 # verify the required parameter 'body' is set264 if ('body' not in params or265 params['body'] is None):266 raise ValueError("Missing the required parameter `body` when calling `process_request_using_head`") # noqa: E501267 # verify the required parameter 'request_headers' is set268 if ('request_headers' not in params or269 params['request_headers'] is None):270 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_head`") # noqa: E501271 # verify the required parameter 'routing_key' is set272 if ('routing_key' not in params or273 params['routing_key'] is None):274 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_head`") # noqa: E501275 collection_formats = {}276 path_params = {}277 if 'routing_key' in params:278 path_params['routingKey'] = params['routing_key'] # noqa: E501279 query_params = []280 header_params = {}281 if 'request_headers' in params:282 header_params['requestHeaders'] = params['request_headers'] # noqa: E501283 form_params = []284 local_var_files = {}285 body_params = None286 if 'body' in params:287 body_params = params['body']288 # HTTP header `Accept`289 header_params['Accept'] = self.api_client.select_header_accept(290 ['*/*']) # noqa: E501291 # HTTP header `Content-Type`292 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501293 ['application/json']) # noqa: E501294 # Authentication setting295 auth_settings = ['X-Authorization'] # noqa: E501296 return self.api_client.call_api(297 '/api/v1/integrations/oceanconnect/{routingKey}', 'HEAD',298 path_params,299 query_params,300 header_params,301 body=body_params,302 post_params=form_params,303 files=local_var_files,304 response_type='DeferredResultResponseEntity', # noqa: E501305 auth_settings=auth_settings,306 async_req=params.get('async_req'),307 _return_http_data_only=params.get('_return_http_data_only'),308 _preload_content=params.get('_preload_content', True),309 _request_timeout=params.get('_request_timeout'),310 collection_formats=collection_formats)311 def process_request_using_options(self, body, request_headers, routing_key, **kwargs): # noqa: E501312 """processRequest # noqa: E501313 This method makes a synchronous HTTP request by default. To make an314 asynchronous HTTP request, please pass async_req=True315 >>> thread = api.process_request_using_options(body, request_headers, routing_key, async_req=True)316 >>> result = thread.get()317 :param async_req bool318 :param str body: msg (required)319 :param Object request_headers: requestHeaders (required)320 :param str routing_key: routingKey (required)321 :return: DeferredResultResponseEntity322 If the method is called asynchronously,323 returns the request thread.324 """325 kwargs['_return_http_data_only'] = True326 if kwargs.get('async_req'):327 return self.process_request_using_options_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501328 else:329 (data) = self.process_request_using_options_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501330 return data331 def process_request_using_options_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501332 """processRequest # noqa: E501333 This method makes a synchronous HTTP request by default. To make an334 asynchronous HTTP request, please pass async_req=True335 >>> thread = api.process_request_using_options_with_http_info(body, request_headers, routing_key, async_req=True)336 >>> result = thread.get()337 :param async_req bool338 :param str body: msg (required)339 :param Object request_headers: requestHeaders (required)340 :param str routing_key: routingKey (required)341 :return: DeferredResultResponseEntity342 If the method is called asynchronously,343 returns the request thread.344 """345 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501346 all_params.append('async_req')347 all_params.append('_return_http_data_only')348 all_params.append('_preload_content')349 all_params.append('_request_timeout')350 params = locals()351 for key, val in six.iteritems(params['kwargs']):352 if key not in all_params:353 raise TypeError(354 "Got an unexpected keyword argument '%s'"355 " to method process_request_using_options" % key356 )357 params[key] = val358 del params['kwargs']359 # verify the required parameter 'body' is set360 if ('body' not in params or361 params['body'] is None):362 raise ValueError("Missing the required parameter `body` when calling `process_request_using_options`") # noqa: E501363 # verify the required parameter 'request_headers' is set364 if ('request_headers' not in params or365 params['request_headers'] is None):366 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_options`") # noqa: E501367 # verify the required parameter 'routing_key' is set368 if ('routing_key' not in params or369 params['routing_key'] is None):370 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_options`") # noqa: E501371 collection_formats = {}372 path_params = {}373 if 'routing_key' in params:374 path_params['routingKey'] = params['routing_key'] # noqa: E501375 query_params = []376 header_params = {}377 if 'request_headers' in params:378 header_params['requestHeaders'] = params['request_headers'] # noqa: E501379 form_params = []380 local_var_files = {}381 body_params = None382 if 'body' in params:383 body_params = params['body']384 # HTTP header `Accept`385 header_params['Accept'] = self.api_client.select_header_accept(386 ['*/*']) # noqa: E501387 # HTTP header `Content-Type`388 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501389 ['application/json']) # noqa: E501390 # Authentication setting391 auth_settings = ['X-Authorization'] # noqa: E501392 return self.api_client.call_api(393 '/api/v1/integrations/oceanconnect/{routingKey}', 'OPTIONS',394 path_params,395 query_params,396 header_params,397 body=body_params,398 post_params=form_params,399 files=local_var_files,400 response_type='DeferredResultResponseEntity', # noqa: E501401 auth_settings=auth_settings,402 async_req=params.get('async_req'),403 _return_http_data_only=params.get('_return_http_data_only'),404 _preload_content=params.get('_preload_content', True),405 _request_timeout=params.get('_request_timeout'),406 collection_formats=collection_formats)407 def process_request_using_patch(self, body, request_headers, routing_key, **kwargs): # noqa: E501408 """processRequest # noqa: E501409 This method makes a synchronous HTTP request by default. To make an410 asynchronous HTTP request, please pass async_req=True411 >>> thread = api.process_request_using_patch(body, request_headers, routing_key, async_req=True)412 >>> result = thread.get()413 :param async_req bool414 :param str body: msg (required)415 :param Object request_headers: requestHeaders (required)416 :param str routing_key: routingKey (required)417 :return: DeferredResultResponseEntity418 If the method is called asynchronously,419 returns the request thread.420 """421 kwargs['_return_http_data_only'] = True422 if kwargs.get('async_req'):423 return self.process_request_using_patch_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501424 else:425 (data) = self.process_request_using_patch_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501426 return data427 def process_request_using_patch_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501428 """processRequest # noqa: E501429 This method makes a synchronous HTTP request by default. To make an430 asynchronous HTTP request, please pass async_req=True431 >>> thread = api.process_request_using_patch_with_http_info(body, request_headers, routing_key, async_req=True)432 >>> result = thread.get()433 :param async_req bool434 :param str body: msg (required)435 :param Object request_headers: requestHeaders (required)436 :param str routing_key: routingKey (required)437 :return: DeferredResultResponseEntity438 If the method is called asynchronously,439 returns the request thread.440 """441 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501442 all_params.append('async_req')443 all_params.append('_return_http_data_only')444 all_params.append('_preload_content')445 all_params.append('_request_timeout')446 params = locals()447 for key, val in six.iteritems(params['kwargs']):448 if key not in all_params:449 raise TypeError(450 "Got an unexpected keyword argument '%s'"451 " to method process_request_using_patch" % key452 )453 params[key] = val454 del params['kwargs']455 # verify the required parameter 'body' is set456 if ('body' not in params or457 params['body'] is None):458 raise ValueError("Missing the required parameter `body` when calling `process_request_using_patch`") # noqa: E501459 # verify the required parameter 'request_headers' is set460 if ('request_headers' not in params or461 params['request_headers'] is None):462 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_patch`") # noqa: E501463 # verify the required parameter 'routing_key' is set464 if ('routing_key' not in params or465 params['routing_key'] is None):466 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_patch`") # noqa: E501467 collection_formats = {}468 path_params = {}469 if 'routing_key' in params:470 path_params['routingKey'] = params['routing_key'] # noqa: E501471 query_params = []472 header_params = {}473 if 'request_headers' in params:474 header_params['requestHeaders'] = params['request_headers'] # noqa: E501475 form_params = []476 local_var_files = {}477 body_params = None478 if 'body' in params:479 body_params = params['body']480 # HTTP header `Accept`481 header_params['Accept'] = self.api_client.select_header_accept(482 ['*/*']) # noqa: E501483 # HTTP header `Content-Type`484 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501485 ['application/json']) # noqa: E501486 # Authentication setting487 auth_settings = ['X-Authorization'] # noqa: E501488 return self.api_client.call_api(489 '/api/v1/integrations/oceanconnect/{routingKey}', 'PATCH',490 path_params,491 query_params,492 header_params,493 body=body_params,494 post_params=form_params,495 files=local_var_files,496 response_type='DeferredResultResponseEntity', # noqa: E501497 auth_settings=auth_settings,498 async_req=params.get('async_req'),499 _return_http_data_only=params.get('_return_http_data_only'),500 _preload_content=params.get('_preload_content', True),501 _request_timeout=params.get('_request_timeout'),502 collection_formats=collection_formats)503 def process_request_using_post2(self, body, request_headers, routing_key, **kwargs): # noqa: E501504 """processRequest # noqa: E501505 This method makes a synchronous HTTP request by default. To make an506 asynchronous HTTP request, please pass async_req=True507 >>> thread = api.process_request_using_post2(body, request_headers, routing_key, async_req=True)508 >>> result = thread.get()509 :param async_req bool510 :param str body: msg (required)511 :param Object request_headers: requestHeaders (required)512 :param str routing_key: routingKey (required)513 :return: DeferredResultResponseEntity514 If the method is called asynchronously,515 returns the request thread.516 """517 kwargs['_return_http_data_only'] = True518 if kwargs.get('async_req'):519 return self.process_request_using_post2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501520 else:521 (data) = self.process_request_using_post2_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501522 return data523 def process_request_using_post2_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501524 """processRequest # noqa: E501525 This method makes a synchronous HTTP request by default. To make an526 asynchronous HTTP request, please pass async_req=True527 >>> thread = api.process_request_using_post2_with_http_info(body, request_headers, routing_key, async_req=True)528 >>> result = thread.get()529 :param async_req bool530 :param str body: msg (required)531 :param Object request_headers: requestHeaders (required)532 :param str routing_key: routingKey (required)533 :return: DeferredResultResponseEntity534 If the method is called asynchronously,535 returns the request thread.536 """537 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501538 all_params.append('async_req')539 all_params.append('_return_http_data_only')540 all_params.append('_preload_content')541 all_params.append('_request_timeout')542 params = locals()543 for key, val in six.iteritems(params['kwargs']):544 if key not in all_params:545 raise TypeError(546 "Got an unexpected keyword argument '%s'"547 " to method process_request_using_post2" % key548 )549 params[key] = val550 del params['kwargs']551 # verify the required parameter 'body' is set552 if ('body' not in params or553 params['body'] is None):554 raise ValueError("Missing the required parameter `body` when calling `process_request_using_post2`") # noqa: E501555 # verify the required parameter 'request_headers' is set556 if ('request_headers' not in params or557 params['request_headers'] is None):558 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_post2`") # noqa: E501559 # verify the required parameter 'routing_key' is set560 if ('routing_key' not in params or561 params['routing_key'] is None):562 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_post2`") # noqa: E501563 collection_formats = {}564 path_params = {}565 if 'routing_key' in params:566 path_params['routingKey'] = params['routing_key'] # noqa: E501567 query_params = []568 header_params = {}569 if 'request_headers' in params:570 header_params['requestHeaders'] = params['request_headers'] # noqa: E501571 form_params = []572 local_var_files = {}573 body_params = None574 if 'body' in params:575 body_params = params['body']576 # HTTP header `Accept`577 header_params['Accept'] = self.api_client.select_header_accept(578 ['*/*']) # noqa: E501579 # HTTP header `Content-Type`580 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501581 ['application/json']) # noqa: E501582 # Authentication setting583 auth_settings = ['X-Authorization'] # noqa: E501584 return self.api_client.call_api(585 '/api/v1/integrations/oceanconnect/{routingKey}', 'POST',586 path_params,587 query_params,588 header_params,589 body=body_params,590 post_params=form_params,591 files=local_var_files,592 response_type='DeferredResultResponseEntity', # noqa: E501593 auth_settings=auth_settings,594 async_req=params.get('async_req'),595 _return_http_data_only=params.get('_return_http_data_only'),596 _preload_content=params.get('_preload_content', True),597 _request_timeout=params.get('_request_timeout'),598 collection_formats=collection_formats)599 def process_request_using_put(self, body, request_headers, routing_key, **kwargs): # noqa: E501600 """processRequest # noqa: E501601 This method makes a synchronous HTTP request by default. To make an602 asynchronous HTTP request, please pass async_req=True603 >>> thread = api.process_request_using_put(body, request_headers, routing_key, async_req=True)604 >>> result = thread.get()605 :param async_req bool606 :param str body: msg (required)607 :param Object request_headers: requestHeaders (required)608 :param str routing_key: routingKey (required)609 :return: DeferredResultResponseEntity610 If the method is called asynchronously,611 returns the request thread.612 """613 kwargs['_return_http_data_only'] = True614 if kwargs.get('async_req'):615 return self.process_request_using_put_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501616 else:617 (data) = self.process_request_using_put_with_http_info(body, request_headers, routing_key, **kwargs) # noqa: E501618 return data619 def process_request_using_put_with_http_info(self, body, request_headers, routing_key, **kwargs): # noqa: E501620 """processRequest # noqa: E501621 This method makes a synchronous HTTP request by default. To make an622 asynchronous HTTP request, please pass async_req=True623 >>> thread = api.process_request_using_put_with_http_info(body, request_headers, routing_key, async_req=True)624 >>> result = thread.get()625 :param async_req bool626 :param str body: msg (required)627 :param Object request_headers: requestHeaders (required)628 :param str routing_key: routingKey (required)629 :return: DeferredResultResponseEntity630 If the method is called asynchronously,631 returns the request thread.632 """633 all_params = ['body', 'request_headers', 'routing_key'] # noqa: E501634 all_params.append('async_req')635 all_params.append('_return_http_data_only')636 all_params.append('_preload_content')637 all_params.append('_request_timeout')638 params = locals()639 for key, val in six.iteritems(params['kwargs']):640 if key not in all_params:641 raise TypeError(642 "Got an unexpected keyword argument '%s'"643 " to method process_request_using_put" % key644 )645 params[key] = val646 del params['kwargs']647 # verify the required parameter 'body' is set648 if ('body' not in params or649 params['body'] is None):650 raise ValueError("Missing the required parameter `body` when calling `process_request_using_put`") # noqa: E501651 # verify the required parameter 'request_headers' is set652 if ('request_headers' not in params or653 params['request_headers'] is None):654 raise ValueError("Missing the required parameter `request_headers` when calling `process_request_using_put`") # noqa: E501655 # verify the required parameter 'routing_key' is set656 if ('routing_key' not in params or657 params['routing_key'] is None):658 raise ValueError("Missing the required parameter `routing_key` when calling `process_request_using_put`") # noqa: E501659 collection_formats = {}660 path_params = {}661 if 'routing_key' in params:662 path_params['routingKey'] = params['routing_key'] # noqa: E501663 query_params = []664 header_params = {}665 if 'request_headers' in params:666 header_params['requestHeaders'] = params['request_headers'] # noqa: E501667 form_params = []668 local_var_files = {}669 body_params = None670 if 'body' in params:671 body_params = params['body']672 # HTTP header `Accept`673 header_params['Accept'] = self.api_client.select_header_accept(674 ['*/*']) # noqa: E501675 # HTTP header `Content-Type`676 header_params['Content-Type'] = self.api_client.select_header_content_type( # noqa: E501677 ['application/json']) # noqa: E501678 # Authentication setting679 auth_settings = ['X-Authorization'] # noqa: E501680 return self.api_client.call_api(681 '/api/v1/integrations/oceanconnect/{routingKey}', 'PUT',682 path_params,683 query_params,684 header_params,685 body=body_params,686 post_params=form_params,687 files=local_var_files,688 response_type='DeferredResultResponseEntity', # noqa: E501689 auth_settings=auth_settings,690 async_req=params.get('async_req'),691 _return_http_data_only=params.get('_return_http_data_only'),692 _preload_content=params.get('_preload_content', True),693 _request_timeout=params.get('_request_timeout'),...

Full Screen

Full Screen

Automation Testing Tutorials

Learn to execute automation testing from scratch with LambdaTest Learning Hub. Right from setting up the prerequisites to run your first automation test, to following best practices and diving deeper into advanced test scenarios. LambdaTest Learning Hubs compile a list of step-by-step guides to help you be proficient with different test automation frameworks i.e. Selenium, Cypress, TestNG etc.

LambdaTest Learning Hubs:

YouTube

You could also refer to video tutorials over LambdaTest YouTube channel to get step by step demonstration from industry experts.

Run Splinter automation tests on LambdaTest cloud grid

Perform automation testing on 3000+ real desktop and mobile devices online.

Try LambdaTest Now !!

Get 100 minutes of automation test minutes FREE!!

Next-Gen App & Browser Testing Cloud

Was this article helpful?

Helpful

NotHelpful