华为云用户手册

响应示例 状态码： 200 成功 { "code": "IPDC.01020000", "message": "success", "datas": null, "totalCount": 2 } 状态码： 400 认证失败 { "reserve" : null, "error_code" : "AUTH-600001", "error_msg" : "" }

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 code String 返回码 message String 返回码描述 datas Object 返回数据 totalCount Long 删除数据条数 状态码： 400 表4 响应Body参数 参数 参数类型 描述 reserve String 保留字段 error_code String 错误编码 error_msg String 错误信息

URI GET /console/servicetask/api/localMethod/navtree/getNavigateTree 示例接口地址：{ 域名 （有文根需带文根）}/pdmcore/ipdcworkflowservice/console/servicetask/api /localMethod/navtree/getNavigateTree?processTemplate=Test0425&processInstanceId=867272db-037c-11ef-8a3a-fa163eaf0a4f&templateVersion=6&startNodeVisible=true 表1 Query参数 参数 是否必选 参数类型 描述 processTemplate 否 String 流程模板名称 processInstanceId 否 String 流程实例ID（可通过启动流程接口返回值里面获取processInstanceId） templateVersion 否 String 流程模板版本 startNodeVisible 否 boolean 默认true

响应示例 状态码： 200 标准响应体 { "code": 0, "data": { "showStartCarbonCopy": false, "type": "", "steps": [ { "sequenceNumber": "0", "visible": false, "compositeClick": true, "editStatus": 1, "resetStatus": 0, "skip": true, "rejectTargetRouterIDs": [], "nodeType": "START_NODE", "navigationName": "start", "expand": true, "iconStatus": "1", "routerId": "StartEvent_1", "showTips": false, "showTodoTaskNum": false, "nodeIndex": 67, "navigationNameEn": "start_EN" }, { "sequenceNumber": "1", "visible": true, "compositeClick": true, "editStatus": 1, "resetStatus": 0, "skip": false, "rejectTargetRouterIDs": [], "nodeType": "ACTIVITY", "navigationName": "提交任务", "expand": true, "iconStatus": "1", "routerId": "SubmitTask_1", "showTips": false, "showTodoTaskNum": false, "nodeIndex": 68, "navigationNameEn": "提交任务_EN" }, { "sequenceNumber": "2", "visible": true, "compositeClick": true, "editStatus": 0, "resetStatus": 0, "skip": false, "rejectTargetRouterIDs": [], "nodeType": "ACTIVITY", "navigationName": "用户任务", "expand": true, "iconStatus": "0", "routerId": "Activity_0apnaab", "showTips": false, "showTodoTaskNum": false, "nodeIndex": 69, "navigationNameEn": "用户任务_EN" }, { "sequenceNumber": "3", "visible": true, "compositeClick": true, "editStatus": 0, "resetStatus": 0, "skip": false, "rejectTargetRouterIDs": [], "nodeType": "END_NODE", "navigationName": "结束事件", "expand": true, "iconStatus": "0", "routerId": "Event_0h34638", "showTips": false, "showTodoTaskNum": false, "nodeIndex": 70, "navigationNameEn": "结束事件_EN" } ], "displayMode": "vertical" }, "orderID": "92de75c4-5901-4f5b-b257-b461a8eb5902" }

响应参数 状态码： 200 表3 响应Body参数 参数 参数类型 描述 code String 返回码 message String 返回码描述 datas Object 返回数据 totalCount Long 数据条数 状态码： 400 表4 响应Body参数 参数 参数类型 描述 reserve String 保留字段 error_code String 错误编码 error_msg String 错误信息

响应示例 状态码： 200 成功 { "code": "IPDC.01020000", "message": "success", "datas": [ { "id": "739517047683162112", "creator": "public@ipdcenter203.huaweiapaas.com 2891572111", "modifier": "public@ipdcenter203.huaweiapaas.com 2891572111", "createTime": "2025-03-07T08:16:43.730+00:00", "lastUpdateTime": "2025-03-07T08:16:43.730+00:00", "rdmVersion": 1, "rdmDeleteFlag": 0, "rdmExtensionType": "XDMUserGroup", "tenant": { "id": "-1", "creator": "xdmAdmin", "modifier": "xdmAdmin", "createTime": "2023-10-31T07:44:53.458+00:00", "lastUpdateTime": "2023-10-31T07:44:53.458+00:00", "rdmVersion": 1, "rdmDeleteFlag": 0, "rdmExtensionType": "Tenant", "tenant": null, "className": "Tenant", "name": "basicTenant", "description": "默认租户", "kiaguid": null, "securityLevel": "internal", "nameEn": null, "code": "basicTenant", "disableFlag": false, "dataSource": "DefaultDataSource" }, "className": "XDMUserGroup", "groupcode": "GSK118", "nameEn": "testYhz202503071056", "descriptionEn": null, "name": "testYhz202503071056", "description": "testYhz202503071056", "disableFlag": false, "extId": "106", "employeeCount": 0, "employeeLimit": 5, "manager": null, "managerName": null, "parentId": null, "children": null, "level": 0, "parentCrumb": null } ], "totalCount": 1 } 状态码： 400 认证失败 { "reserve" : null, "error_code" : "AUTH-600001", "error_msg" : "" }

