检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
tMQ网络要求页面。 已配置安全组。 已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本,并完成环境变量配置。 命令行模式连接实例 登录客户端所在服务器。 下载“rocketmq-tutorial”示例软件包。 wget https://dms-demos
tMQ网络要求页面。 已配置安全组。 已创建Topic。 客户端所在服务器已安装Java Development Kit 1.8.111或以上版本,并完成环境变量配置。 命令行模式连接实例 登录客户端所在服务器。 下载“rocketmq-tutorial”示例软件包。 wget https://dms-demos
ws系统ECS的JDK安装与环境变量配置可自行在互联网查找相关帮助。 登录管理控制台,在左上角单击,选择“计算 > 弹性云服务器”,创建一个ECS实例。 具体创建操作,请参考购买弹性云服务器。如果您已有可用的ECS,可重复使用,不需要再次创建。 使用root用户登录ECS。 安装
"security_group_name" : "security_group_test", "subnet_id" : "0a0f1fcb-f019-458d-b9e5-301867394d50", "subnet_name" : "subnet-test", "subnet_cidr" : "192
配置完成后,单击“确定”,完成消费组的创建。 消费组创建完成后,消费组列表中会增加“消费模式”参数,RocketMQ支持如下两种消费模式: CLUSTERING:表示集群消费模式。当使用集群消费模式时,RocketMQ认为任意一条消息只需要被消费组内的任意一个消费者处理即可。 BROADCASTING:表示广播消费模
String 引擎。 status String 状态。 description String 消息描述。 type String 实例类型:集群,cluster。 specification String 实例规格。 engine_version String 版本。 instance_id
查询可用区信息 功能介绍 在创建实例时,需要配置实例所在的可用区ID,可通过该接口查询可用区的ID。 调用方法 请参见如何调用API。 URI GET /v2/available-zones 请求参数 无 响应参数 状态码: 200 表1 响应Body参数 参数 参数类型 描述 region_id
定时消息:支持任意延迟时长,最长延迟1年。 仅支持18个固定延迟时长,最长延迟2小时。 顺序消息 支持 支持 消息重试 支持 支持 死信消息 支持 支持 集群消费 支持 支持 广播消费 支持 支持 死信队列 支持 支持 消费重置 支持 支持 消息查询 支持 支持 加密传输 支持 支持 消息轨迹 支持
{nameserver地址及端口号} -c {RocketMQ集群名称} -f {导出的元数据文件的存放路径} 例如:“nameserver地址及端口号”为“192.168.0.65:8100”,“RocketMQ集群名称”为“DmsCluster”,“导出的元数据文件的存放路径
type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code String CBC的规格码。 arch_types Array of
"perm" : "PUB|SUB" } ] } 响应示例 状态码: 200 创建成功。 { "access_key" : "test_01", "admin" : false, "default_group_perm" : "DENY", "default_topic_perm"
type String 产品类型,single或者cluster。 product_id String 产品ID。 ecs_flavor_id String ECS的flavor id。 billing_code String CBC的规格码。 arch_types Array of
其他接口 查询可用区信息 查询产品规格列表 查询RocketMQ产品规格核数 父主题: API V2(推荐)
其他接口 查询可用区 查询配额 查询实例在CES的监控层级关系 查询产品规格 父主题: API V1
x版本) 变更配置类型 是否支持扩容 是否支持缩容 存储空间(单机实例) √ × 实例规格(单机实例) × × 存储空间(集群实例) √ × 实例规格(集群实例) √ √ 约束与限制 扩容存储空间有次数限制,只能扩容20次。 扩容代理个数时,系统会根据当前磁盘大小进行相应比例的存
TransactionMQProducer, TransactionStatus topic = 'TopicTest' gid = 'test' name_srv = '192.168.0.1:8100' def create_message(): msg = Message(topic)
建议不要在生产环境使用DMS for RocketMQ 5.x单机实例。 建议使用跨可用区复制构建数据容灾能力。 DMS for RocketMQ集群实例支持跨可用区部署,选择多可用区部署实例时,可达到跨可用区复制数据容灾能力。 审计是否存在异常数据访问 开启云审计服务,记录DMS for
broker_cpu_core_load CPU核均负载 该指标用于统计节点虚拟机CPU每个核的平均负载 >0 RocketMQ实例节点 1分钟 broker_disk_usage 磁盘容量使用率 该指标用于统计节点虚拟机的磁盘容量使用率 单位:% 0~100 RocketMQ实例节点 1分钟
查询主题列表 功能介绍 该接口用于查询指定RocketMQ实例的Topic列表。 调用方法 请参见如何调用API。 URI GET /v2/{project_id}/instances/{instance_id}/topics 表1 路径参数 参数 是否必选 参数类型 描述 project_id
"security_group_name" : "security_group_test", "subnet_id" : "0a0f1fcb-f019-458d-b9e5-301867394d50", "subnet_name" : "subnet-test", "subnet_cidr" : "192