华为云用户手册

开源SDK列表 分布式消息服务RabbitMQ版支持所有开源版本的SDK，常见的开源SDK如表1所示。 表1 开源SDK列表 编程语言 SDK Java rabbitmq-java-client Spring Framework SpringAMQP .Net rabbitmq-dotnet-client Python pika PHP php-amqplib C rabbitmq-c Go amqp091-go 推荐使用最新Release版本的SDK。

客户端网络环境说明 客户端可以通过以下方式访问RabbitMQ实例： VPC内子网地址访问 如果客户端是云上E CS ，与RabbitMQ实例处于同region同VPC，则可以直接访问RabbitMQ实例提供的VPC内子网地址。 VPC对等连接方式访问 如果客户端是云上ECS，与RabbitMQ实例处于相同region但不同VPC，则可以通过建立VPC对等连接后，访问RabbitMQ实例提供的VPC内子网地址。 关于创建和使用VPC对等连接，可参考VPC对等连接说明。 公网访问 客户端在其他网络环境，或者与RabbitMQ实例处于不同region，则访问实例的公网地址。 不同网络环境，对于客户端配置来说，只是连接地址的差异，其他都一样。因此，本手册以同一VPC内子网地址的方式，介绍客户端开发环境搭建。 遇到连接超时或失败时，请注意确认网络是否连通。可使用telnet方式，检测实例连接地址与端口。

（可选）在application.properties文件中填写配置 如果RabbitMQ实例已开启SSL，在“application.properties”文件中填写如下配置。 #开启SSL认证spring.rabbitmq.ssl.enabled=true#SSL使用的算法spring.rabbitmq.ssl.algorithm=TLSv1.2#是否启用主机验证spring.rabbitmq.ssl.verify-hostname=false#是否启用服务端证书验证spring.rabbitmq.ssl.validate-server-certificate=false

生产消息 以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 SSL认证方式 import pikaimport ssl# 连接信息conf = { 'host': 'ip', 'port': 5671, 'queue_name': 'queue-test', 'username': 'root', 'password': 'password'}context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)credentials = pika.PlainCredentials(conf['username'], conf['password'])parameters = pika.ConnectionParameters(conf['host'], conf['port'], '/', credentials, ssl_options=pika.SSLOptions(context))connection = pika.BlockingConnection(parameters)channel = connection.channel()channel.queue_declare(conf['queue_name'])data = bytes('Hello World!', encoding='utf-8')channel.basic_publish(exchange='', routing_key=conf['queue_name'], body=data)print(" [x] Sent 'Hello World!'")connection.close() 非SSL认证方式 import pika# 连接信息conf = { 'host': 'ip', 'port': 5672, 'queue_name': 'queue-test', 'username': 'root', 'password': 'password'}credentials = pika.PlainCredentials(conf['username'], conf['password'])parameters = pika.ConnectionParameters(conf['host'], conf['port'], '/', credentials)connection = pika.BlockingConnection(parameters)channel = connection.channel()channel.queue_declare(conf['queue_name'])data = bytes("Hello World!", encoding="utf-8")channel.basic_publish(exchange='', routing_key=conf['queue_name'], body=data)print(" [x] Sent 'Hello World!'")connection.close()

SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在 SDK中心 查询版本信息。 表1提供了DCS服务支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导 Go huaweicloud-sdk-go-v3 Go SDK使用指导 .NET huaweicloud-sdk-net-v3 .Net SDK使用指导 本文档中的SDK，是指API所封装的SDK，不是Redis开源客户端的SDK。 Redis开源客户端的SDK建议访问开源社区，如果您需要了解客户端连接实例的内容，请参考连接Redis缓存实例。