调试选项 loglevel：UPDATE|INFO|WARNING|ASSERT|EXCEPTION|ERROR|NONE 日志级别左边包含右边的日志信息，即UPDATE级别会打印所有日志信息，使用该字段会打印HTDebug的日志，并写日志到此文件的上一级文件目录。NONE表示不保存log。 debugger_ctrl_switch：ON|OFF 是否在日志中显示调试面板，只对HTAppUIType中mNativeAppIds包含的应用包名有效。 fixed_location_switch：ON|OFF 是否使用自定义的固定位置。 longitude 经度，填写固定位置经纬的值，只在“fixed_location_switch”为“ON”时有效。 latitude 纬度，填写固定位置纬度的值，只在“fixed_location_switch”为“ON”时有效。

快速开始 使用微信 开发者工具 创建小程序工程，导入SDK。 本文档使用的微信开发者工具版本为Nightly 1.06.2411282。 使用微信号登录微信开发者工具。 新建微信小程序工程。 单击“新建项目”，进入“创建小程序”页面。 图1 创建小程序 在“项目名称”文本框中填写项目名称。 “目录”选择项目存放的路径。 “AppID”选择“测试号”。 “后端服务”选择“不使用云服务”。 “开发模式”选择“小程序”。 “模板选择”选“不使用模板”。 单击“创建”，完成小程序工程创建。创建完成后，工程目录如图2。 图2 目录名称 新建文件并导入SDK。 在工具的资源管理器，单击右键，选择“新建文件”，新建文件“app.json”，并在app.json中配置页面（pages），代码如下： { "pages": [ "pages/index/index" ] } 单击右键，选择“新建文件”，新建文件“app.js”。 按Ctrl+S组合键，保存并编译，工具会自动生成pages文件夹及文件夹下的文件。 下载并解压CyberverseXRLightSDK软件包。 打开工程目录，将解压后得到的build文件夹复制到pages同级目录。 图3 导入SDK后目录 调用SDK，获取版本号。 在“index.js”文件的第一行导入XRClient。 import { XRClient } from "../../build/XRClient"; 在“index.js”文件的onLoad方法里打印SDK版本号。 onLoad(options) { console.log(XRClient.getVersion()) }, 真机调试，验证结果。 自动调试前，确保移动端设备的微信在前台运行，且与开发者工具登录的是同一个账号。 在微信开发者工具中，单击“真机调试”。 根据移动端设备情况选择“启动 Android 端自动真机调试”或 “启动 iOS 端自动真机调试”。 XRLightSDK是基于XRFrame方案的AR应用，不支持PC端调试。 单击“编译并自动调试”，弹出“真机调试”窗口。 图4 真机调试 在“Console”页签下，查看输出的内容，如果打印了SDK版本号信息，说明引入SDK成功。 图5 查看SDK版本信息 父主题： XRLightSDK使用手册

支持UEFI启动方式的操作系统版本 云服务器的启动方式包括BIOS启动和UEFI启动，二者区别请参见“UEFI启动方式与BIOS启动方式有哪些区别？”章节。 支持UEFI启动方式的操作系统版本如表1所示。 表1 支持UEFI启动方式的操作系统版本 操作系统类型 操作系统版本 Windows Windows Server 2019 Standard 64bit Windows Server 2019 Datacenter 64bit Windows Server 2016 Standard 64bit Windows Server 2016 Datacenter 64bit Windows Server 2012 R2 Standard 64bit Windows Server 2012 R2 Datacenter 64bit Windows Server 2012 Essentials R2 64bit Windows Server 2012 Standard 64bit Windows Server 2012 Datacenter 64bit Windows 10 64bit Ubuntu Ubuntu 19.04 Server 64bit Ubuntu 18.04 Server 64bit Ubuntu 16.04 Server 64bit Ubuntu 14.04 Server 64bit Red Hat Red Hat Linux Enterprise 7.4 64bit Red Hat Linux Enterprise 7.3 64bit Red Hat Linux Enterprise 7.1 64bit Red Hat Linux Enterprise 7.0 64bit Red Hat Linux Enterprise 6.9 64bit Red Hat Linux Enterprise 6.6 32bit Red Hat Linux Enterprise 6.5 64bit Oracle Linux Oracle Linux Server release 7.4 64bit Oracle Linux Server release 6.9 64bit openSUSE openSUSE 42.1 64bit SUSE SUSE Linux Enterprise Server 12 SP5 64bit SUSE Linux Enterprise Server 12 SP1 64bit SUSE Linux Enterprise Server 11 SP3 64bit Fedora Fedora 29 64bit Fedora 24 64bit Debian Debian GNU/Linux 8.8.0 64bit CentOS CentOS 7.6 64bit CentOS 7.5 64bit CentOS 7.4 64bit CentOS 7.0 64bit CentOS 6.9 64bit CentOS 6.6 64bit EulerOS EulerOS 2.8 64bit EulerOS 2.7 64bit EulerOS 2.5 64bit EulerOS 2.3 64bit EulerOS 2.2 64bit openEuler openEuler 20.03 64bit 中标麒麟 NeoKylin V7 64bit 统信 UOS 20 64bit 父主题： 相关支持列表

