检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
合规证书下载 资源中心 华为云还提供以下资源来帮助用户满足合规性要求,具体请查看资源中心。 图2 资源中心 销售许可证&软件著作权证书 另外,华为云还提供了以下销售许可证及软件著作权证书,供用户下载和参考。具体请查看合规资质证书。 图3 销售许可证&软件著作权证书 父主题: 安全
导出RocketMQ实例列表 RocketMQ支持通过控制台导出实例列表信息,供用户查看和使用。 前提条件 已购买RocketMQ实例。 导出RocketMQ实例列表 登录管理控制台。 在管理控制台左上角单击,选择区域。 请选择RocketMQ实例所在的区域。 在管理控制台左上角单击,选择“应用中间件
管理消费组 创建RocketMQ消费组 查看RocketMQ消费组详情 查看RocketMQ消费者连接地址 修改RocketMQ消费组配置 重置RocketMQ消费进度 删除RocketMQ消费组
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
管理实例 查看和修改RocketMQ实例基本信息 查看RocketMQ实例后台任务 配置RocketMQ实例标签 导出RocketMQ实例列表 诊断RocketMQ实例 重启RocketMQ实例的Broker节点 删除RocketMQ实例 配置RocketMQ实例回收站策略 修改RocketMQ实例的SSL配置
页面。 选择待诊断的消费组名称,单击“开始诊断”。 诊断完成后,在“诊断记录”区域,新增一条诊断记录。 单击“查看报告”,进入“实例诊断”页面,查看诊断结果。 您可以查看到消费组状态是否在线、消费者数量、订阅关系是否一致和消息堆积量,并根据结果分析处理生产和消费消息时所遇到的问题。
获取“公网连接地址”。 使用gRPC协议通过公网连接RocketMQ实例时,获取“grpc公网连接地址”。 图1 查看实例的连接地址和端口(5.x版本) 图2 查看实例的连接地址和端口(4.8.0版本) Topic名称 从RocketMQ实例控制台的“Topic管理”页签中获取Topic名称。
Credentials{ AccessKey: os.Getenv("ROCKETMQ_AK"), //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey: os.Getenv("ROCKETMQ_SK")
Topic管理 查看RocketMQ Topic详情 修改RocketMQ Topic配置 删除RocketMQ Topic 父主题: 配置Topic
= "{CLOUD_SDK_AK}"; //访问密钥ID。查看AK的方法请参见获取AK/SK。 String sk = "{CLOUD_SDK_SK}"; //与访问密钥ID结合使用的密钥。查看SK的方法请参见获取AK/SK。 String
xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK")
单击“确定”。 迁移完成后,在迁移任务列表页面查看“任务状态”。 当“任务状态”为“迁移完成”,表示所有元数据都已成功迁移。 当“任务状态”为“迁移失败”,表示元数据中部分或全部元数据迁移失败。 单击迁移任务名称,进入迁移任务详情页。在“迁移结果”中可查看到迁移失败的Topic/消费组名称,以及失败原因及解决方法。
xx:8080" AccessKey = os.Getenv("ROCKETMQ_AK") //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险,建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey = os.Getenv("ROCKETMQ_SK")
的用户才可以查看和管理该告警规则。 标签:标签用于标识云资源,当您拥有相同类型的许多云资源时,可以使用标签按各种维度(例如用途、所有者或环境)对云资源进行分类。 单击“立即创建”,完成告警规则的设置。 告警规则创建完成后,在云监控服务的“告警 > 告警规则”界面,查看新创建的告警规则。
/v2/primitive" "github.com/apache/rocketmq-client-go/v2/producer" "os" ) // implements a simple producer to send message. func main() { p
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"
and CLOUD_SDK_SK in the local environment ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] projectId = "{project_id}"