消费消息 以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 SSL认证方式 import pikaimport ssl# 连接信息conf = { 'host': 'ip', 'port': 5671, 'queue_name': 'queue-test', 'username': 'root', 'password': 'password'}context = ssl.SSLContext(ssl.PROTOCOL_TLSv1_2)credentials = pika.PlainCredentials(conf['username'], conf['password'])parameters = pika.ConnectionParameters(conf['host'], conf['port'], '/', credentials, ssl_options=pika.SSLOptions(context))connection = pika.BlockingConnection(parameters)channel = connection.channel()channel.queue_declare(conf['queue_name'])def callback(ch, method, properties, body): print(" [x] Received %r" % body.decode('utf-8'))channel.basic_consume(queue=conf['queue_name'], on_message_callback=callback, auto_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')channel.start_consuming() 非SSL认证方式 import pika# 连接信息conf = { 'host': 'ip', 'port': 5672, 'queue_name': 'queue-test', 'username': 'root', 'password': 'password'}credentials = pika.PlainCredentials(conf['username'], conf['password'])parameters = pika.ConnectionParameters(conf['host'], conf['port'], '/', credentials)connection = pika.BlockingConnection(parameters)channel = connection.channel()channel.queue_declare(conf['queue_name'])def callback(ch, method, properties, body): print(" [x] Received %r" % body.decode('utf-8'))channel.basic_consume(queue=conf['queue_name'], on_message_callback=callback, auto_ack=True)print(' [*] Waiting for messages. To exit press CTRL+C')channel.start_consuming()

SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在SDK中心查询版本信息。 表1提供了 云桌面Workspace 服务支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导 Go huaweicloud-sdk-go-v3 Go SDK使用指导

SDK列表 在开始使用之前，请确保您安装的是最新版本的SDK。使用过时的版本可能会导致兼容性问题或无法使用最新功能。您可以在SDK中心查询版本信息。 表1提供了 SMN 服务支持的SDK列表，您可以在GitHub仓库查看SDK更新历史、获取安装包以及查看指导文档。 表1 SDK列表 编程语言 Github地址 参考文档 Java huaweicloud-sdk-java-v3 Java SDK使用指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导 Go huaweicloud-sdk-go-v3 Go SDK使用指导 .NET huaweicloud-sdk-net-v3 .Net SDK使用指导 NodeJS huaweicloud-sdk-nodejs-v3 NodeJS SDK使用指导 PHP huaweicloud-sdk-php-v3 PHP SDK使用指导