购买套餐包 进入购买 KooMessage 套餐包页面。 图1 购买页面 根据实际，选择需要的套餐规格，套餐包说明如表1。 表1 套餐包说明 类型 套餐包 说明 按需套餐包 智能信息 智能信息基于普通短信下发通道支持富媒体消息的呈现和交互效果，包括多媒体内容生产（短链生成、短链解析）。 智能信息基础版 智能信息基础版包含三网通道，即移动、电信、联通。 智能信息服务号 在智能信息服务号中，提供品牌认证与展示、自定义菜单按钮、打开应用服务跳转、企业主页展示等能力，可与智能信息或智能信息基础版叠加使用。 填写完成后，页面下方会出现“配置费用”，请检查选择规格及费用。 确认无误后，单击“去支付”，进入“购买KooMessage套餐包”页面。 查看“云服务订单”，选择支付方式，单击“确认付款”。 如果开启操作保护，则会弹出操作确认对话框，进行身份验证，根据界面提示填写信息。 界面提示订单支付成功，购买完成。

文本内容审核 （v3） 本章节对文本 内容审核 AK/SK方式使用SDK进行示例说明。 示例代码中修改TextDetectionDataReq的text值配置待检测的文本信息，配置完成后运行即可。 服务所在的应用区域和终端节点，详情请查看 地区和终端节点 。 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 # coding: utf-8 from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdkmoderation.v3.region.moderation_region import ModerationRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdkmoderation.v3 import * import os if __name__ == "__main__": # 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全； # 本示例以ak和sk保存在环境变量中来实现身份验证为例，运行本示例前请先在本地环境中设置环境变量HUAWEICLOUD_SDK_AK和HUAWEICLOUD_SDK_SK。 ak = os.getenv("HUAWEICLOUD_SDK_AK") sk = os.getenv("HUAWEICLOUD_SDK_SK") credentials = BasicCredentials(ak, sk) \ client = ModerationClient.new_builder() \ .with_credentials(credentials) \ .with_region(ModerationRegion.value_of("xxx"))\ .build() # 把xxx替换成服务所在的区域，例如北京四：cn-north-4。 try: request = RunTextModerationRequest() databody = TextDetectionDataReq( text="test" ) request.body = TextDetectionReq( data=databody, event_type="comment" ) response = client.run_text_moderation(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg) 控制台输出200即表示程序执行成功，文本内容审核结果输出到控制台。 {"request_id": "d81702cfd3599e103030c3d52d6f955f", "result": {"suggestion": "pass", "label": "normal", "details": []}} 父主题： 文本审核

方案优势 开箱即用：上传文档后，即可进行基于文档的问答，并支持灵活的API接入。支持非结构化和结构化数据入库，提供多轮问答、可溯源及图文输出功能。 高精度：集成高精度文本Embedding模型，提供智能文档解析、重组及搜索规划服务，检索准确率高。 高性能：内置 CSS 向量数据库，具备高精度和高性能，支持Flat、Graph、IVF、IVF_Graph、PQ等多种索引，并兼容Elasticsearch生态。 安全：支持物理多租、租户隔离、全托管服务，独享资源更稳定、性能更高。 强大的知识检索与生成能力：集成DeepSeek模型服务，使得RAG系统能够从大规模知识库中高效检索相关信息，并生成高质量、准确的答案。

