检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS
PushConsumer, ConsumeStatus def callback(msg): print(msg.id, msg.body, msg.get_property('property')) return ConsumeStatus.CONSUME_SUCCESS
return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT; } return ConsumeOrderlyStatus.SUCCESS
请求参数 无 响应参数 状态码: 200 表2 响应Body参数 参数 参数类型 描述 access_key String 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。 secret_key String 密钥。 8-32个字符。
message_trace_enable,features.pod.token.access,log.enable,features.log.collection,max.connections,rabbitmq.manage.support,replica_port_standalone
iam.cn-north-4.myhuaweicloud.com/v3.0/OS-USER/users Content-Type: application/json X-Sdk-Date: 20240416T095341Z Authorization: SDK-HMAC-SHA256 Access
表4 trace 参数 参数类型 描述 success Boolean 是否成功。 trace_type String 轨迹类型 timestamp Number 时间。 group_name String 生产组或消费组。 cost_time Number 耗时。
表4 User 参数 参数类型 描述 access_key String 用户名,只能英文字母开头,且由英文字母、数字、中划线、下划线组成,长度为7~64个字符。 secret_key String 密钥。 8-32个字符。
= nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } err = p.Shutdown
= nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } } time.Sleep
请联系技术支持 400 DMS.00400128 Invalid public access parameters. 公网访问参数错误。
您需要有RocketMQ的管理员权限“DMS FullAccess”,具体操作请参考创建用户并授权使用DMS for RocketMQ。 创建VPC和子网。 创建的VPC与RocketMQ实例必须在相同的区域。
2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 90000 25000 8000 8000 rocketmq.12u24g.cluster
>=0 RocketMQ实例节点 1分钟 broker_produce_success_rate 生产成功率 节点所有生产请求的成功率 单位:% 说明: 2022年5月16号及以后购买的实例,支持此监控项。
POST https://{endpoint}/v2/rocketmq/{project_id}/instances/{instance_id}/extend { "oper_type" : "horizontal", "new_product_id" : "c6.4u8g.cluster
2000 2000 rocketmq.4u8g.cluster 1 ~ 10 300 ~ 60000 20000 4000 4000 rocketmq.8u16g.cluster 1 ~ 10 300 ~ 90000 25000 8000 8000 rocketmq.12u24g.cluster
实例当前规格无法满足业务需要,于2023/03/20 9:00:00升配为rocketmq.8u16g.cluster*1。
连接实例失败,报错RemotingTooMuchRequestException: sendDefaultImpl call timeout 问题现象 连接RocketMQ实例失败,报错“RemotingTooMuchRequestException: sendDefaultImpl
c6.4u8g.cluster.small:单个代理最大Topic数2000,单个代理最大消费组数2000 c6.4u8g.cluster:单个代理最大Topic数4000,单个代理最大消费组数4000 c6.8u16g.cluster:单个代理最大Topic数8000,单个代理最大消费组数
{ "resend_results" : [ { "msg_id" : "C0A8149E0000277600000000000B6835", "error_code" : "DMS.00000000", "error_message" : "Success