响应示例 状态码： 200 Successful { "organizational_units" : [ { "id" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "urn" : "organizations::0a6d25d23900d45c0faac010e0fb4de0:ou:o-fhkmi6mek7wlqdp6nideqhb47qwtjdsv/ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "name" : "autoOU0923152729270Pkgk", "created_at" : "2022-09-23T07:27:28Z" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

响应示例 状态码： 200 Successful. { "delegated_administrators" : [ { "delegation_enabled_at" : "autoservice0922102321263V58H", "account_id" : "0a6d25d23900d45c0faac010e0fb4de0", "account_urn" : "urnstring", "join_method" : "invited", "joined_at" : "2022-08-24T06:41:15Z", "account_name" : "paas_iam_573331" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 organizational_units Array of OrganizationalUnitDto objects 组织单元列表。 page_info PageInfoDto object 分页信息 表4 OrganizationalUnitDto 参数 参数类型 描述 id String 与组织单元关联的唯一标识符（ID）。 urn String 组织单元的统一资源名称。 name String 组织单元的名称。 created_at String 组织单元的创建时间。 表5 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 tags Array of TagDto objects 标签列表。 page_info PageInfoDto object 分页信息 表5 TagDto 参数 参数类型 描述 key String 标签键的密钥标识符或名称。 value String 与标签键关联的字符串值。您可以将标签的值设置为空字符串，但不能将标签的值设置为NULL。 表6 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应示例 状态码： 200 Successful. { "tags" : [ { "key" : "auto09230Uv5key", "value" : "auto0923XXFmvalue" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

URI GET https://{endpoint}/v1/organizations/{resource_type}/{resource_id}/tags 表1 路径参数 参数 是否必选 参数类型 描述 resource_type 是 String 资源类型。枚举值：organizations:policies（服务策略）、organizations:ous（组织OU）、organizations:accounts（账号信息） 、organizations:roots：（根）。 resource_id 是 String 根、组织单元、账号或策略的唯一标识符（ID）。 表2 Query参数 参数 是否必选 参数类型 描述 limit 否 Integer 页面中最大结果数量。 marker 否 String 分页标记。

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 delegated_administrators Array of DelegatedAdministratorDto objects 组织中委托管理员列表。 page_info PageInfoDto object 分页信息 表4 DelegatedAdministratorDto 参数 参数类型 描述 delegation_enabled_at String 将账号设置为委托管理员的日期。 account_id String 账号的唯一标识符（ID）。 account_urn String 账号的统一资源名称。 join_method String 账号加入组织的方式,invited：邀请加入，created：创建加入。 joined_at String 账号成为组织一部分的日期。 account_name String 账号名称 表5 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 create_account_statuses Array of CreateAccountStatusDto objects 包含有关请求的详细信息的对象列表。 page_info PageInfoDto object 分页信息 表4 CreateAccountStatusDto 参数 参数类型 描述 account_id String 如果账号创建成功，则为新账号的唯一标识符（ID）。 account_name String 账号名称 completed_at String 创建账号和完成请求的日期和时间。 created_at String 请求创建账号的日期和时间。 id String 请求的唯一标识符（ID）。您可以从创建账号的初始CreateAccount请求的响应中获得此值。 state String 创建账号的异步请求的状态，in_progress：处理中，succeeded：成功，failed：失败。 failure_reason String 如果请求失败，则说明失败原因。 表5 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应示例 状态码： 200 Successful { "create_account_statuses" : [ { "account_id" : "0a6d25d23900d45c0faac010e0fb4de0", "account_name" : "paas_iam_573331", "completed_at" : "2022-08-24T06:41:15Z", "created_at" : "2022-08-24T06:41:15Z", "id" : "h-awjp43m7bz3b8jgy5v61jrfwakt3og8w", "state" : "in_progress", "failure_reason" : "string" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

URI GET https://{endpoint}/v1/organizations/create-account-status 表1 Query参数 参数 是否必选 参数类型 描述 states 否 Array of strings 要包含在响应中的一个或多个状态的列表。如果此参数不存在，则所有请求都包含在响应中。 limit 否 Integer 页面中最大结果数量。 marker 否 String 分页标记。

URI GET https://{endpoint}/v1/organizations/policies/{policy_id}/attached-entities 表1 路径参数 参数 是否必选 参数类型 描述 policy_id 是 String 策略的唯一标识符（ID）。 表2 Query参数 参数 是否必选 参数类型 描述 limit 否 Integer 页面中最大结果数量。 marker 否 String 分页标记。

响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 attached_entities Array of EntityDto objects 结构列表，每个结构都包含有关指定策略附加到的实体的详细信息。 page_info PageInfoDto object 分页信息 表5 EntityDto 参数 参数类型 描述 name String 实体的名称。 id String 实体的唯一标识符（ID）。 type String 实体的类型。account：账号；organizational_unit：组织单元；root：根。 表6 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应示例 状态码： 200 Successful. { "attached_entities" : [ { "name" : "paas_iam_573331", "id" : "05261f923e80d3890f33c0056e9b3f80", "type" : "account" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

响应示例 状态码： 200 Successful. { "delegated_services" : [ { "service_principal" : "autoservice0922102321263V58H", "delegation_enabled_at" : "2022-09-22T02:23:21Z" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

响应参数 状态码： 200 表2 响应Body参数 参数 参数类型 描述 services Array of TagPolicyServiceDto objects 被添加到标签策略强制执行的资源类型。 表3 TagPolicyServiceDto 参数 参数类型 描述 service_name String 服务名称。 resource_types Array of strings 资源类型。 support_all Boolean resource_type是否支持全量选择，即*

响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 delegated_services Array of DelegatedServiceDto objects 账号是其委托管理员的服务。 page_info PageInfoDto object 分页信息 表5 DelegatedServiceDto 参数 参数类型 描述 service_principal String 服务主体的名称。 delegation_enabled_at String 账号成为此服务的委托管理员的日期。 表6 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应示例 状态码： 200 Successful. { "handshakes" : [ { "id" : "h-2tnfkrhe64qokwripd2kqrhd7d3079u5", "urn" : "organizations::0a6d25d23900d45c0faac010e0fb4de0:ou:o-fhkmi6mek7wlqdp6nideqhb47qwtjdsv/ou-fi0rv9jbjgc6nifokh65jjo8c24fnujv", "updated_at" : "2022-09-23T07:38:15Z", "created_at" : "2022-09-23T07:38:15Z", "management_account_id" : "0a6d25d23900d45c0faac010e0fb4de0", "management_account_name" : "paas_iam_573331", "organization_id" : "o-fhkmi6mek7wlqdp6nideqhb47qwtjdsv", "notes" : "test-notes", "target" : { "type" : "account", "entity" : "644c579bea6d473e8ce386e0e8ec449d" }, "status" : "cancelled" } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

URI GET https://{endpoint}/v1/organizations/accounts/{account_id}/delegated-services 表1 路径参数 参数 是否必选 参数类型 描述 account_id 是 String 账号的唯一标识符（ID）。 表2 Query参数 参数 是否必选 参数类型 描述 limit 否 Integer 页面中最大结果数量。 marker 否 String 分页标记。

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 handshakes Array of HandshakeDto objects 邀请（握手）对象的列表，其中包含与指定账号关联的每个邀请（握手）的详细信息。 page_info PageInfoDto object 分页信息 表4 HandshakeDto 参数 参数类型 描述 id String 邀请（握手）的唯一标识符（ID）。源账号在发起邀请（握手）时创建ID。 urn String 邀请（握手）的统一资源名称。 updated_at String 邀请（握手）请求被接受、取消、拒绝或到期的日期和时间。 created_at String 提出邀请（握手）请求的日期和时间。 expired_at String 邀请（握手）过期的日期和时间。 management_account_id String 组织管理账号的唯一标识符（ID）。 management_account_name String 组织管理账号的名称。 organization_id String 组织的唯一标识符（ID）。 notes String 给收件账号所有者的邮件中的附加信息。 target TargetDto object 要邀请加入组织的账号的标识符（ID）。 status String 邀请（握手）的当前状态, pending：邀请中；accepted：接受邀请；cancelled：取消邀请；declined：拒绝邀请；expired：邀请过期。 表5 TargetDto 参数 参数类型 描述 type String 目标类型，account：账户id，name：账户名称。 entity String 如果指定 'type:account'，则必须提供账号ID作为实体。如果指定 'type:name'，则必须指定账号名称作为实体。 表6 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 accounts Array of AccountDto objects 组织中的账号列表。 page_info PageInfoDto object 分页信息 表4 AccountDto 参数 参数类型 描述 id String 账号的唯一标识符（ID）。 urn String 账号的统一资源名称。 join_method String 账号加入组织的方式。invited：邀请加入，created：创建加入。 status String 账号当前的状态。active：有效； suspended：已关闭； pending_closure：关闭中。 joined_at String 账号加入组织的日期。 name String 账号名称 mobile_phone String 手机号码 intl_number_prefix String 手机号前缀。 email String 与此账号关联的电子邮件地址。 description String 描述信息。 表5 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量

响应示例 状态码： 200 Successful. { "accounts" : [ { "id" : "05261f923e80d3890f33c0056e9b3f80", "urn" : "organizations::0a6d25d23900d45c0faac010e0fb4de0:account:o-fhkmi6mek7wlqdp6nideqhb47qwtjdsv/05261f923e80d3890f33c0056e9b3f80", "join_method" : "invited", "joined_at" : "2022-08-24T06:41:15Z", "name" : "paas_iam_573331", "status" : "active", "mobile_phone" : "null,", "intl_number_prefix" : "null,", "email" : null } ], "page_info" : { "next_marker" : "ou-taowxgy4xbme6m4x3c2iijbxw7yj8fcw", "current_count" : 100 }}

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 entities Array of EntityDto objects 组织中的根、组织单元和账号的列表。 page_info PageInfoDto object 分页信息 表4 EntityDto 参数 参数类型 描述 name String 实体的名称。 id String 实体的唯一标识符（ID）。 type String 实体的类型。account：账号；organizational_unit：组织单元；root：根。 表5 PageInfoDto 参数 参数类型 描述 next_marker String 如果存在，则表示可用的输出比当前响应中包含的输出多。在对操作的后续调用中，在标签请求参数中使用此值，以获取输出的下一部分。您应该重复此操作，直到next_marker响应元素返回为null。 current_count Integer 本页返回条目数量