步骤二： KooSearch 对接公网 通过配置NAT网关和弹性公网IP将KooSearch对接到公网，便于接入MaaS服务中的DeepSeek模型服务。 登录NAT网关管理控制台。 在公网NAT网关列表页面，单击“购买公网NAT网关”，进入购买公网NAT网关页面。 在购买公网NAT网关页面，配置NAT网关。 关键参数请参见表1配置，其他参数可以保持默认值或基于业务场景配置。 表1 购买公网NAT网关 参数 说明 计费模型 建议选择“按需计费”。 区域 和KooSearch保持一个区域，选择“西南-贵阳一”。 虚拟私有云 和KooSearch选择同一个VPC。 子网 和KooSearch选择同一个子网。 单击“立即购买”，确认产品规格无误后，单击“提交”，开始创建公网NAT网关。当状态为“运行中”时，表示公网NAT网关创建成功。 当公网NAT网关创建成功后，在公网NAT网关列表页面，单击操作列的“设置规则”，在弹窗中单击“添加规则”。 在“SNAT规则”页面，单击“添加SNAT规则”，在弹窗中配置公网NAT网关的SNAT规则。 表2 添加SNAT规则 参数 说明 使用场景 选择“虚拟私有云”。 网段 选择“使用已有”，选择和KooSearch同一个VPC。 公网IP类型 选择“弹性公网IP”，勾选满足要求的IP。 如果没有可选的弹性公网IP，可以单击“查看弹性公网IP”跳转到弹性公网IP列表页，申请弹性公网IP。 弹性公网IP的建议配置如下： “计费模式”：“按需计费” “公网带宽”：“按流量计费” “带宽大小”：“20” 单击“确定”完成SNAT规则的添加。

步骤一：获取DeepSeek模型服务 在MaaS服务中获取DeepSeek模型服务，并记录API地址、模型名称和API Key，用于接入KooSearch。 登录ModelArts管理控制台，区域选择“西南-贵阳一”。 在左侧导航栏中，选择“ModelArts Studio”进入ModelArts Studio大模型即服务平台。 参考使用ModelArts Studio的DeepSeek-R1模型框架实现对话问答，在MaaS服务中获取DeepSeek模型服务。 在DeepSeek模型服务的调用说明页面，获取并记录“API地址”和“模型名称”，根据页面提示获取并记录API Key。 图1 获取DeepSeek模型服务信息 最多支持创建5个密钥，密钥只会在新建后显示一次，请妥善保存。 当密钥丢失将无法找回，请新建API Key获取新的访问密钥。

体验知识问答 创建知识库。 在KooSearch控制台的左侧导航栏选择“知识库管理”，进入知识库管理页面。 单击右上角“新建知识库”，进入新建知识库页面。 在“新建知识库”页面设置知识库信息。 在“模型设置”页签，设置“NLP模型服务”，选择上一步新建的模型服务。 其他参数可以保持默认值或基于业务场景配置。 设置好后，单击“确定”完成知识库创建。 在知识库列表，选择新建知识库，单击操作列的“文档管理”。进入知识库详情页面。 选择“文档管理”页签，单击“上传”。在上传对话框中单击“选择文档”，本地选择已提前准备好的文档。重复的文档不允许上传。 图3 上传文档 单击“确认”。文档上传后，可在文档管理页签查看已上传的文档，当“文档状态”为“正常”，说明文档已上传成功。 选择知识库。 在KooSearch控制台，左侧导航栏选择“体验平台”，进入体验平台页面。 单击右上角，在“资料来源”对话框勾选新建的知识库，单击“确定”。 体验问答。 KooSearch同时支持由大模型自身知识回答和通过文章内容回答。 在“体验平台”页面右上角单击“问答”，切换至问答体验页面。 在输入框中输入问题，单击，查看返回的答案。 图4 体验问答

