检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
String accessKey = System.getenv("ACL_ACCESS_KEY"); String secretKey = System.getenv("ACL_SECRET_KEY"); //ACL_ACCESS_KEY为用户
String accessKey = System.getenv("ACL_ACCESS_KEY"); String secretKey = System.getenv("ACL_SECRET_KEY"); //ACL_ACCESS_KEY为用户
String accessKey = System.getenv("ACL_ACCESS_KEY"); String secretKey = System.getenv("ACL_SECRET_KEY"); //ACL_ACCESS_KEY为用户
application/json X-Sdk-Date: 20240416T095341Z Authorization: SDK-HMAC-SHA256 Access=****************, SignedHeaders=content-type;host;x-sdk-date, Sign
200 查询成功。 { "nodes" : [ { "id" : "node-1", "broker_name" : "broker-name-1", "broker_id" : "broker-1", "address" : "0.0.0.2"
public void setName(String name) { this.name = name; } public String getMessageType() { return messageType; }
[]string{"192.168.0.1:8100"} traceCfg := &primitive.TraceConfig{ Access: primitive.Local, Resolver: primitive.NewPassthroughResolver(namesrvs)
TransactionMQProducer(gid, check_callback) producer.set_name_server_address(name_srv) producer.start() for n in range(count):
"7F00000123DC6E0BE85808B037820000" }, { "name" : "CLUSTER", "value" : "DmsCluster" }, { "name" : "TAGS", "value" : "" }
"broker_name" : "broker-0", "read_queue_num" : 3, "write_queue_num" : 3 } ], "message_type" : "NORMAL" }, { "name" : "topic-2"
send_delay_message(): producer = Producer(gid) producer.set_name_server_address(name_srv) producer.start() msg = create_message() msg
参数 参数类型 描述 soldOut Boolean 是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。
overwrite=true&name=task-123&type=rabbitToRocket { "vhosts" : [ { "name" : "DeleteVhost123" } ], "queues" : [ { "name" : "test-001"
RocketMQ实例规格。 c6.4u8g.cluster.small：单个代理最大Topic数2000，单个代理最大消费组数2000 c6.4u8g.cluster：单个代理最大Topic数4000，单个代理最大消费组数4000 c6.8u16g.cluster：单个代理最大Topic数8000，单个代理最大消费组数8000
Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } err = p.Shutdown() if err != nil
of strings 关联的代理列表。 name String 消费组名称。 group_desc String 消费组描述。 retry_max_time Integer 最大重试次数。 app_id String 应用ID。 app_name String 应用名称。 permissions
需要鉴权。 切换到解压后的软件包目录下，在“conf/tools.yml”文件中，增加如下内容。 accessKey:******* secretKey:******* accessKey和secretKey表示在控制台“用户管理”页面，创建的用户名和密钥，具体可参见创建用户。
参数 参数类型 描述 soldOut Boolean 是否售罄。 id String 可用区ID。 code String 可用区编码。 name String 可用区名称。 port String 可用区端口号。 resource_availability String 分区上是否还有可用资源。
是否可以消费。 broadcast 是 Boolean 是否广播。 brokers 否 Array of strings 关联的代理列表。 name 否 String 待修改参数的消费组（消费组名称不支持修改）。 retry_max_time 是 Integer 最大重试次数，取值范围为1~16。
RocketMQConfigReq objects RocketMQ配置。 表3 RocketMQConfigReq 参数 是否必选 参数类型 描述 name 否 String RocketMQ配置名称。 value 否 String RocketMQ配置目标值。 响应参数 无 请求示例 修改
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
