~i:JdZddlmZddlZddlZddlZGddeZdS)z rocketmq No description provided (generated by Swagger Codegen https://github.com/swagger-api/swagger-codegen) # noqa: E501 OpenAPI spec version: common-version Generated by: https://github.com/swagger-api/swagger-codegen.git )absolute_importNcneZdZdZddZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ d Z!d!Z"d"Z#d#Z$d$Z%d%Z&d&Z'd'Z(d(Z)d)Z*d*Z+d+Z,d,Z-d-Z.d.Z/d/Z0d0Z1d1Z2d2Z3d3Z4d4Z5d5Z6d6Z7d7Z8d8Z9d9Z:d:Z;d;Zd>Z?d?Z@d@ZAdAZBdBZCdCZDdDZEdEZFdFZGdGZHdHZIdIZJdJZKdKZLdLZMdMZNdNZOdOZPdPZQdQZRdRZSdSZTdTZUdUZVdVZWdWZXdXZYdYZZdZZ[d[Z\d\Z]d]Z^d^Z_d_Z`d`ZadaZbdbZcdcZdddZedeZfdfZgdgZhdhZidiZjdjZkdkZldlZmdmZndnZodoZpdpZqdqZrdrZsdsZtdtZuduZvdvZwdwZxdxZydyZzdzZ{d{Z|d|Z}d}Z~d~ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdS) ROCKETMQApizNOTE: This class is auto generated by the swagger code generator program. Do not edit the class manually. Ref: https://github.com/swagger-api/swagger-codegen Nc>|tj}||_dSN)volcenginesdkcore ApiClient api_client)selfr s o/root/.openclaw/workspace/.venvs/ark-sdk/lib/python3.11/site-packages/volcenginesdkrocketmq/api/rocketmq_api.py__init__zROCKETMQApi.__init__s!  *466J$c rd|d<|dr|j|fi|S|j|fi|}|S)aadd_pl_whitelist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_pl_whitelist(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddPLWhitelistRequest body: (required) :return: AddPLWhitelistResponse If the method is called asynchronously, returns the request thread. T_return_http_data_only async_req)getadd_pl_whitelist_with_http_infor bodykwargsdatas r add_pl_whitelistzROCKETMQApi.add_pl_whitelist$],0'( ::k " " 747GGGG G9T9$II&IITKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aadd_pl_whitelist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_pl_whitelist_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddPLWhitelistRequest body: (required) :return: AddPLWhitelistResponse If the method is called asynchronously, returns the request thread. rrr_preload_content_request_timeoutrzBGot an unexpected keyword argument '%s' to method add_pl_whitelistNzEMissing the required parameter `body` when calling `add_pl_whitelist`application/jsonAccept Content-TypevolcengineSignz:/AddPLWhitelist/2023-01-01/rocketmq/post/application_json/POSTAddPLWhitelistResponseT r post_paramsfiles response_type auth_settingsrrrrcollection_formats appendlocalssix iteritems TypeErrorr client_side_validation ValueErrorselect_header_acceptselect_header_content_typecall_apirr rr all_paramsparamskeyvalr( path_params query_params header_params form_paramslocal_var_files body_paramsr's r rz+ROCKETMQApi.add_pl_whitelist_with_http_info9sX +&&&2333,---,--- fX&677  HC*$$2478F3KK 8  ? 1 fvV7K7K7=f~7Mdee e     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' H&   #!2'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aadd_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. Trr)r#add_tags_to_resource_with_http_infors r add_tags_to_resourcez ROCKETMQApi.add_tags_to_resource],0'( ::k " " ;4;DKKFKK K=T=dMMfMMTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aadd_tags_to_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.add_tags_to_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AddTagsToResourceRequest body: (required) :return: AddTagsToResourceResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method add_tags_to_resourceNzIMissing the required parameter `body` when calling `add_tags_to_resource`rrrr z=/AddTagsToResource/2023-01-01/rocketmq/post/application_json/r!AddTagsToResourceResponseTr#r)r4s r r@z/ROCKETMQApi.add_tags_to_resource_with_http_infosX +&&&2333,---,--- fX&677  HC*$$68;<F3KK 8  ? 1 jvV7K7K7=f~7Mhii i     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' KV   #!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.associate_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param AssociateAllowListRequest body: (required) :return: AssociateAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r#associate_allow_list_with_http_infors r associate_allow_listz ROCKETMQApi.associate_allow_listrBrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.associate_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param AssociateAllowListRequest body: (required) :return: AssociateAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method associate_allow_listNzIMissing the required parameter `body` when calling `associate_allow_list`rrrr z>/AssociateAllowList/2023-01-01/rocketmq/post/application_json/r!AssociateAllowListResponseTr#r)r4s r rFz/ROCKETMQApi.associate_allow_list_with_http_infoX +&&&2333,---,--- fX&677  HC*$$68;<F3KK 8  ? 1 jvV7K7K7=f~7Mhii i     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Lf   #!6'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAllowListRequest body: (required) :return: CreateAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r create_allow_list_with_http_infors r create_allow_listzROCKETMQApi.create_allow_listG],0'( ::k " " 848HHHH H:T:4JJ6JJTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a create_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateAllowListRequest body: (required) :return: CreateAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method create_allow_listNzFMissing the required parameter `body` when calling `create_allow_list`rrrr z;/CreateAllowList/2023-01-01/rocketmq/post/application_json/r!CreateAllowListResponseTr#r)r4s r rLz,ROCKETMQApi.create_allow_list_with_http_info\X +&&&2333,---,--- fX&677  HC*$$3589F3KK 8  ? 1 gvV7K7K7=f~7Meff f     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' I6   #!3'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupRequest body: (required) :return: CreateGroupResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_group_with_http_infors r create_groupzROCKETMQApi.create_group],0'( ::k " " 343DCCFCC C5T5dEEfEETKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupRequest body: (required) :return: CreateGroupResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method create_groupNzAMissing the required parameter `body` when calling `create_group`rrrr z7/CreateGroup/2023-01-01/rocketmq/post/application_json/r!CreateGroupResponseTr#r)r4s r rSz'ROCKETMQApi.create_group_with_http_infoX +&&&2333,---,--- fX&677  HC*$$.034F3KK 8  ? 1 bvV7K7K7=f~7M`aa a     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Ev   #!/'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_group_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group_async(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupAsyncRequest body: (required) :return: CreateGroupAsyncResponse If the method is called asynchronously, returns the request thread. Trr)r!create_group_async_with_http_infors r create_group_asynczROCKETMQApi.create_group_async ],0'( ::k " " 949$II&II I;T;DKKFKKTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_group_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_group_async_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateGroupAsyncRequest body: (required) :return: CreateGroupAsyncResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method create_group_asyncNzGMissing the required parameter `body` when calling `create_group_async`rrrr z>> thread = api.create_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_instance_with_http_infors r create_instancezROCKETMQApi.create_instancej],0'( ::k " " 646tFFvFF F8T8HHHHTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateInstanceRequest body: (required) :return: CreateInstanceResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method create_instanceNzDMissing the required parameter `body` when calling `create_instance`rrrr z:/CreateInstance/2023-01-01/rocketmq/post/application_json/r!CreateInstanceResponseTr#r)r4s r raz*ROCKETMQApi.create_instance_with_http_infoX +&&&2333,---,--- fX&677  HC*$$1367F3KK 8  ? 1 evV7K7K7=f~7Mcdd d     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' H&   #!2'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_private_link # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_private_link(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePrivateLinkRequest body: (required) :return: CreatePrivateLinkResponse If the method is called asynchronously, returns the request thread. Trr)r"create_private_link_with_http_infors r create_private_linkzROCKETMQApi.create_private_link],0'( ::k " " :4:4JJ6JJ J>> thread = api.create_private_link_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePrivateLinkRequest body: (required) :return: CreatePrivateLinkResponse If the method is called asynchronously, returns the request thread. rrrrrrzEGot an unexpected keyword argument '%s' to method create_private_linkNzHMissing the required parameter `body` when calling `create_private_link`rrrr z=/CreatePrivateLink/2023-01-01/rocketmq/post/application_json/r!CreatePrivateLinkResponseTr#r)r4s r rhz.ROCKETMQApi.create_private_link_with_http_infoX +&&&2333,---,--- fX&677  HC*$$57:;F3KK 8  ? 1 ivV7K7K7=f~7Mghh h     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' KV   #!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a create_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_public_address(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePublicAddressRequest body: (required) :return: CreatePublicAddressResponse If the method is called asynchronously, returns the request thread. Trr)r$create_public_address_with_http_infors r create_public_addressz!ROCKETMQApi.create_public_address,],0'( ::k " " <4T>tNNvNNTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_public_address_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreatePublicAddressRequest body: (required) :return: CreatePublicAddressResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method create_public_addressNzJMissing the required parameter `body` when calling `create_public_address`rrrr z?/CreatePublicAddress/2023-01-01/rocketmq/post/application_json/r!CreatePublicAddressResponseTr#r)r4s r roz0ROCKETMQApi.create_public_address_with_http_infoAX +&&&2333,---,--- fX&677  HC*$$79<=F3KK 8  ? 1 kvV7K7K7=f~7Mijj j     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Mv   #!7'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicRequest body: (required) :return: CreateTopicResponse If the method is called asynchronously, returns the request thread. Trr)rcreate_topic_with_http_infors r create_topiczROCKETMQApi.create_topicrUrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicRequest body: (required) :return: CreateTopicResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method create_topicNzAMissing the required parameter `body` when calling `create_topic`rrrr z7/CreateTopic/2023-01-01/rocketmq/post/application_json/r!CreateTopicResponseTr#r)r4s r rvz'ROCKETMQApi.create_topic_with_http_inforXrc rd|d<|dr|j|fi|S|j|fi|}|S)acreate_topic_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic_async(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicAsyncRequest body: (required) :return: CreateTopicAsyncResponse If the method is called asynchronously, returns the request thread. Trr)r!create_topic_async_with_http_infors r create_topic_asynczROCKETMQApi.create_topic_asyncr\rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)acreate_topic_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.create_topic_async_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param CreateTopicAsyncRequest body: (required) :return: CreateTopicAsyncResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method create_topic_asyncNzGMissing the required parameter `body` when calling `create_topic_async`rrrr z>> thread = api.delete_access_key(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAccessKeyRequest body: (required) :return: DeleteAccessKeyResponse If the method is called asynchronously, returns the request thread. Trr)r delete_access_key_with_http_infors r delete_access_keyzROCKETMQApi.delete_access_keyOrNrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a delete_access_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_access_key_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAccessKeyRequest body: (required) :return: DeleteAccessKeyResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method delete_access_keyNzFMissing the required parameter `body` when calling `delete_access_key`rrrr z;/DeleteAccessKey/2023-01-01/rocketmq/post/application_json/r!DeleteAccessKeyResponseTr#r)r4s r rz,ROCKETMQApi.delete_access_key_with_http_infodrQrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAllowListRequest body: (required) :return: DeleteAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r delete_allow_list_with_http_infors r delete_allow_listzROCKETMQApi.delete_allow_listrNrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a delete_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteAllowListRequest body: (required) :return: DeleteAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method delete_allow_listNzFMissing the required parameter `body` when calling `delete_allow_list`rrrr z;/DeleteAllowList/2023-01-01/rocketmq/post/application_json/r!DeleteAllowListResponseTr#r)r4s r rz,ROCKETMQApi.delete_allow_list_with_http_inforQrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupRequest body: (required) :return: DeleteGroupResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_group_with_http_infors r delete_groupzROCKETMQApi.delete_grouprUrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupRequest body: (required) :return: DeleteGroupResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method delete_groupNzAMissing the required parameter `body` when calling `delete_group`rrrr z7/DeleteGroup/2023-01-01/rocketmq/post/application_json/r!DeleteGroupResponseTr#r)r4s r rz'ROCKETMQApi.delete_group_with_http_info&rXrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_group_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group_async(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupAsyncRequest body: (required) :return: DeleteGroupAsyncResponse If the method is called asynchronously, returns the request thread. Trr)r!delete_group_async_with_http_infors r delete_group_asynczROCKETMQApi.delete_group_asyncrr\rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_group_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_group_async_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupAsyncRequest body: (required) :return: DeleteGroupAsyncResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method delete_group_asyncNzGMissing the required parameter `body` when calling `delete_group_async`rrrr z>> thread = api.delete_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupsRequest body: (required) :return: DeleteGroupsResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_groups_with_http_infors r delete_groupszROCKETMQApi.delete_groupss],0'( ::k " " 444TDDVDD D6T6tFFvFFTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteGroupsRequest body: (required) :return: DeleteGroupsResponse If the method is called asynchronously, returns the request thread. rrrrrrz?Got an unexpected keyword argument '%s' to method delete_groupsNzBMissing the required parameter `body` when calling `delete_groups`rrrr z8/DeleteGroups/2023-01-01/rocketmq/post/application_json/r!DeleteGroupsResponseTr#r)r4s r rz(ROCKETMQApi.delete_groups_with_http_infosX +&&&2333,---,--- fX&677  HC*$$/145F3KK 8  ? 1 cvV7K7K7=f~7Mabb b     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' F   #!0'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_instance(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteInstanceRequest body: (required) :return: DeleteInstanceResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_instance_with_http_infors r delete_instancezROCKETMQApi.delete_instance4rcrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_instance # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_instance_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteInstanceRequest body: (required) :return: DeleteInstanceResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method delete_instanceNzDMissing the required parameter `body` when calling `delete_instance`rrrr z:/DeleteInstance/2023-01-01/rocketmq/post/application_json/r!DeleteInstanceResponseTr#r)r4s r rz*ROCKETMQApi.delete_instance_with_http_infoIrfrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_private_link # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_private_link(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePrivateLinkRequest body: (required) :return: DeletePrivateLinkResponse If the method is called asynchronously, returns the request thread. Trr)r"delete_private_link_with_http_infors r delete_private_linkzROCKETMQApi.delete_private_linkrjrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_private_link # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_private_link_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePrivateLinkRequest body: (required) :return: DeletePrivateLinkResponse If the method is called asynchronously, returns the request thread. rrrrrrzEGot an unexpected keyword argument '%s' to method delete_private_linkNzHMissing the required parameter `body` when calling `delete_private_link`rrrr z=/DeletePrivateLink/2023-01-01/rocketmq/post/application_json/r!DeletePrivateLinkResponseTr#r)r4s r rz.ROCKETMQApi.delete_private_link_with_http_informrc rd|d<|dr|j|fi|S|j|fi|}|S)a delete_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_public_address(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePublicAddressRequest body: (required) :return: DeletePublicAddressResponse If the method is called asynchronously, returns the request thread. Trr)r$delete_public_address_with_http_infors r delete_public_addressz!ROCKETMQApi.delete_public_addressrqrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_public_address # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_public_address_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeletePublicAddressRequest body: (required) :return: DeletePublicAddressResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method delete_public_addressNzJMissing the required parameter `body` when calling `delete_public_address`rrrr z?/DeletePublicAddress/2023-01-01/rocketmq/post/application_json/r!DeletePublicAddressResponseTr#r)r4s r rz0ROCKETMQApi.delete_public_address_with_http_info rtrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicRequest body: (required) :return: DeleteTopicResponse If the method is called asynchronously, returns the request thread. Trr)rdelete_topic_with_http_infors r delete_topiczROCKETMQApi.delete_topicWrUrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_topic # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicRequest body: (required) :return: DeleteTopicResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method delete_topicNzAMissing the required parameter `body` when calling `delete_topic`rrrr z7/DeleteTopic/2023-01-01/rocketmq/post/application_json/r!DeleteTopicResponseTr#r)r4s r rz'ROCKETMQApi.delete_topic_with_http_infolrXrc rd|d<|dr|j|fi|S|j|fi|}|S)adelete_topic_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic_async(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicAsyncRequest body: (required) :return: DeleteTopicAsyncResponse If the method is called asynchronously, returns the request thread. Trr)r!delete_topic_async_with_http_infors r delete_topic_asynczROCKETMQApi.delete_topic_asyncr\rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adelete_topic_async # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.delete_topic_async_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DeleteTopicAsyncRequest body: (required) :return: DeleteTopicAsyncResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method delete_topic_asyncNzGMissing the required parameter `body` when calling `delete_topic_async`rrrr z>> thread = api.describe_access_key_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAccessKeyDetailRequest body: (required) :return: DescribeAccessKeyDetailResponse If the method is called asynchronously, returns the request thread. Trr)r)describe_access_key_detail_with_http_infors r describe_access_key_detailz&ROCKETMQApi.describe_access_key_detail],0'( ::k " " A4A$QQ&QQ QCTCDSSFSSTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a,describe_access_key_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_access_key_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAccessKeyDetailRequest body: (required) :return: DescribeAccessKeyDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method describe_access_key_detailNzOMissing the required parameter `body` when calling `describe_access_key_detail`rrrr zC/DescribeAccessKeyDetail/2023-01-01/rocketmq/post/application_json/r!DescribeAccessKeyDetailResponseTr#r)r4s r rz5ROCKETMQApi.describe_access_key_detail_with_http_info.X +&&&2333,---,--- fX&677  HC*$$<>ABF3KK 8  ? 1 pvV7K7K7=f~7Mnoo o     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' QSY   #!;'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_access_keys # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_access_keys(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAccessKeysRequest body: (required) :return: DescribeAccessKeysResponse If the method is called asynchronously, returns the request thread. Trr)r#describe_access_keys_with_http_infors r describe_access_keysz ROCKETMQApi.describe_access_keyszrBrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_access_keys # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_access_keys_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAccessKeysRequest body: (required) :return: DescribeAccessKeysResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method describe_access_keysNzIMissing the required parameter `body` when calling `describe_access_keys`rrrr z>/DescribeAccessKeys/2023-01-01/rocketmq/post/application_json/r!DescribeAccessKeysResponseTr#r)r4s r rz/ROCKETMQApi.describe_access_keys_with_http_inforJrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_allow_list_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_list_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListDetailRequest body: (required) :return: DescribeAllowListDetailResponse If the method is called asynchronously, returns the request thread. Trr)r)describe_allow_list_detail_with_http_infors r describe_allow_list_detailz&ROCKETMQApi.describe_allow_list_detailrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a,describe_allow_list_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_list_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListDetailRequest body: (required) :return: DescribeAllowListDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method describe_allow_list_detailNzOMissing the required parameter `body` when calling `describe_allow_list_detail`rrrr zC/DescribeAllowListDetail/2023-01-01/rocketmq/post/application_json/r!DescribeAllowListDetailResponseTr#r)r4s r rz5ROCKETMQApi.describe_allow_list_detail_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_allow_lists # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_lists(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListsRequest body: (required) :return: DescribeAllowListsResponse If the method is called asynchronously, returns the request thread. Trr)r#describe_allow_lists_with_http_infors r describe_allow_listsz ROCKETMQApi.describe_allow_lists< rBrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_allow_lists # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_allow_lists_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAllowListsRequest body: (required) :return: DescribeAllowListsResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method describe_allow_listsNzIMissing the required parameter `body` when calling `describe_allow_lists`rrrr z>/DescribeAllowLists/2023-01-01/rocketmq/post/application_json/r!DescribeAllowListsResponseTr#r)r4s r rz/ROCKETMQApi.describe_allow_lists_with_http_infoQ rJrc rd|d<|dr|j|fi|S|j|fi|}|S)a#describe_availability_zones # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_availability_zones(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailabilityZonesRequest body: (required) :return: DescribeAvailabilityZonesResponse If the method is called asynchronously, returns the request thread. Trr)r*describe_availability_zones_with_http_infors r describe_availability_zonesz'ROCKETMQApi.describe_availability_zones ],0'( ::k " " B4B4RR6RR RDTDTTTVTTTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a2describe_availability_zones # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_availability_zones_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeAvailabilityZonesRequest body: (required) :return: DescribeAvailabilityZonesResponse If the method is called asynchronously, returns the request thread. rrrrrrzMGot an unexpected keyword argument '%s' to method describe_availability_zonesNzPMissing the required parameter `body` when calling `describe_availability_zones`rrrr zE/DescribeAvailabilityZones/2023-01-01/rocketmq/post/application_json/r!!DescribeAvailabilityZonesResponseTr#r)r4s r rz6ROCKETMQApi.describe_availability_zones_with_http_info sX +&&&2333,---,--- fX&677  HC*$$=?BCF3KK 8  ? 1 qvV7K7K7=f~7Mopp p     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' SU[   #!='jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_consumed_clients # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_clients(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedClientsRequest body: (required) :return: DescribeConsumedClientsResponse If the method is called asynchronously, returns the request thread. Trr)r(describe_consumed_clients_with_http_infors r describe_consumed_clientsz%ROCKETMQApi.describe_consumed_clients ],0'( ::k " " @4@PPPP PBTB4RR6RRTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a*describe_consumed_clients # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_clients_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedClientsRequest body: (required) :return: DescribeConsumedClientsResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method describe_consumed_clientsNzNMissing the required parameter `body` when calling `describe_consumed_clients`rrrr zC/DescribeConsumedClients/2023-01-01/rocketmq/post/application_json/r!DescribeConsumedClientsResponseTr#r)r4s r rz4ROCKETMQApi.describe_consumed_clients_with_http_info sX +&&&2333,---,--- fX&677  HC*$$;=@AF3KK 8  ? 1 ovV7K7K7=f~7Mmnn n     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' QSY   #!;'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a-describe_consumed_topic_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topic_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicDetailRequest body: (required) :return: DescribeConsumedTopicDetailResponse If the method is called asynchronously, returns the request thread. Trr)r-describe_consumed_topic_detail_with_http_infors r describe_consumed_topic_detailz*ROCKETMQApi.describe_consumed_topic_detail_ ^,0'( ::k " " E4EdUUfUU UGTGWWPVWWTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a<describe_consumed_topic_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topic_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicDetailRequest body: (required) :return: DescribeConsumedTopicDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzPGot an unexpected keyword argument '%s' to method describe_consumed_topic_detailNzSMissing the required parameter `body` when calling `describe_consumed_topic_detail`rrrr zG/DescribeConsumedTopicDetail/2023-01-01/rocketmq/post/application_json/r!#DescribeConsumedTopicDetailResponseTr#r)r4s r rz9ROCKETMQApi.describe_consumed_topic_detail_with_http_infot X +&&&2333,---,--- fX&677  HC*$$@BEFF3KK 8  ? 1 tvV7K7K7=f~7Mrss s     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' UW]   #!?'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_consumed_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicsRequest body: (required) :return: DescribeConsumedTopicsResponse If the method is called asynchronously, returns the request thread. Trr)r'describe_consumed_topics_with_http_infors r describe_consumed_topicsz$ROCKETMQApi.describe_consumed_topics ],0'( ::k " " ?4?OOOO OATA$QQ&QQTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a&describe_consumed_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_consumed_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeConsumedTopicsRequest body: (required) :return: DescribeConsumedTopicsResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method describe_consumed_topicsNzMMissing the required parameter `body` when calling `describe_consumed_topics`rrrr zB/DescribeConsumedTopics/2023-01-01/rocketmq/post/application_json/r!DescribeConsumedTopicsResponseTr#r)r4s r rz3ROCKETMQApi.describe_consumed_topics_with_http_info X +&&&2333,---,--- fX&677  HC*$$:>> thread = api.describe_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsRequest body: (required) :return: DescribeGroupsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_groups_with_http_infors r describe_groupszROCKETMQApi.describe_groups! rcrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsRequest body: (required) :return: DescribeGroupsResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method describe_groupsNzDMissing the required parameter `body` when calling `describe_groups`rrrr z:/DescribeGroups/2023-01-01/rocketmq/post/application_json/r!DescribeGroupsResponseTr#r)r4s r rz*ROCKETMQApi.describe_groups_with_http_info6 rfrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_groups_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_groups_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsDetailRequest body: (required) :return: DescribeGroupsDetailResponse If the method is called asynchronously, returns the request thread. Trr)r%describe_groups_detail_with_http_infors r describe_groups_detailz"ROCKETMQApi.describe_groups_detail ],0'( ::k " " =4=dMMfMM M?T?OOOOTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_groups_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_groups_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeGroupsDetailRequest body: (required) :return: DescribeGroupsDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzHGot an unexpected keyword argument '%s' to method describe_groups_detailNzKMissing the required parameter `body` when calling `describe_groups_detail`rrrr z@/DescribeGroupsDetail/2023-01-01/rocketmq/post/application_json/r!DescribeGroupsDetailResponseTr#r)r4s r rz1ROCKETMQApi.describe_groups_detail_with_http_info X +&&&2333,---,--- fX&677  HC*$$8:=>F3KK 8  ? 1 lvV7K7K7=f~7Mjkk k     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' NPV   #!8'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_instance_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instance_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceDetailRequest body: (required) :return: DescribeInstanceDetailResponse If the method is called asynchronously, returns the request thread. Trr)r'describe_instance_detail_with_http_infors r describe_instance_detailz$ROCKETMQApi.describe_instance_detail rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a&describe_instance_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instance_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstanceDetailRequest body: (required) :return: DescribeInstanceDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method describe_instance_detailNzMMissing the required parameter `body` when calling `describe_instance_detail`rrrr zB/DescribeInstanceDetail/2023-01-01/rocketmq/post/application_json/r!DescribeInstanceDetailResponseTr#r)r4s r rz3ROCKETMQApi.describe_instance_detail_with_http_info rrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_instances # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instances(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstancesRequest body: (required) :return: DescribeInstancesResponse If the method is called asynchronously, returns the request thread. Trr)r!describe_instances_with_http_infors r describe_instanceszROCKETMQApi.describe_instancesD r\rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_instances # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_instances_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeInstancesRequest body: (required) :return: DescribeInstancesResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method describe_instancesNzGMissing the required parameter `body` when calling `describe_instances`rrrr z=/DescribeInstances/2023-01-01/rocketmq/post/application_json/r!DescribeInstancesResponseTr#r)r4s r rz-ROCKETMQApi.describe_instances_with_http_infoY sX +&&&2333,---,--- fX&677  HC*$$469:F3KK 8  ? 1 hvV7K7K7=f~7Mfgg g     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' KV   #!5'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a describe_pl_whitelist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_pl_whitelist(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribePLWhitelistRequest body: (required) :return: DescribePLWhitelistResponse If the method is called asynchronously, returns the request thread. Trr)r$describe_pl_whitelist_with_http_infors r describe_pl_whitelistz!ROCKETMQApi.describe_pl_whitelist rqrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_pl_whitelist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_pl_whitelist_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribePLWhitelistRequest body: (required) :return: DescribePLWhitelistResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method describe_pl_whitelistNzJMissing the required parameter `body` when calling `describe_pl_whitelist`rrrr z?/DescribePLWhitelist/2023-01-01/rocketmq/post/application_json/r!DescribePLWhitelistResponseTr#r)r4s r rz0ROCKETMQApi.describe_pl_whitelist_with_http_info rtrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_regions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_regions(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeRegionsRequest body: (required) :return: DescribeRegionsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_regions_with_http_infors r describe_regionszROCKETMQApi.describe_regions rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_regions # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_regions_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeRegionsRequest body: (required) :return: DescribeRegionsResponse If the method is called asynchronously, returns the request thread. rrrrrrzBGot an unexpected keyword argument '%s' to method describe_regionsNzEMissing the required parameter `body` when calling `describe_regions`rrrr z;/DescribeRegions/2023-01-01/rocketmq/post/application_json/r!DescribeRegionsResponseTr#r)r4s r rz+ROCKETMQApi.describe_regions_with_http_info sX +&&&2333,---,--- fX&677  HC*$$2478F3KK 8  ? 1 fvV7K7K7=f~7Mdee e     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' I6   #!3'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_secret_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_secret_key(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSecretKeyRequest body: (required) :return: DescribeSecretKeyResponse If the method is called asynchronously, returns the request thread. Trr)r"describe_secret_key_with_http_infors r describe_secret_keyzROCKETMQApi.describe_secret_keyg rjrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_secret_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_secret_key_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeSecretKeyRequest body: (required) :return: DescribeSecretKeyResponse If the method is called asynchronously, returns the request thread. rrrrrrzEGot an unexpected keyword argument '%s' to method describe_secret_keyNzHMissing the required parameter `body` when calling `describe_secret_key`rrrr z=/DescribeSecretKey/2023-01-01/rocketmq/post/application_json/r!DescribeSecretKeyResponseTr#r)r4s r rz.ROCKETMQApi.describe_secret_key_with_http_info| rmrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. Trr)r(describe_tags_by_resource_with_http_infors r describe_tags_by_resourcez%ROCKETMQApi.describe_tags_by_resource rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a(describe_tags_by_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_tags_by_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTagsByResourceRequest body: (required) :return: DescribeTagsByResourceResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method describe_tags_by_resourceNzNMissing the required parameter `body` when calling `describe_tags_by_resource`rrrr zB/DescribeTagsByResource/2023-01-01/rocketmq/post/application_json/r!DescribeTagsByResourceResponseTr#r)r4s r rz4ROCKETMQApi.describe_tags_by_resource_with_http_info X +&&&2333,---,--- fX&677  HC*$$;=@AF3KK 8  ? 1 ovV7K7K7=f~7Mmnn n     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' PRX   #!:'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a-describe_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_access_policies(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicAccessPoliciesRequest body: (required) :return: DescribeTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. Trr)r-describe_topic_access_policies_with_http_infors r describe_topic_access_policiesz*ROCKETMQApi.describe_topic_access_policies)rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a<describe_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_access_policies_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicAccessPoliciesRequest body: (required) :return: DescribeTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. rrrrrrzPGot an unexpected keyword argument '%s' to method describe_topic_access_policiesNzSMissing the required parameter `body` when calling `describe_topic_access_policies`rrrr zG/DescribeTopicAccessPolicies/2023-01-01/rocketmq/post/application_json/r!#DescribeTopicAccessPoliciesResponseTr#r)r4s r r z9ROCKETMQApi.describe_topic_access_policies_with_http_info>rrc rd|d<|dr|j|fi|S|j|fi|}|S)a describe_topic_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_detail(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicDetailRequest body: (required) :return: DescribeTopicDetailResponse If the method is called asynchronously, returns the request thread. Trr)r$describe_topic_detail_with_http_infors r describe_topic_detailz!ROCKETMQApi.describe_topic_detailrqrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_topic_detail # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_detail_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicDetailRequest body: (required) :return: DescribeTopicDetailResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method describe_topic_detailNzJMissing the required parameter `body` when calling `describe_topic_detail`rrrr z?/DescribeTopicDetail/2023-01-01/rocketmq/post/application_json/r!DescribeTopicDetailResponseTr#r)r4s r rz0ROCKETMQApi.describe_topic_detail_with_http_infortrc rd|d<|dr|j|fi|S|j|fi|}|S)a describe_topic_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_groups(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicGroupsRequest body: (required) :return: DescribeTopicGroupsResponse If the method is called asynchronously, returns the request thread. Trr)r$describe_topic_groups_with_http_infors r describe_topic_groupsz!ROCKETMQApi.describe_topic_groupsrqrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_topic_groups # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_groups_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicGroupsRequest body: (required) :return: DescribeTopicGroupsResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method describe_topic_groupsNzJMissing the required parameter `body` when calling `describe_topic_groups`rrrr z?/DescribeTopicGroups/2023-01-01/rocketmq/post/application_json/r!DescribeTopicGroupsResponseTr#r)r4s r rz0ROCKETMQApi.describe_topic_groups_with_http_infortrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_topic_queue # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_queue(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicQueueRequest body: (required) :return: DescribeTopicQueueResponse If the method is called asynchronously, returns the request thread. Trr)r#describe_topic_queue_with_http_infors r describe_topic_queuez ROCKETMQApi.describe_topic_queueLrBrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_topic_queue # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topic_queue_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicQueueRequest body: (required) :return: DescribeTopicQueueResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method describe_topic_queueNzIMissing the required parameter `body` when calling `describe_topic_queue`rrrr z>/DescribeTopicQueue/2023-01-01/rocketmq/post/application_json/r!DescribeTopicQueueResponseTr#r)r4s r rz/ROCKETMQApi.describe_topic_queue_with_http_infoarJrc rd|d<|dr|j|fi|S|j|fi|}|S)adescribe_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topics(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsRequest body: (required) :return: DescribeTopicsResponse If the method is called asynchronously, returns the request thread. Trr)rdescribe_topics_with_http_infors r describe_topicszROCKETMQApi.describe_topicsrcrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)adescribe_topics # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.describe_topics_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DescribeTopicsRequest body: (required) :return: DescribeTopicsResponse If the method is called asynchronously, returns the request thread. rrrrrrzAGot an unexpected keyword argument '%s' to method describe_topicsNzDMissing the required parameter `body` when calling `describe_topics`rrrr z:/DescribeTopics/2023-01-01/rocketmq/post/application_json/r!DescribeTopicsResponseTr#r)r4s r r!z*ROCKETMQApi.describe_topics_with_http_inforfrc rd|d<|dr|j|fi|S|j|fi|}|S)adisassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disassociate_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisassociateAllowListRequest body: (required) :return: DisassociateAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r&disassociate_allow_list_with_http_infors r disassociate_allow_listz#ROCKETMQApi.disassociate_allow_list],0'( ::k " " >4>tNNvNN N@T@PPPPTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"disassociate_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.disassociate_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param DisassociateAllowListRequest body: (required) :return: DisassociateAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method disassociate_allow_listNzLMissing the required parameter `body` when calling `disassociate_allow_list`rrrr zA/DisassociateAllowList/2023-01-01/rocketmq/post/application_json/r!DisassociateAllowListResponseTr#r)r4s r r&z2ROCKETMQApi.disassociate_allow_list_with_http_info#X +&&&2333,---,--- fX&677  HC*$$9;>?F3KK 8  ? 1 mvV7K7K7=f~7Mkll l     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' OQW   #!9'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aenable_auto_create_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_auto_create_group(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableAutoCreateGroupRequest body: (required) :return: EnableAutoCreateGroupResponse If the method is called asynchronously, returns the request thread. Trr)r'enable_auto_create_group_with_http_infors r enable_auto_create_groupz$ROCKETMQApi.enable_auto_create_grouporrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a$enable_auto_create_group # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_auto_create_group_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableAutoCreateGroupRequest body: (required) :return: EnableAutoCreateGroupResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method enable_auto_create_groupNzMMissing the required parameter `body` when calling `enable_auto_create_group`rrrr zA/EnableAutoCreateGroup/2023-01-01/rocketmq/post/application_json/r!EnableAutoCreateGroupResponseTr#r)r4s r r-z3ROCKETMQApi.enable_auto_create_group_with_http_infosX +&&&2333,---,--- fX&677  HC*$$:>> thread = api.enable_instance_burst_tps(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableInstanceBurstTpsRequest body: (required) :return: EnableInstanceBurstTpsResponse If the method is called asynchronously, returns the request thread. Trr)r(enable_instance_burst_tps_with_http_infors r enable_instance_burst_tpsz%ROCKETMQApi.enable_instance_burst_tpsrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a(enable_instance_burst_tps # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_instance_burst_tps_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableInstanceBurstTpsRequest body: (required) :return: EnableInstanceBurstTpsResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method enable_instance_burst_tpsNzNMissing the required parameter `body` when calling `enable_instance_burst_tps`rrrr zB/EnableInstanceBurstTps/2023-01-01/rocketmq/post/application_json/r!EnableInstanceBurstTpsResponseTr#r)r4s r r2z4ROCKETMQApi.enable_instance_burst_tps_with_http_infor rc rd|d<|dr|j|fi|S|j|fi|}|S)aenable_instance_inspect # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_instance_inspect(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableInstanceInspectRequest body: (required) :return: EnableInstanceInspectResponse If the method is called asynchronously, returns the request thread. Trr)r&enable_instance_inspect_with_http_infors r enable_instance_inspectz#ROCKETMQApi.enable_instance_inspect1r(rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"enable_instance_inspect # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.enable_instance_inspect_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param EnableInstanceInspectRequest body: (required) :return: EnableInstanceInspectResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method enable_instance_inspectNzLMissing the required parameter `body` when calling `enable_instance_inspect`rrrr zA/EnableInstanceInspect/2023-01-01/rocketmq/post/application_json/r!EnableInstanceInspectResponseTr#r)r4s r r7z2ROCKETMQApi.enable_instance_inspect_with_http_infoFr+rc rd|d<|dr|j|fi|S|j|fi|}|S)aget_inspect_config # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_inspect_config(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetInspectConfigRequest body: (required) :return: GetInspectConfigResponse If the method is called asynchronously, returns the request thread. Trr)r!get_inspect_config_with_http_infors r get_inspect_configzROCKETMQApi.get_inspect_configr\rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aget_inspect_config # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_inspect_config_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetInspectConfigRequest body: (required) :return: GetInspectConfigResponse If the method is called asynchronously, returns the request thread. rrrrrrzDGot an unexpected keyword argument '%s' to method get_inspect_configNzGMissing the required parameter `body` when calling `get_inspect_config`rrrr z>> thread = api.get_instance_inspect_result(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetInstanceInspectResultRequest body: (required) :return: GetInstanceInspectResultResponse If the method is called asynchronously, returns the request thread. Trr)r*get_instance_inspect_result_with_http_infors r get_instance_inspect_resultz'ROCKETMQApi.get_instance_inspect_resultrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a0get_instance_inspect_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.get_instance_inspect_result_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param GetInstanceInspectResultRequest body: (required) :return: GetInstanceInspectResultResponse If the method is called asynchronously, returns the request thread. rrrrrrzMGot an unexpected keyword argument '%s' to method get_instance_inspect_resultNzPMissing the required parameter `body` when calling `get_instance_inspect_result`rrrr zD/GetInstanceInspectResult/2023-01-01/rocketmq/post/application_json/r! GetInstanceInspectResultResponseTr#r)r4s r rAz6ROCKETMQApi.get_instance_inspect_result_with_http_infoX +&&&2333,---,--- fX&677  HC*$$=?BCF3KK 8  ? 1 qvV7K7K7=f~7Mopp p     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' RTZ   #!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a manual_process_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.manual_process_result(body, async_req=True) >>> result = thread.get() :param async_req bool :param ManualProcessResultRequest body: (required) :return: ManualProcessResultResponse If the method is called asynchronously, returns the request thread. Trr)r$manual_process_result_with_http_infors r manual_process_resultz!ROCKETMQApi.manual_process_resultTrqrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amanual_process_result # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.manual_process_result_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ManualProcessResultRequest body: (required) :return: ManualProcessResultResponse If the method is called asynchronously, returns the request thread. rrrrrrzGGot an unexpected keyword argument '%s' to method manual_process_resultNzJMissing the required parameter `body` when calling `manual_process_result`rrrr z?/ManualProcessResult/2023-01-01/rocketmq/post/application_json/r!ManualProcessResultResponseTr#r)r4s r rGz0ROCKETMQApi.manual_process_result_with_http_infoirtrc rd|d<|dr|j|fi|S|j|fi|}|S)amanual_trigger_inspect # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.manual_trigger_inspect(body, async_req=True) >>> result = thread.get() :param async_req bool :param ManualTriggerInspectRequest body: (required) :return: ManualTriggerInspectResponse If the method is called asynchronously, returns the request thread. Trr)r%manual_trigger_inspect_with_http_infors r manual_trigger_inspectz"ROCKETMQApi.manual_trigger_inspectrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amanual_trigger_inspect # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.manual_trigger_inspect_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ManualTriggerInspectRequest body: (required) :return: ManualTriggerInspectResponse If the method is called asynchronously, returns the request thread. rrrrrrzHGot an unexpected keyword argument '%s' to method manual_trigger_inspectNzKMissing the required parameter `body` when calling `manual_trigger_inspect`rrrr z@/ManualTriggerInspect/2023-01-01/rocketmq/post/application_json/r!ManualTriggerInspectResponseTr#r)r4s r rLz1ROCKETMQApi.manual_trigger_inspect_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)amessage_send # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.message_send(body, async_req=True) >>> result = thread.get() :param async_req bool :param MessageSendRequest body: (required) :return: MessageSendResponse If the method is called asynchronously, returns the request thread. Trr)rmessage_send_with_http_infors r message_sendzROCKETMQApi.message_sendrUrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amessage_send # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.message_send_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param MessageSendRequest body: (required) :return: MessageSendResponse If the method is called asynchronously, returns the request thread. rrrrrrz>Got an unexpected keyword argument '%s' to method message_sendNzAMissing the required parameter `body` when calling `message_send`rrrr z7/MessageSend/2023-01-01/rocketmq/post/application_json/r!MessageSendResponseTr#r)r4s r rQz'ROCKETMQApi.message_send_with_http_info+rXrc rd|d<|dr|j|fi|S|j|fi|}|S)a/modify_access_key_all_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_access_key_all_authority(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAccessKeyAllAuthorityRequest body: (required) :return: ModifyAccessKeyAllAuthorityResponse If the method is called asynchronously, returns the request thread. Trr)r.modify_access_key_all_authority_with_http_infors r modify_access_key_all_authorityz+ROCKETMQApi.modify_access_key_all_authorityws^,0'( ::k " " F4FtVVvVV VHTHXXQWXXTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a>modify_access_key_all_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_access_key_all_authority_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAccessKeyAllAuthorityRequest body: (required) :return: ModifyAccessKeyAllAuthorityResponse If the method is called asynchronously, returns the request thread. rrrrrrzQGot an unexpected keyword argument '%s' to method modify_access_key_all_authorityNzTMissing the required parameter `body` when calling `modify_access_key_all_authority`rrrr zG/ModifyAccessKeyAllAuthority/2023-01-01/rocketmq/post/application_json/r!#ModifyAccessKeyAllAuthorityResponseTr#r)r4s r rVz:ROCKETMQApi.modify_access_key_all_authority_with_http_infosX +&&&2333,---,--- fX&677  HC*$$ACFGF3KK 8  ? 1 uvV7K7K7=f~7Mstt t     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' UW]   #!?'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a!modify_access_key_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_access_key_authority(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAccessKeyAuthorityRequest body: (required) :return: ModifyAccessKeyAuthorityResponse If the method is called asynchronously, returns the request thread. Trr)r*modify_access_key_authority_with_http_infors r modify_access_key_authorityz'ROCKETMQApi.modify_access_key_authorityrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a0modify_access_key_authority # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_access_key_authority_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAccessKeyAuthorityRequest body: (required) :return: ModifyAccessKeyAuthorityResponse If the method is called asynchronously, returns the request thread. rrrrrrzMGot an unexpected keyword argument '%s' to method modify_access_key_authorityNzPMissing the required parameter `body` when calling `modify_access_key_authority`rrrr zD/ModifyAccessKeyAuthority/2023-01-01/rocketmq/post/application_json/r! ModifyAccessKeyAuthorityResponseTr#r)r4s r r[z6ROCKETMQApi.modify_access_key_authority_with_http_inforErc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_allow_list(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAllowListRequest body: (required) :return: ModifyAllowListResponse If the method is called asynchronously, returns the request thread. Trr)r modify_allow_list_with_http_infors r modify_allow_listzROCKETMQApi.modify_allow_list9rNrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a modify_allow_list # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_allow_list_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyAllowListRequest body: (required) :return: ModifyAllowListResponse If the method is called asynchronously, returns the request thread. rrrrrrzCGot an unexpected keyword argument '%s' to method modify_allow_listNzFMissing the required parameter `body` when calling `modify_allow_list`rrrr z;/ModifyAllowList/2023-01-01/rocketmq/post/application_json/r!ModifyAllowListResponseTr#r)r4s r r`z,ROCKETMQApi.modify_allow_list_with_http_infoNrQrc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_group_description # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_group_description(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyGroupDescriptionRequest body: (required) :return: ModifyGroupDescriptionResponse If the method is called asynchronously, returns the request thread. Trr)r'modify_group_description_with_http_infors r modify_group_descriptionz$ROCKETMQApi.modify_group_descriptionrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a&modify_group_description # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_group_description_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyGroupDescriptionRequest body: (required) :return: ModifyGroupDescriptionResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method modify_group_descriptionNzMMissing the required parameter `body` when calling `modify_group_description`rrrr zB/ModifyGroupDescription/2023-01-01/rocketmq/post/application_json/r!ModifyGroupDescriptionResponseTr#r)r4s r rez3ROCKETMQApi.modify_group_description_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_instance_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_attributes(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceAttributesRequest body: (required) :return: ModifyInstanceAttributesResponse If the method is called asynchronously, returns the request thread. Trr)r)modify_instance_attributes_with_http_infors r modify_instance_attributesz&ROCKETMQApi.modify_instance_attributesrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a.modify_instance_attributes # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_attributes_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceAttributesRequest body: (required) :return: ModifyInstanceAttributesResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method modify_instance_attributesNzOMissing the required parameter `body` when calling `modify_instance_attributes`rrrr zD/ModifyInstanceAttributes/2023-01-01/rocketmq/post/application_json/r! ModifyInstanceAttributesResponseTr#r)r4s r rjz5ROCKETMQApi.modify_instance_attributes_with_http_infosX +&&&2333,---,--- fX&677  HC*$$<>ABF3KK 8  ? 1 pvV7K7K7=f~7Mnoo o     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' RTZ   #!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)a!modify_instance_charge_type # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_charge_type(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceChargeTypeRequest body: (required) :return: ModifyInstanceChargeTypeResponse If the method is called asynchronously, returns the request thread. Trr)r*modify_instance_charge_type_with_http_infors r modify_instance_charge_typez'ROCKETMQApi.modify_instance_charge_type\rrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a0modify_instance_charge_type # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_charge_type_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceChargeTypeRequest body: (required) :return: ModifyInstanceChargeTypeResponse If the method is called asynchronously, returns the request thread. rrrrrrzMGot an unexpected keyword argument '%s' to method modify_instance_charge_typeNzPMissing the required parameter `body` when calling `modify_instance_charge_type`rrrr zD/ModifyInstanceChargeType/2023-01-01/rocketmq/post/application_json/r! ModifyInstanceChargeTypeResponseTr#r)r4s r roz6ROCKETMQApi.modify_instance_charge_type_with_http_infoqrErc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_instance_spec # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_spec(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceSpecRequest body: (required) :return: ModifyInstanceSpecResponse If the method is called asynchronously, returns the request thread. Trr)r#modify_instance_spec_with_http_infors r modify_instance_specz ROCKETMQApi.modify_instance_specrBrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)amodify_instance_spec # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_instance_spec_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyInstanceSpecRequest body: (required) :return: ModifyInstanceSpecResponse If the method is called asynchronously, returns the request thread. rrrrrrzFGot an unexpected keyword argument '%s' to method modify_instance_specNzIMissing the required parameter `body` when calling `modify_instance_spec`rrrr z>/ModifyInstanceSpec/2023-01-01/rocketmq/post/application_json/r!ModifyInstanceSpecResponseTr#r)r4s r rtz/ROCKETMQApi.modify_instance_spec_with_http_inforJrc rd|d<|dr|j|fi|S|j|fi|}|S)a%modify_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_access_policies(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAccessPoliciesRequest body: (required) :return: ModifyTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. Trr)r+modify_topic_access_policies_with_http_infors r modify_topic_access_policiesz(ROCKETMQApi.modify_topic_access_policiess],0'( ::k " " C4CDSSFSS SETEdUUfUUTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a4modify_topic_access_policies # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_access_policies_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicAccessPoliciesRequest body: (required) :return: ModifyTopicAccessPoliciesResponse If the method is called asynchronously, returns the request thread. rrrrrrzNGot an unexpected keyword argument '%s' to method modify_topic_access_policiesNzQMissing the required parameter `body` when calling `modify_topic_access_policies`rrrr zE/ModifyTopicAccessPolicies/2023-01-01/rocketmq/post/application_json/r!!ModifyTopicAccessPoliciesResponseTr#r)r4s r ryz7ROCKETMQApi.modify_topic_access_policies_with_http_info3sX +&&&2333,---,--- fX&677  HC*$$>@CDF3KK 8  ? 1 rvV7K7K7=f~7Mpqq q     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' SU[   #!='jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)amodify_topic_description # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_description(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicDescriptionRequest body: (required) :return: ModifyTopicDescriptionResponse If the method is called asynchronously, returns the request thread. Trr)r'modify_topic_description_with_http_infors r modify_topic_descriptionz$ROCKETMQApi.modify_topic_descriptionrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a&modify_topic_description # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.modify_topic_description_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ModifyTopicDescriptionRequest body: (required) :return: ModifyTopicDescriptionResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method modify_topic_descriptionNzMMissing the required parameter `body` when calling `modify_topic_description`rrrr zB/ModifyTopicDescription/2023-01-01/rocketmq/post/application_json/r!ModifyTopicDescriptionResponseTr#r)r4s r r~z3ROCKETMQApi.modify_topic_description_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)a%query_dlq_message_by_group_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_dlq_message_by_group_id(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryDLQMessageByGroupIdRequest body: (required) :return: QueryDLQMessageByGroupIdResponse If the method is called asynchronously, returns the request thread. Trr)r,query_dlq_message_by_group_id_with_http_infors r query_dlq_message_by_group_idz)ROCKETMQApi.query_dlq_message_by_group_ids],0'( ::k " " D4DTTTVTT TFTFtVVvVVTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a4query_dlq_message_by_group_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_dlq_message_by_group_id_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryDLQMessageByGroupIdRequest body: (required) :return: QueryDLQMessageByGroupIdResponse If the method is called asynchronously, returns the request thread. rrrrrrzOGot an unexpected keyword argument '%s' to method query_dlq_message_by_group_idNzRMissing the required parameter `body` when calling `query_dlq_message_by_group_id`rrrr zD/QueryDLQMessageByGroupId/2023-01-01/rocketmq/post/application_json/r! QueryDLQMessageByGroupIdResponseTr#r)r4s r rz8ROCKETMQApi.query_dlq_message_by_group_id_with_http_infosX +&&&2333,---,--- fX&677  HC*$$?ADEF3KK 8  ? 1 svV7K7K7=f~7Mqrr r     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' RTZ   #!<'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aquery_dlq_message_by_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_dlq_message_by_id(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryDLQMessageByIdRequest body: (required) :return: QueryDLQMessageByIdResponse If the method is called asynchronously, returns the request thread. Trr)r&query_dlq_message_by_id_with_http_infors r query_dlq_message_by_idz#ROCKETMQApi.query_dlq_message_by_idAr(rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aquery_dlq_message_by_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_dlq_message_by_id_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryDLQMessageByIdRequest body: (required) :return: QueryDLQMessageByIdResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method query_dlq_message_by_idNzLMissing the required parameter `body` when calling `query_dlq_message_by_id`rrrr z?/QueryDLQMessageById/2023-01-01/rocketmq/post/application_json/r!QueryDLQMessageByIdResponseTr#r)r4s r rz2ROCKETMQApi.query_dlq_message_by_id_with_http_infoVX +&&&2333,---,--- fX&677  HC*$$9;>?F3KK 8  ? 1 mvV7K7K7=f~7Mkll l     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' Mv   #!7'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aquery_message_by_msg_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_msg_id(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByMsgIdRequest body: (required) :return: QueryMessageByMsgIdResponse If the method is called asynchronously, returns the request thread. Trr)r&query_message_by_msg_id_with_http_infors r query_message_by_msg_idz#ROCKETMQApi.query_message_by_msg_idr(rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aquery_message_by_msg_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_msg_id_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByMsgIdRequest body: (required) :return: QueryMessageByMsgIdResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method query_message_by_msg_idNzLMissing the required parameter `body` when calling `query_message_by_msg_id`rrrr z?/QueryMessageByMsgId/2023-01-01/rocketmq/post/application_json/r!QueryMessageByMsgIdResponseTr#r)r4s r rz2ROCKETMQApi.query_message_by_msg_id_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)aquery_message_by_msg_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_msg_key(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByMsgKeyRequest body: (required) :return: QueryMessageByMsgKeyResponse If the method is called asynchronously, returns the request thread. Trr)r'query_message_by_msg_key_with_http_infors r query_message_by_msg_keyz$ROCKETMQApi.query_message_by_msg_keyrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"query_message_by_msg_key # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_msg_key_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByMsgKeyRequest body: (required) :return: QueryMessageByMsgKeyResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method query_message_by_msg_keyNzMMissing the required parameter `body` when calling `query_message_by_msg_key`rrrr z@/QueryMessageByMsgKey/2023-01-01/rocketmq/post/application_json/r!QueryMessageByMsgKeyResponseTr#r)r4s r rz3ROCKETMQApi.query_message_by_msg_key_with_http_infoX +&&&2333,---,--- fX&677  HC*$$:>> thread = api.query_message_by_offset(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByOffsetRequest body: (required) :return: QueryMessageByOffsetResponse If the method is called asynchronously, returns the request thread. Trr)r&query_message_by_offset_with_http_infors r query_message_by_offsetz#ROCKETMQApi.query_message_by_offsetdr(rc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a query_message_by_offset # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_offset_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByOffsetRequest body: (required) :return: QueryMessageByOffsetResponse If the method is called asynchronously, returns the request thread. rrrrrrzIGot an unexpected keyword argument '%s' to method query_message_by_offsetNzLMissing the required parameter `body` when calling `query_message_by_offset`rrrr z@/QueryMessageByOffset/2023-01-01/rocketmq/post/application_json/r!QueryMessageByOffsetResponseTr#r)r4s r rz2ROCKETMQApi.query_message_by_offset_with_http_infoysX +&&&2333,---,--- fX&677  HC*$$9;>?F3KK 8  ? 1 mvV7K7K7=f~7Mkll l     V   .K"&/"F"F  #"#" h)-(R(R  )")" n%** '' NPV   #!8'jj--#)::.F#G#G#ZZ(:DAA#ZZ(:;;1(33 3rc rd|d<|dr|j|fi|S|j|fi|}|S)aquery_message_by_timestamp # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_timestamp(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByTimestampRequest body: (required) :return: QueryMessageByTimestampResponse If the method is called asynchronously, returns the request thread. Trr)r)query_message_by_timestamp_with_http_infors r query_message_by_timestampz&ROCKETMQApi.query_message_by_timestamprrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a,query_message_by_timestamp # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_by_timestamp_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageByTimestampRequest body: (required) :return: QueryMessageByTimestampResponse If the method is called asynchronously, returns the request thread. rrrrrrzLGot an unexpected keyword argument '%s' to method query_message_by_timestampNzOMissing the required parameter `body` when calling `query_message_by_timestamp`rrrr zC/QueryMessageByTimestamp/2023-01-01/rocketmq/post/application_json/r!QueryMessageByTimestampResponseTr#r)r4s r rz5ROCKETMQApi.query_message_by_timestamp_with_http_inforrc rd|d<|dr|j|fi|S|j|fi|}|S)a5query_message_trace_by_message_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_trace_by_message_id(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageTraceByMessageIdRequest body: (required) :return: QueryMessageTraceByMessageIdResponse If the method is called asynchronously, returns the request thread. Trr)r0query_message_trace_by_message_id_with_http_infors r !query_message_trace_by_message_idz-ROCKETMQApi.query_message_trace_by_message_id&s_,0'( ::k " " H4HXXQWXX XJTJ4ZZSYZZTKrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aDquery_message_trace_by_message_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.query_message_trace_by_message_id_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param QueryMessageTraceByMessageIdRequest body: (required) :return: QueryMessageTraceByMessageIdResponse If the method is called asynchronously, returns the request thread. rrrrrrzSGot an unexpected keyword argument '%s' to method query_message_trace_by_message_idNzVMissing the required parameter `body` when calling `query_message_trace_by_message_id`rrrr zH/QueryMessageTraceByMessageId/2023-01-01/rocketmq/post/application_json/r!$QueryMessageTraceByMessageIdResponseTr#r)r4s r rz>> thread = api.remove_pl_whitelist(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemovePLWhitelistRequest body: (required) :return: RemovePLWhitelistResponse If the method is called asynchronously, returns the request thread. Trr)r"remove_pl_whitelist_with_http_infors r remove_pl_whitelistzROCKETMQApi.remove_pl_whitelistrjrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)aremove_pl_whitelist # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_pl_whitelist_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemovePLWhitelistRequest body: (required) :return: RemovePLWhitelistResponse If the method is called asynchronously, returns the request thread. rrrrrrzEGot an unexpected keyword argument '%s' to method remove_pl_whitelistNzHMissing the required parameter `body` when calling `remove_pl_whitelist`rrrr z=/RemovePLWhitelist/2023-01-01/rocketmq/post/application_json/r!RemovePLWhitelistResponseTr#r)r4s r rz.ROCKETMQApi.remove_pl_whitelist_with_http_informrc rd|d<|dr|j|fi|S|j|fi|}|S)aremove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. Trr)r(remove_tags_from_resource_with_http_infors r remove_tags_from_resourcez%ROCKETMQApi.remove_tags_from_resourcerrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a(remove_tags_from_resource # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.remove_tags_from_resource_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param RemoveTagsFromResourceRequest body: (required) :return: RemoveTagsFromResourceResponse If the method is called asynchronously, returns the request thread. rrrrrrzKGot an unexpected keyword argument '%s' to method remove_tags_from_resourceNzNMissing the required parameter `body` when calling `remove_tags_from_resource`rrrr zB/RemoveTagsFromResource/2023-01-01/rocketmq/post/application_json/r!RemoveTagsFromResourceResponseTr#r)r4s r rz4ROCKETMQApi.remove_tags_from_resource_with_http_infor rc rd|d<|dr|j|fi|S|j|fi|}|S)aresend_dlq_message_by_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resend_dlq_message_by_id(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResendDLQMessageByIdRequest body: (required) :return: ResendDLQMessageByIdResponse If the method is called asynchronously, returns the request thread. Trr)r'resend_dlq_message_by_id_with_http_infors r resend_dlq_message_by_idz$ROCKETMQApi.resend_dlq_message_by_idIrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)a"resend_dlq_message_by_id # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.resend_dlq_message_by_id_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResendDLQMessageByIdRequest body: (required) :return: ResendDLQMessageByIdResponse If the method is called asynchronously, returns the request thread. rrrrrrzJGot an unexpected keyword argument '%s' to method resend_dlq_message_by_idNzMMissing the required parameter `body` when calling `resend_dlq_message_by_id`rrrr z@/ResendDLQMessageById/2023-01-01/rocketmq/post/application_json/r!ResendDLQMessageByIdResponseTr#r)r4s r rz3ROCKETMQApi.resend_dlq_message_by_id_with_http_info^rrc rd|d<|dr|j|fi|S|j|fi|}|S)areset_consumed_offsets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.reset_consumed_offsets(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetConsumedOffsetsRequest body: (required) :return: ResetConsumedOffsetsResponse If the method is called asynchronously, returns the request thread. Trr)r%reset_consumed_offsets_with_http_infors r reset_consumed_offsetsz"ROCKETMQApi.reset_consumed_offsetsrrc 4dg}|d|d|d|dt}tj|dD] \}}||vrt d|z|||<!|d=|jjrd|vs|dtd i}i}g} i} g} i} d} d|vr|d} |jd g| d <|j d g| d <d g}|j dd|| | | | | d|| d| d| dd| d|S)areset_consumed_offsets # noqa: E501 This method makes a synchronous HTTP request by default. To make an asynchronous HTTP request, please pass async_req=True >>> thread = api.reset_consumed_offsets_with_http_info(body, async_req=True) >>> result = thread.get() :param async_req bool :param ResetConsumedOffsetsRequest body: (required) :return: ResetConsumedOffsetsResponse If the method is called asynchronously, returns the request thread. rrrrrrzHGot an unexpected keyword argument '%s' to method reset_consumed_offsetsNzKMissing the required parameter `body` when calling `reset_consumed_offsets`rrrr z@/ResetConsumedOffsets/2023-01-01/rocketmq/post/application_json/r!ResetConsumedOffsetsResponseTr#r)r4s r rz1ROCKETMQApi.reset_consumed_offsets_with_http_inforrr)__name__ __module__ __qualname____doc__r rrrAr@rGrFrMrLrTrSr[rZrbrarirhrprorwrvr|r{rrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrrr rrrrrrr"r!r'r&r.r-r3r2r8r7r=r<rBrArHrGrMrLrRrQrWrVr\r[rar`rfrerkrjrprorurtrzryrr~rrrrrrrrrrrrrrrrrrrrrrrr rrs  %%%% *J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3X*J3J3J3J3J3rr)r __future__rrer,robjectrrrr rs'&&&&&  qk3qk3qk3qk3qk3&qk3qk3qk3qk3qk3r