生产消息 生产消息的示例代码如下（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 @SpringBootApplication public class ProduceDemoApplication implements CommandLineRunner { @Resource private RocketMQTemplate rocketMQTemplate; public static void main(String[] args) { SpringApplication.run(ProduceDemoApplication.class, args); } @Override public void run(String... args) throws Exception { // send message synchronously rocketMQTemplate.convertAndSend("topic", "Hello, World!"); // send spring message rocketMQTemplate.send( "topic", MessageBuilder.withPayload("Hello, World! I'm from spring message").build()); // send messgae asynchronously rocketMQTemplate.asyncSend( "topic", MessageBuilder.withPayload("Hello, World! I'm from spring message").build(), new SendCallback() { @Override public void onSuccess(SendResult var1) { System.out.printf("async onSucess SendResult=%s %n", var1); } @Override public void onException(Throwable var1) { System.out.printf("async onException Throwable=%s %n", var1); } }); // Send messages orderly rocketMQTemplate.syncSendOrderly( "topic", MessageBuilder.withPayload("Hello, World").build(), "hashkey"); } }

准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy

订阅顺序消息 只需要在订阅普通消息的代码基础上增加consumer.WithConsumerOrder(true)，参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "os" "time" "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/consumer" "github.com/apache/rocketmq-client-go/v2/primitive" ) func main() { c, _ := rocketmq.NewPushConsumer( consumer.WithGroupName("testGroup"), consumer.WithNsResolver(primitive.NewPassthroughResolver([]string{"192.168.0.1:8100"})), consumer.WithConsumerModel(consumer.Clustering), consumer.WithConsumeFromWhere(consumer.ConsumeFromFirstOffset), consumer.WithConsumerOrder(true), //consumer.WithTls(true), //创建实例时，如果开启了SSL，请添加此行代码。 ) err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { orderlyCtx, _ := primitive.GetOrderlyCtx(ctx) fmt.Printf("orderly context: %v\n", orderlyCtx) fmt.Printf("subscribe orderly callback: %v \n", msgs) return consumer.ConsumeSuccess, nil }) if err != nil { fmt.Println(err.Error()) } // Note: start after subscribe err = c.Start() if err != nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time.Hour) err = c.Shutdown() if err != nil { fmt.Printf("Shutdown Consumer error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 testGroup：表示消费组名称。 192.168.0.1:8100：表示实例连接地址和端口。 test：表示Topic名称。

订阅普通消息 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "os" "time" "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/consumer" "github.com/apache/rocketmq-client-go/v2/primitive" ) func main() { c, _ := rocketmq.NewPushConsumer( consumer.WithGroupName("testGroup"), consumer.WithNsResolver(primitive.NewPassthroughResolver([]string{"192.168.0.1:8100"})), //consumer.WithTls(true), //创建实例时，如果开启了SSL，请添加此行代码。 ) err := c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { for i := range msgs { fmt.Printf("subscribe callback: %v \n", msgs[i]) } return consumer.ConsumeSuccess, nil }) if err != nil { fmt.Println(err.Error()) } // Note: start after subscribe err = c.Start() if err != nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time.Hour) err = c.Shutdown() if err != nil { fmt.Printf("shutdown Consumer error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 testGroup：表示消费组名称。 192.168.0.1:8100：表示实例连接地址和端口。 test：表示Topic名称。

同步发送 同步发送是指消息发送方发出一条消息到服务端，服务端接收并处理消息，然后返回响应给发送方，发送方收到响应后才会发送下一条消息的通讯方式。 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/primitive" "github.com/apache/rocketmq-client-go/v2/producer" "os" ) // implements a simple producer to send message. func main() { p, _ := rocketmq.NewProducer( producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"192.168.0.1:8100"})), producer.WithRetry(2), //producer.WithTls(true), //创建实例时，如果开启了SSL，请添加此行代码。 ) err := p.Start() if err != nil { fmt.Printf("start producer error: %s", err.Error()) os.Exit(1) } msg := &primitive.Message{ Topic: "topic1", Body: []byte("Hello RocketMQ Go Client!"), } msg.WithTag("TagA") msg.WithKeys([]string{"KeyA"}) res, err := p.SendSync(context.Background(), msg) if err != nil { fmt.Printf("send message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", res.String()) } err = p.Shutdown() if err != nil { fmt.Printf("shutdown producer error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 topic1：表示Topic名称。

异步发送 异步发送是指消息发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息的通讯方式。 使用异步发送需要客户端实现异步发送回调接口（SendCallback）。即消息发送方在发送了一条消息后，不需要等待服务端响应接着发送第二条消息。发送方通过回调接口接收服务端响应，并处理响应结果。 参考如下示例代码（以下加粗内容需要替换为实例自有信息，请根据实际情况替换）。 package main import ( "context" "fmt" "os" "sync" "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/primitive" "github.com/apache/rocketmq-client-go/v2/producer" ) // implements a async producer to send message. func main() { p, _ := rocketmq.NewProducer( producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"192.168.0.1:8100"})), producer.WithRetry(2), //producer.WithTls(true), //创建实例时，如果开启了SSL，请添加此行代码。 ) err := p.Start() if err != nil { fmt.Printf("start producer error: %s", err.Error()) os.Exit(1) } var wg sync.WaitGroup wg.Add(1) callback := func(ctx context.Context, result *primitive.SendResult, e error) { if e != nil { fmt.Printf("receive message error: %s\n", err) } else { fmt.Printf("send message success: result=%s\n", result.String()) } wg.Done() } message := primitive.NewMessage("test", []byte("Hello RocketMQ Go Client!")) err = p.SendAsync(context.Background(), callback, message) if err != nil { fmt.Printf("send message error: %s\n", err) wg.Done() } wg.Wait() err = p.Shutdown() if err != nil { fmt.Printf("shutdown producer error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 192.168.0.1:8100：表示实例连接地址和端口。 test：表示Topic名称。

准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy

消费者增加用户认证信息 无论是普通消息、顺序消息、定时消息，还是事务消息，都参考如下代码。以下加粗内容需要替换为实例自有信息，请根据实际情况替换。 package main import ( "context" "fmt" "os" "time" "github.com/apache/rocketmq-client-go/v2" "github.com/apache/rocketmq-client-go/v2/consumer" "github.com/apache/rocketmq-client-go/v2/primitive" ) func main() { c, err := rocketmq.NewPushConsumer( consumer.WithGroupName("testGroup"), consumer.WithNsResolver(primitive.NewPassthroughResolver([]string{"192.168.0.1:8100"})), consumer.WithCredentials(primitive.Credentials{ AccessKey: os.Getenv("ACL_User_Name"), //用户名和密钥直接硬编码到代码中或者明文存储都存在很大的风险，建议在配置文件或者环境变量中密文存放,使用时解密。 SecretKey: os.Getenv("ACL_Secret_Key"), }), //consumer.WithTls(true), //创建实例时，如果开启了SSL，请添加此行代码。 ) if err != nil { fmt.Println("init consumer error: " + err.Error()) os.Exit(0) } err = c.Subscribe("test", consumer.MessageSelector{}, func(ctx context.Context, msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) { fmt.Printf("subscribe callback: %v \n", msgs) return consumer.ConsumeSuccess, nil }) if err != nil { fmt.Println(err.Error()) } // Note: start after subscribe err = c.Start() if err != nil { fmt.Println(err.Error()) os.Exit(-1) } time.Sleep(time.Hour) err = c.Shutdown() if err != nil { fmt.Printf("Shutdown Consumer error: %s", err.Error()) } } 示例代码中的参数说明如下，请参考收集连接信息获取参数值。 testGroup：表示消费组名称。 192.168.0.1:8100：表示实例连接地址和端口。 AccessKey：表示用户名。创建用户的步骤，请参见创建用户。 SecretKey：表示用户的密钥。 test：表示Topic名称。

准备环境 执行以下命令，检查是否已安装Go。 go version 返回如下回显时，说明Go已经安装。 go version go1.16.5 linux/amd64 如果未安装Go，请下载并安装。 进入Go脚本所在的bin目录下。 执行“touch go.mod”命令新建一个“go.mod”，并增加以下代码，添加依赖。 module rocketmq-example-go go 1.13 require ( github.com/apache/rocketmq-client-go/v2 v2.1.2 ) 执行如下命令增加代理。 export GOPROXY=https://goproxy.cn,direct 执行如下命令下载依赖。 go mod tidy

功能说明 云监控服务 （Cloud Eye）可以监控和查看云服务的运行状态、各个指标的使用情况，并对监控项创建告警规则。 当您创建了 CDM 集群后， 云监控 服务会自动关联CDM的监控指标，帮助您实时掌握CDM集群的各项性能指标，精确掌握CDM集群的运行情况。 本章节描述了CDM上报云监控的监控指标的命名空间、监控指标列表和维度定义。 如果您需要查看CDM相关的监控指标，请参见查看CDM监控指标。 如果您需要在监控数据满足指定条件时发送报警通知，可参见设置CDM告警规则。

资源和成本规划 该解决方案主要部署如下资源，以下费用仅供参考，具体请参考华为云官网价格详情，实际收费以账单为准。 表1 资源和成本规划（按需计费） 华为云服务 资源名称 配置示例 数量 每月预估花费 虚拟私有云 VPC deploying-evalscope-demo VPC网段：172.16.0.0/16 区域：华北-北京四 1 0.00元 子网 Subnet deploying-evalscope-demo-subnet 子网网段：172.16.1.0/24 区域：华北-北京四 1 0.00元 安全组 SecurityGroup deploying-evalscope-demo-sg 允许ping：0.0.0.0/0 开放端口22允许Cloud Shell 登录：121.36.59.153/32 区域：华北-北京四 1 0.00元 Flexus云服务器X实例 deploying-evalscope-demo 按需计费：0.26元/小时 区域：华北-北京四 规格：Flexus云服务器X实例 | 性能模式（关闭）| x1.2u.4g | 2核 | 4GB 镜像：Ubuntu 22.04 server 64bit 系统盘：通用型SSD | 40GB 1 187.20元 弹性公网IP EIP deploying-evalscope-demo-eip 按需计费：0.80元/GB 区域：华北-北京四 线路：动态BGP 公网带宽：按流量计费 带宽大小：300Mbit/s 1 0.80元/GB 合计 - 187.20元 + 弹性公网IP EIP费用 表2 资源和成本规划（包年包月） 华为云服务 资源名称 配置示例 数量 每月预估花费 虚拟私有云 VPC deploying-evalscope-demo VPC网段：172.16.0.0/16 区域：华北-北京四 1 0.00元 子网 Subnet deploying-evalscope-demo-subnet 子网网段：172.16.1.0/24 区域：华北-北京四 1 0.00元 安全组 SecurityGroup deploying-evalscope-demo-sg 允许ping：0.0.0.0/0 开放端口22允许Cloud Shell 登录：121.36.59.153/32 区域：华北-北京四 1 0.00元 Flexus云服务器X实例 deploying-evalscope-demo 包年包月 区域：华北-北京四 规格：Flexus云服务器X实例 | 性能模式（关闭）| x1.2u.4g | 2核 | 4GB 镜像：Ubuntu 22.04 server 64bit 系统盘：通用型SSD | 40GB 1 136.00元 弹性公网IP EIP deploying-evalscope-demo-eip 按需计费：0.80元/GB 区域：华北-北京四 线路：动态BGP 公网带宽：按流量计费 带宽大小：300Mbit/s 1 0.80元/GB 合计 - 136.00元 + 弹性公网IP EIP费用

操作步骤 登录华为云解决方案实践，选择“快速搭建EvalScope模型性能评测平台”，单击“一键部署”，跳转至解决方案创建资源栈界面。 图1 解决方案实施库 在选择模板界面中，单击“下一步”。 图2 选择模板 在配置参数界面中，参考“表1 参数填写说明”完成自定义参数填写，部分参数会自动默认填充参数值。如需修改请在参数配置页面删除文本框内的默认值后填写新的参数值，所有参数填写完成后方可单击“下一步”。 图3 配置参数 表1 参数填写说明 参数名称 类型 是否可选 参数解释 默认值 vpc_name string 必填 虚拟私有云名称，同时作为子网、安全组的名称前缀，该模板使用新建VPC，不允许重名。取值范围：1-57个字符，支持中文、英文字母、数字、_（下划线）、-（中划线）、.（点）。 deploying-evalscope-demo ecs_name string 必填 云服务器实例名称，同时作为弹性公网 IP及其带宽的名称前缀，不支持重名。取值范围：1-54个字符，支持中文、英文字母、数字、_（下划线）、-（中划线）、.（点）。 deploying-evalscope-demo ecs_flavor string 必填 云服务器实例规格，支持弹性云服务器 E CS 及华为云Flexus 云服务器X实例。Flexus 云服务器X实例规格ID命名规则为x1.?u.?g，例如2vCPUs4GiB规格ID为x1.2u.4g，具体华为云Flexus 云服务器X实例规格请参考控制台。弹性云服务器 ECS规格请参考部署指南配置。默认：x1.2u.4g。规格信息具体请参考官网弹性云服务器规格清单。 x1.2u.4g ecs_password string 必填 云服务器密码，长度为8-26位，密码至少必须包含大写字母、小写字母、数字和特殊字符（!@$%^-_=+[{}]:,./?）中的三种。修改密码，请参考重置云服务器密码登录ECS控制台修改密码。管理员账户默认root。 空 system_disk_size number 必填 云服务器系统盘大小，磁盘类型默认为通用型SSD，单位：GB，取值范围为40-1,024，不支持缩盘。 40 charging_mode string 必填 云服务器计费模式，默认自动扣费，可选值为：postPaid（按需计费）、prePaid（包年包月）。 postPaid charging_unit string 必填 云服务器订购周期类型，仅当charging_mode为prePaid（包年/包月）生效，此时该参数为必填参数。取值范围：month（月），year（年）。 month chargeing_period number 必填 云服务器订购周期，仅当charging_mode为prePaid（包年/包月）生效，此时该参数为必填参数。取值范围：charging_unit=month（周期类型为月）时，取值为1-9；charging_unit=year（周期类型为年）时，取值为1-3。 1 （可选，如果使用华为主账号或admin用户组下的 IAM 子账户可不选委托）在资源设置界面中，在权限委托下拉框中选择“rf_admin_trust”委托，单击“下一步”。 图4 资源栈设置 在配置确认界面中，单击“创建执行计划”。 图5 配置确认 在弹出的创建执行计划框中，自定义填写执行计划名称，单击“确定”。 图6 创建执行计划 单击“部署”，并且在弹出的执行计划确认框中单击“执行”。 图7 执行计划 图8 执行计划确认 （可选）如果计费模式选择“包年包月”，在余额不充足的情况下（所需总费用请参考表2）请及时登录费用中心，手动完成待支付订单的费用支付。 待“事件”中出现“Apply required resource success”，堆栈部署成功，表示顺利完成资源的下发和部署。堆栈部署成功后，搭建EvalScope脚本开始执行，耐心等待10-20分钟左右（受网络波动影响）。 图9 部署完成

资源和成本规划 资源和成本规划 该解决方案主要部署如下资源，以下费用仅供参考，具体请参考华为云官网价格详情，实际收费以账单为准。 表1 资源和成本规划（按需计费） 华为云服务 资源名称 配置示例 数量 每月预估花费 虚拟私有云 VPC deploying-evalscope-demo VPC网段：172.16.0.0/16 区域：华北-北京四 1 0.00元 子网 Subnet deploying-evalscope-demo-subnet 子网网段：172.16.1.0/24 区域：华北-北京四 1 0.00元 安全组 SecurityGroup deploying-evalscope-demo-sg 允许ping：0.0.0.0/0 开放端口22允许Cloud Shell 登录：121.36.59.153/32 区域：华北-北京四 1 0.00元 Flexus云服务器X实例 deploying-evalscope-demo 按需计费：0.26元/小时 区域：华北-北京四 规格：Flexus云服务器X实例 | 性能模式（关闭）| x1.2u.4g | 2核 | 4GB 镜像：Ubuntu 22.04 server 64bit 系统盘：通用型SSD | 40GB 1 187.20元 弹性公网IP EIP deploying-evalscope-demo-eip 按需计费：0.80元/GB 区域：华北-北京四 线路：动态BGP 公网带宽：按流量计费 带宽大小：300Mbit/s 1 0.80元/GB 合计 - 187.20元 + 弹性公网IP EIP费用 表2 资源和成本规划（包年包月） 华为云服务 资源名称 配置示例 数量 每月预估花费 虚拟私有云 VPC deploying-evalscope-demo VPC网段：172.16.0.0/16 区域：华北-北京四 1 0.00元 子网 Subnet deploying-evalscope-demo-subnet 子网网段：172.16.1.0/24 区域：华北-北京四 1 0.00元 安全组 SecurityGroup deploying-evalscope-demo-sg 允许ping：0.0.0.0/0 开放端口22允许Cloud Shell 登录：121.36.59.153/32 区域：华北-北京四 1 0.00元 Flexus云服务器X实例 deploying-evalscope-demo 包年包月 区域：华北-北京四 规格：Flexus云服务器X实例 | 性能模式（关闭）| x1.2u.4g | 2核 | 4GB 镜像：Ubuntu 22.04 server 64bit 系统盘：通用型SSD | 40GB 1 136.00元 弹性公网IP EIP deploying-evalscope-demo-eip 按需计费：0.80元/GB 区域：华北-北京四 线路：动态BGP 公网带宽：按流量计费 带宽大小：300Mbit/s 1 0.80元/GB 合计 - 136.00元 + 弹性公网IP EIP费用

配额限制 为防止资源滥用，平台限定了各服务资源的配额，对用户的资源数量和容量做了限制。UCS具有集群、舰队、权限、集群联邦，以及容器智能分析实例配额限制，如表1所示。若UCS提供的默认配额无法满足使用需要，您可以提交工单申请扩大配额。 集群配额：UCS支持接入的集群数量上限，华为云集群、本地集群、附着集群、多云集群和伙伴云集群的数量均占用该配额值。 舰队配额：用户拥有的舰队数量上限。 权限配额：用户可以在“权限管理”页面创建的权限数量上限。 集群联邦配额：用户可以开通的集群联邦数量上限。不可申请扩大配额。 容器智能分析实例配额：用户可以创建的容器智能分析实例数量上限。不可申请扩大配额。 表1 UCS配额项 配额项 默认配额值 集群 50 舰队 50 权限 50 集群联邦 1 容器智能分析实例 1 用户在使用UCS时也会使用其他云服务，例如弹性云服务器、云硬盘、虚拟私有云、弹性负载均衡、 容器镜像服务 、云解析服务等。其他云服务配额与UCS配额相互独立，由各服务自行管理，详情请参见关于配额。

功能介绍 跨云、跨地域集群统一接入，统一管理 支持跨云、跨地域的集群统一接入、统一管理，支持接入华为云集群、本地集群、附着集群、伙伴云集群和多云集群。 集群配置跨云、跨地域统一下发，管理更简单 支持多云多集群配置策略的统一管理，支持企业级项目租户的权限管理，可以通过统一的策略管理中心完成多云多集群的合规性审计。 可视化监控洞察，运维更简单 支持立体化监控运维，并且兼容开源Prometheus和OpenTelemetry生态，拥有灵活的Dashboard，支持智能巡检、容器洞察、服务网格洞察。 算力统一调度，部署最优，运行最佳 基于Karmada内核，UCS可完成上千个分布式集群的统一接入，实现百万节点资源的协同调度，并拥有秒级响应速度。为用户提供了多种分布式部署策略，可以做到根据全局资源分布和业务特点，结合地理位置、网络QoS、资源均衡度等条件对应用进行最优化部署。 应用统一流量治理，提升业务体验 UCS可基于访问位置和业务策略对全域流量进行最优化调度，支持跨云多集群服务接入和流量管理，可实现基于权重、内容进行流量切分、灰度、故障倒换、熔断限流等功能。 应用数据协同，一键迁移 UCS实现了数据与业务一体化，围绕应用构建自动化的应用迁移、克隆能力，实现数据同步复制及跨云伸缩能力，支持存储层、容器层、中间件层等不同层次数据随应用场景实时联动，支撑应用容灾、扩容、迁移。 应用统一生态，全域可用 UCS拥有统一的服务规范，可真正实现应用开箱即用。通过自研部署引擎，统一服务生命周期管理，所有服务包统一管理、统一存储、全域分发，可实现跨云跨集群的一键部署。