检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Key进行通配符匹配,然后将消息路由到匹配成功的Queue中。 headers:该类型Exchange与Routing Key无关,而与消息中的Headers属性信息相关。Exchange根据消息中的Headers属性键值对和绑定的属性键值对进行匹配,根据匹配情况路由消息。 Durability
credentials = pika.PlainCredentials(conf['username'], conf['password']) parameters = pika.ConnectionParameters(conf['host'],
createDMSInstanceOrderSuccess 创建DMS实例订单失败 rabbitmq createDMSInstanceOrderFailure 修改DMS实例订单成功 rabbitmq modifyDMSInstanceOrderSuccess 修改DMS实例订单失败
3。 Header Exchange 工作原理: 将一个Queue绑定到某个Header Exchange上,并设置绑定属性键值对。 将消息发送给Header Exchange时,需要设置消息的Header属性键值对,Header Exchange根据消息Headers属性键值对和绑定属性键值对的匹配情况路由消息。
RabbitMQ的所有系统权限。 表1 DMS for RabbitMQ系统权限 系统角色/策略名称 描述 类别 依赖关系 DMS FullAccess 分布式消息服务管理员权限,拥有该权限的用户可以操作所有分布式消息服务的功能。 系统策略 无 DMS UserAccess 分布式
"channels", "queues", "consumers", "messages_ready", "messages_unacknowledged", "publish", "deliver", "deliver_no_ack", "deliver_get", "instance_bytes_in_rate"
RequestTimeoutException; import com.huaweicloud.sdk.core.exception.ServiceResponseException; import com.huaweicloud.sdk.rabbitmq.v2.region.RabbitMQRegion;
response, err := client.ShowRabbitMqTags(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.CreateVhost(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
表1 Query参数 参数 是否必选 参数类型 描述 instance_id 是 String 实例ID。 product_id 是 String 产品ID。 请求参数 无 响应参数 状态码:200 表2 响应Body参数 参数 参数类型 描述 core_num Integer 核数
response, err := client.DeleteBackgroundTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
response, err := client.ShowBackgroundTask(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err)
分布式消息服务RabbitMQ版完全兼容开源RabbitMQ,为您提供即开即用、消息特性丰富、灵活路由、高可用、监控和告警等特性,广泛应用于秒杀、流控、系统解耦等场景。 即开即用 分布式消息服务RabbitMQ版提供单机和集群的消息实例,拥有丰富内存规格,您可以通过控制台直接下单购买并创建,无需单独准备服务器资源。
response, err := client.ResetPassword(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
不能与名称或倒序的名称相同。 vhosts 是 Array of AMQPUserPerm objects 参数解释: 需要配置权限的Vhost,一个用户可以配置多个Vhost下的资源权限。 表3 AMQPUserPerm 参数 是否必选 参数类型 描述 vhost 是 String 参数解释:
response, err := client.ListPlugins(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) }
默认取值: 不涉及。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 参数解释: 分页查询偏移量,表示从此偏移量开始查询。 约束限制: 不涉及。 取值范围: 大于等于0。 默认取值: 0。 limit 否 Integer 参数解释: 分页查询单页数量。
&model.DeleteInstanceRequest{} request.InstanceId = "{instance_id}" response, err := client.DeleteInstance(request) if err == nil {
取值范围: 不涉及。 user_id String 参数解释: 用户ID。 取值范围: 不涉及。 user_name String 参数解释: 用户名。 取值范围: 不涉及。 order_id String 参数解释: 订单ID,只有在包周期计费时才会有order_id值,其他计费方式order_id值为空。
题导致宕机。 Delivery limit 无需配置,固定值,默认16次。 需要配置。 Dead letter exchange 支持。 支持。 Dead letter routing key 支持。 支持。 Single active consumer 不支持。 支持。