Test your AI Agents with the all-new Agent to Agent Testing Platform.Learn More

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

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'),...

t_mobile_iot_cdp_integration_controller_api.py

Source:t_mobile_iot_cdp_integration_controller_api.py

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'),...

sig_fox_integration_controller_api.py

Source:sig_fox_integration_controller_api.py

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'),...

ocean_connect_integration_controller_api.py

Source:ocean_connect_integration_controller_api.py

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'),...

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.