-
使用ACL权限访问 - 分布式消息服务RocketMQ版
return msg def send_message_sync(): producer = Producer(gid) producer.set_name_server_address(name_srv) # 设置权限(角色名和密钥) producer.set_session_credentials
-
实例规格变更 - 分布式消息服务RocketMQ版
new_product_id 否 String 当oper_type类型是vertical时,该参数才有效且必填。 new_broker_num 否 Integer 代理数量 当oper_type参数为horizontal时,该参数必填。
-
删除元数据迁移任务 - 分布式消息服务RocketMQ版
fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
查询指定消费组 - 分布式消息服务RocketMQ版
{ "name" : "test", "enabled" : true, "broadcast" : true, "brokers" : [ "broker-0" ], "permissions" : [ ], "retry_max_time" : 10,
-
删除指定主题 - 分布式消息服务RocketMQ版
(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer
-
查询单个主题 - 分布式消息服务RocketMQ版
total_read_queue_num Number 总读队列个数。 total_write_queue_num Number 总写队列个数。 permission String 权限。 brokers Array of brokers objects 关联的代理。
-
查询消息 - 分布式消息服务RocketMQ版
born_timestamp Number 产生消息的时间。 reconsume_times Integer 重试次数。 body String 消息体。 body_crc Number 消息体校验和。 store_size Number 存储大小。
-
删除指定消费组 - 分布式消息服务RocketMQ版
= client.DeleteConsumerGroup(request) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } }
-
快速入门 - 分布式消息服务RocketMQ版
broker_num:代理个数。
-
查询项目标签 - 分布式消息服务RocketMQ版
fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
重发死信消息 - 分布式消息服务RocketMQ版
error_code String 错误码。 error_message String 错误信息。 请求示例 重发死信消息。
-
查询主题消费组列表 - 分布式消息服务RocketMQ版
表2 Query参数 参数 是否必选 参数类型 描述 limit 否 Integer 当次查询返回的最大个数,默认值为10,取值范围为1~50。 offset 否 Integer 偏移量,表示从此偏移量开始查询,offset大于等于0。
-
删除指定的实例 - 分布式消息服务RocketMQ版
) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签
-
查询实例标签 - 分布式消息服务RocketMQ版
) if err == nil { fmt.Printf("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签
-
批量修改消费组 - 分布式消息服务RocketMQ版
) print(e.error_msg) 批量修改消费组的参数,将consumer-group-test消费组的最大重试次数修改为16。
-
创建用户 - 分布式消息服务RocketMQ版
DefaultGroupPerm: &defaultGroupPermUser, DefaultTopicPerm: &defaultTopicPermUser, Admin: &adminUser, WhiteRemoteAddress: &whiteRemoteAddressUser
-
计费样例 - 分布式消息服务RocketMQ版
实例当前规格无法满足业务需要,于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。
-
审计与日志 - 分布式消息服务RocketMQ版
审计与日志 云审计服务(Cloud Trace Service,简称CTS),是华为云安全解决方案中专业的日志审计服务,提供对各种云资源操作记录的收集、存储和查询功能,可用于支撑安全分析、合规审计、资源跟踪和问题定位等常见应用场景。
-
查询可用区信息 - 分布式消息服务RocketMQ版
("%+v\n", response) } else { fmt.Println(err) } } 更多编程语言的SDK代码示例,请参见API Explorer的代码示例页签,可生成自动对应的SDK代码示例。
-
快速连接RocketMQ并生产消费消息 - 分布式消息服务RocketMQ版
弹性云服务器 在连接RocketMQ实例之前,需要先购买弹性云服务器(Elastic Cloud Server,以下简称ECS),JDK安装、环境变量配置。本文以Linux系统的ECS为例,Windows系统ECS的JDK安装与环境变量配置可自行在互联网查找相关帮助。