检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
//ACL_ACCESS_KEY为用户名,ACL_SECRET_KEY为用户的密钥。创建用户的步骤,请参见创建用户。用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SessionCredentialsProvider
store_timestamp 存储消息的时间。 born_timestamp 产生消息的时间。 reconsume_times 重试次数。 body 消息体。 body_crc 消息体校验和,用来检查消息体数据是否正确。 store_size 存储大小。 property_list 消息属性列表。
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class UpdateRocketMqConfigsSolution
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class CreateUserSolution {
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class BatchCreateOrDeleteRocketmqTagSolution
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class CreateRocketMqMigrationTaskSolution
页面。 RocketMQ实例支持通过筛选来查询对应的RocketMQ实例。当前支持的筛选条件为状态、名称、版本、实例类型、规格、已用/可用存储空间、计费模式、可用区、企业项目和标签。RocketMQ实例状态请参见表1。 表1 RocketMQ实例状态说明 状态 说明 创建中 创建
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class BatchUpdateConsumerGroupSolution
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class CreateTopicOrBatchDeleteTopicSolution
实例可靠性是怎么保障的? 通过以下两方面保障实例的可靠性: RocketMQ实例采用一主两备的方式存储数据 RocketMQ实例支持跨AZ部署 父主题: 实例问题
实例规格单价请参见分布式消息服务RocketMQ版价格详情中的“实例价格”。 存储空间费用 计费因子:云硬盘类型、容量 包年/包月、按需计费 云硬盘单价 * 购买时长 云硬盘单价请参见分布式消息服务RocketMQ版价格详情中的“存储价格”。 弹性TPS费用 5.x专业版时,如果开启弹性TPS功
dms:instance:create √ √ 查询所有实例列表 GET /v2/{project_id}/instances dms:instance:list √ √ 查询指定实例 GET /v2/{project_id}/instances/{instance_id} dms:instance:get
offset消息ID。 tags String 消息的标签。 keys String 消息的keys。 store_host String 存储消息的主机IP。 client_host String 产生消息的主机IP。 retry_times Integer 重试次数。 body_length
回收站策略默认是关闭状态。 约束与限制 回收站中的按需实例不会收取实例的费用,但是会收取存储空间的费用。 包年/包月的实例退订后会存入回收站中,此时不会收取实例的费用,但是会按需收取存储空间的费用。 包年/包月的实例从回收站中恢复后,计费模式会变为按需计费。 处于宽限期和保留期
Long 队列消息总数。 consumer_offset Long 已消费消息数。 last_message_time Long 最新消费消息的存储时间,unix毫秒时间戳格式。 请求示例 GET https://{endpoint}/v2/{project_id}/instances
"{instance_id}" request.topic = "{topic}" response = client.list_consumer_group_of_topic(request) print(response) except
*; import com.huaweicloud.sdk.rocketmq.v2.model.*; import java.util.List; import java.util.ArrayList; public class BatchDeleteInstancesSolution
request.instance_id = "{instance_id}" response = client.list_brokers(request) print(response) except exceptions.ClientRequestException
"{instance_id}" request.topic = "{topic}" response = client.list_topic_access_policy(request) print(response) except exceptions
request.instance_id = "{instance_id}" response = client.list_rocket_mq_migration_task(request) print(response) except