本页介绍了通过mongodump和mongorestore工具迁移数据操作步骤。 通过使用mongodump和mongorestore工具来迁移文档数据库服务数据是一种常见且可靠的方法。这两个工具是MongoDB官方提供的备份和还原工具，可以帮助您将数据从一个文档数据库服务实例备份到文件，然后再将备份文件还原到另一个文档数据库服务实例。 以下是使用mongodump和mongorestore工具进行文档数据库服务数据迁移的步骤： 1. 使用mongodump备份数据： 在源文档数据库服务实例所在的服务器上运行mongodump命令，用于备份数据到文件。 mongodump命令：mongodump uriyoursourcemongodburi out/path/to/backupdirectory。 其中，yoursourcemongodburi是源文档数据库服务实例的连接URI，/path/to/backupdirectory是备份文件保存的目录。请确保您有权限在该目录下写入文件。 2. 将备份文件传输到目标服务器： 将上一步备份的文件传输到目标文档数据库服务实例所在的服务器，可以使用scp、rsync或其他文件传输工具。 3. 使用mongorestore还原数据： 在目标文档数据库服务实例所在的服务器上运行mongorestore命令，用于将备份文件还原到目标MongoDB实例。 mongorestore命令：mongorestore uriyourtargetmongodburi /path/to/backupdirectory。 其中，yourtargetmongodburi是目标MongoDB实例的连接URI，/path/to/backupdirectory是备份文件所在的目录。 4. 验证数据迁移： 运行完mongorestore命令后，您可以连接到目标文档数据库服务实例，并使用mongo shell或MongoDB客户端工具验证数据是否成功迁移。 注意 使用mongodump和mongorestore工具进行数据迁移会导致目标MongoDB实例上的数据完全被源实例中的数据覆盖。因此，在进行数据迁移前，请务必谨慎备份数据，并在生产环境之外进行测试和验证。如果迁移的目标实例上已经存在数据，那么请特别注意避免数据冲突和重复插入。另外，如果数据量较大或者需要在生产环境中进行数据迁移，考虑使用文档数据库服务副本集或分片集群，并采用逐步迁移的方式，以确保数据的连续性和一致性。

本页主要介绍关系数据库MySQL 5.7版本的测试结果。 测试限制 压测场景 压测分两个场景进行，您可以根据自身数据量判断使用哪种场景。 内存命中型：适用于数据量较小的场景，可将数据全量放入Buffer Pool进行存取。Buffer Pool默认大小为实例内存规格的50%70%。 磁盘I/O型：适用于数据量大的场景，只将最常访问的数据放入Buffer Pool进行存取，压测时会读写磁盘以及更新Buffer Pool。 压测指标 压力测试的指标包括TPS和QPS。 关系数据库MySQL版支持的IOPS取决于云硬盘的IO性能，具体请参见《云硬盘产品简介》中“产品规格”的内容。参考链接：云硬盘产品规格。 地域 由于不同地域的底层技术架构差异关系数据库MySQL版的测试数据在不同地域有所差异，按地域分为以下A/B两类测试结果以供参考。地域A包括所有I 类型资源池（以上海7为例），地域B包括II 类型资源池（以西南1为例），具体资源池信息请参见：产品简介功能概览。 测试结果 以下测试结果仅供参考，建议开通实例进行实际测试。 地域AI 类型资源池（上海7为例） 场景1：OLTP内存命中型 实例规格 单表数据量 表数量 最大连接数 TPS QPS 2核4GB（S2型） 80000 32 1000 517 10343 2核8GB（S2型） 80000 32 2000 571 11428 4核8GB（S2型） 80000 32 2000 1064 21296

步骤三：创建持久卷声明（PVC） 1. 创建示例yaml文件pvcstaticzos.yaml： plaintext apiVersion: v1 kind: PersistentVolumeClaim metadata: annotations: volume.beta.kubernetes.io/storageprovisioner: zos.csi.cstor.com name: pvcstaticzos namespace: default spec: accessModes: ReadWriteOnce resources: requests: storage: 5Gi volumeMode: Filesystem volumeName: {YOURPVNAME} 替换PV名称 2. 执行以下命令，创建pvc： plaintext kubectl apply f pvcstaticzos.yaml 步骤四：创建工作负载 1. 创建示例yaml文件podpvcstaticzos.yaml： shell apiVersion: apps/v1 kind: StatefulSet metadata: name: nginxpvcstaticzos labels: app: nginxpvcstaticzos spec: replicas: 1 serviceName: "" selector: matchLabels: app: nginxpvcstaticzos template: metadata: labels: app: nginxpvcstaticzos spec: containers: image: "registryhuadong1.crsinternal.ctyun.cn/opensource/nginx:1.26alpineslim" imagePullPolicy: "IfNotPresent" name: "nginx" resources: limits: cpu: "100m" memory: "256Mi" requests: cpu: "100m" memory: "256Mi" volumeMounts: mountPath: "/mnt/data" name: "volume1" subPath: "scetest" volumes: name: "volume1" persistentVolumeClaim: claimName: {YOURPVCNAME} 替换为步骤3中的PVC名称 2. 执行以下命令，创建StatefulSet： plaintext kubectl apply f podpvcstaticzos.yaml 步骤五：验证数据持久化 1. 登录弹性容器服务管理控制台。 2. 在容器组列表页点击刚才创建的实例。 3. 点击“远程连接”页签，进入到容器内。 4. 向/mnt/data 目录下写一个文件，执行: plaintext echo "Hello World" > /mnt/data/test.log 5. 查看/mnt/data 目录下文件，执行： plaintext cat /mnt/data/test.log 预期结果如下： 6. 退出“远程连接”，使用kubectl删除pod，会触发pod自动重建，等待Pod重新运行正常。 plaintext kubectl delete po nginxpvcstaticzos0 7. 对新建Pod，登录“弹性容器服务”管理控制台，继续执行“远程连接”，进入到容器内查看数据。执行： plaintext cat /mnt/data/test.log 预期结果如下： 8. 登录天翼云对象存储管理控制台，根据PV名称查看bucket，进入bucket中的文件管理，可以看到在容器内创建的文件： 下载文件并查看内容，预期结果与容器内写入数据一致。 9. 以上步骤说明，pod删除重建后，重新挂载对象存储卷，数据仍然存在；从对象存储下载数据并与写入数据一致， 说明对象存储中的数据可持久化保存。

天翼云学堂（ 注册 在天翼云官网没有账号的用户，请先注册一个账号，注册地址为[]( 登录 1) 在天翼云官网已经登录成功的用户，访问天翼云学堂时将会自动跳转并登录。 2) 没有在天翼云官网登录的用户，点击进入天翼云学堂后系统会跳转至天翼云官网登录页面，登录成功后将会返回天翼云学堂首页，此时天翼云学堂已经自动登录。 第一次进入天翼云学堂系统会跳转至身份认证页面，如下图所以： 1) 个人学习用户：点击【下一步】按钮直接进入首页，无需验证； 2) 中国电信员工： 点击【下一步】按钮需要进行企业邮箱验证，验证通过后进入首页；(员工务必选择准确所属公司，以免对学习数据统计造成影响) 3) 天翼云代理商：点击【下一步】按钮需要输入对应的企业邮箱和编号进行验证，验证通过后进入首页。 用户可以选择不进行验证，直接点击网页左上角的“天翼云学堂”logo进入首页，后期想要进行身份验证的时候，可以在[个人设置安全设置修改](

本节介绍如何安装混合备份客户端。 操作场景 混合备份通过客户端提供备份服务。备份操作前，需要在备份目标机器中安装客户端，可在控制台进行客户端安装操作。 约束与限制 操作系统限制：支持Windows7/10/11系列、Windows Server 2008/2012/2016/2019/2022系列、Ubuntu16/18/20系列、Centos6/7/8系列、统信UOS20、银河麒麟V10、阿里龙蜥8、其他通用Linux系列64位操作系统。 由于云备份服务需要与存储库端网络可达，请在目标机器端放行880、8888、8899端口。 备份目标机器必须处于开机状态，与存储库端网络可达。 每个目标机器仅允许安装一个客户端。若想更新客户端至最新版本，可以升级客户端。 操作步骤 1. 登录控制中心。 2. 在控制中心左上角点击，选择地域，此处选择华东华东1。 3. 选择“存储>云备份>混合备份（存储版）”，进入“主机列表”页签，点击“下载客户端”按钮，根据目标机器的CPU架构和操作系统选择对应的和客户端类型。 4. 若选择Windows类型 1. 选择存储库和网络传输方式。 1. 若选择公网方式，无需填写对应IP。 2. 若选择非公网方式，需先创建连接备份服务（华东1的备份服务实例ID为endpseryanvu0zc7z）的终端节点VPCE，创建好终端节点后在下载备份客户端界面填写终端节点IP地址。 2. 点击“下载”按钮，并将安装包拷贝到对应备份主机上。 3. 解压安装包，得到app.config文件和exe安装程序。 4. 确保解压出的两个文件在同级目录下，以管理员权限运行exe安装程序。 5. 选择安装路径，默认安装路径为：“C:Program Filesxclient”。 6. 点击下一步，等待安装完成，安装成功后，在“主机列表”页签中，查看目标机器为“在线”状态，即可为目标机器进行不同类型的数据备份。 5. 若选择Linux类型（Ubuntu、CentOS、统信、银河麒麟、阿里龙蜥、通用Linux） 1. 选择存储库和网络传输方式。 1. 若选择公网方式，无需填写对应IP。 2. 若选择非公网方式，需先创建连接备份服务（华东1的备份服务实例ID为endpseryanvu0zc7z）的终端节点VPCE，创建好终端节点后在下载备份客户端界面填写终端节点IP地址。 2. 点击“生成脚本”按钮，复制下载命令到对应备份主机上执行，获取客户端安装脚本。 3. 选择系统账户（备份oracle数据库时需要选择oracle账户，其他备份选择系统账户），点击“复制在线脚本”或“复制离线脚本”。 4. 在对应备份主机上执行上一步的脚本，等待客户端安装完成，安装成功后，在“主机列表”页签中，查看目标机器为“在线”状态，即可为目标机器进行不同类型的数据备份。

本章节会介绍如何管理关系型数据库管理表空间。 操作场景 关系型数据库提供基于root用户的PostgreSQL表空间管理方案。 创建表空间 步骤 1 以root用户连接数据库，并创建表空间。 psql host port dbname usernameroot c " select controltablespace ( 'create', ' ');" 参数说明 参数 说明 :: RDSADDRESS RDS实例的IP地址。 DBPORT RDS数据库实例的端口。 DBNAME 数据库名称。 TABLESPACENAME 表空间名称。 步骤 2 根据提示输入root用户密码。 登录至数据库“mydb”中并创建表空间“tbspc1”示例如下： psql host192.168.6.141 port5432 dbnamemydb usernameroot c "select controltablespace('create', 'tbspc1');" Password for user root: controltablespace create tablespace tbspc1 successfully. (1 row) 如创建不成功，详细信息请查看该实例错误日志。 说明 为考虑性能，用户最多可创建20个表空间。 删除表空间 步骤 1 以root用户连接数据库，并删除表空间。 psql host port usernameroot dbname c " select controltablespace ( 'drop',' ');" 参数说明 参数 说明 :: RDSADDRESS RDS实例的IP地址。 DBPORT RDS数据库实例的端口。 DBNAME 数据库名称。 TABLESPACENAME 表空间名称。 根据提示输入root用户密码。 示例如下：

本页介绍了如何管理天翼云RDSPostgreSQL产品的只读实例。 RDSPostgreSQL产品支持管理只读实例的功能，主要包括以下操作： 基础操作：重启、停止、升级等，支持绑定EIP和设置标签。 生命周期：退订、扩容（包括规格扩容和磁盘扩容）等。 参数设置：修改实例参数，并支持设置参数模板应用到只读实例。 实例操作：包括空闲连接查杀、清理在线表等。 实例监控：资源监控（主机资源包括CPU、IO等核心监控数据）、引擎监控（QPS、TPS、连接数、缓存等内核指标监控）、日志监控（慢日志、错误日志等）以及操作日志（包括控制台操作在内的监控等）。 数据库安全：白名单管理、数据库审计等安全操作。

本文主要介绍编辑参数模板 为确保文档数据库服务发挥出最优性能，您可以根据业务需求对自定义的参数模板中的参数进行调整。 文档数据库服务提供了两种修改参数的方法。 直接修改当前指定实例的参数。 该方法更改动态参数并保存数据库参数模板时，系统将立即应用更改，而不管“应用”设置如何。当您更改静态参数并保存数据库参数模板时，参数更改将在您手动重启该数据库实例后生效。 通过修改参数模板的参数值，将其应用于指定的实例。 该方法修改参数模板参数值后需执行“应用”操作，才会对实例生效。当您更改静态参数并保存数据库参数模板时，参数更改将在您应用到实例后，手动重启与数据库参数模板关联的数据库实例后生效。应用参数模板到数据库实例，请参见应用参数模板。 使用须知 您可以修改用户创建的数据库参数模板中的参数值，但不能更改系统提供的默认参数模板，默认参数模板只可单击参数模板名进行查看。 当用户参数设置不合理导致数据库无法启动时，可参考默认参数模板重新配置。 修改当前实例的参数 步骤 1 登录管理控制台。 步骤 2 单击管理控制台左上方的，选择区域和项目。 步骤 3 在页面左上角单击，选择“数据库 > 文档数据库服务 DDS”，进入文档数据库服务信息页面。 步骤 4 在左侧导航栏选择“实例管理”，单击指定实例名称，进入基本信息页面。 步骤 5 单击左侧导航栏中的“参数修改”，在“参数”页签下根据需要修改相关参数值。 修改当前实例的参数 步骤 6 根据实例类型修改参数。 如果实例类型为集群，在“参数修改”页签中，有mongos节点、shard节点和config节点，选择您需要的节点后，修改“ net.maxIncomingConnections ”的值，该参数表示mongos或mongod可接受的最大同时连接数量。 在界面右上角搜索框内输入“ net.maxIncomingConnections ”筛选最大连接数的参数。 修改最大连接数 如果实例类型为副本集，在“参数修改”页签中，有副本集节点和只读节点，选择您需要的节点后，修改“ net.maxIncomingConnections ”的值，该参数表示mongos或mongod可接受的最大同时连接数量。 在界面右上角搜索框内输入“ net.maxIncomingConnections ”筛选最大连接数的参数。 修改最大连接数 步骤 7 根据参数值的允许范围修改最大连接数值，该参数依赖于实例的规格，实例规格不同对应其默认值也不同。因此，此参数在用户未设置前显示为“default”，表示该参数随内存规格变化。更多参数相关说明，请参见。 单击“保存”，在弹出框中单击“确认”，保存修改。 单击“取消”，放弃本次设置。 单击“预览”，可对比参数修改前和修改后的值。 步骤 7 参数修改完成后，您可在“参数修改历史”页面，查看参数的修改详情。具体操作请参见查看当前实例的参数修改历史。 说明 根据参数列表中“是否需要重启”提示，进行相应操作： 是：在实例列表中，查看“运行状态”，如果显示参数模板变更，等待重启，则需重启实例使之生效。 否：无需重启，立即生效。

指标名称 单位 说明 每秒并发操作数 ops 每秒总请求数，包含读和写命令。 缓存命中率 % 命中率计算方法：Key命中数÷（Key命中数+Key未命中数）。 内存碎片率 % memfragmentationratio （内存碎片率） usedmemoryrss (操作系统实际分配给 Redis 的物理内存空间大小)/ usedmemory(Redis 内存分配器为了存储数据实际申请使用的内存空间大小) memfragmentationratio （内存碎片率）的值越大代表内存碎片率越严重。 已使用内存比例 % 统计Redis的内存利用率。 客户端连接数 count 统计已连接的客户端数量。 活跃客户端连接数 count 统计活跃的客户端的数量。 阻塞客户端连接数 count 统计被阻塞操作挂起的客户端的数量。 已使用内存 byte 统计Redis已使用的内存字节数。 已用内存RSS byte 统计Redis已使用的RSS内存。即实际驻留在内存中的内存数。包含和堆，但不包括换出的内存。 已用内存峰值 byte 统计Redis服务器启动以来使用内存的峰值。 每秒新建连接数 count 统计每秒新建连接数。 连接数使用率 % 统计连接数使用率。 平均时延 us 统计实例的平均时延。 命令最大调用时延 ms 统计实例命令最大调用时延。 Pubsub channels count 统计Pub/Sub通道个数。 Pubsub patterns count 统计Pub/Sub模式个数。 Key命中数 count 统计实例Key命中数。 每秒Key命中数 count/s 统计实例每秒Key命中数。 Key未命中数 count 统计在主字典中查找不命中次数。 每秒Key未命中数 count/s 统计每秒在主字典中查找不命中次数。 数据集使用内存 byte 统计Redis中数据集使用的内存。 数据集使用内存百分比 % 统计Redis中数据集使用的内存所占总内存百分比。 Lua已用内存 byte 统计Lua引擎已使用的内存字节。 已拒绝的连接数 count 统计周期内因为超过maxclients而拒绝的连接数量。 处理的命令数 count 统计周期内处理的命令数。 键总数 count 统计Redis缓存中键总数。 已设置过期时间的key总数 count 统计已设置过期时间的key总数。 历史过期key总数 count 统计历史过期key总数。 历史淘汰key总数 count 统计历史淘汰key总数。 历史累计逐出key总数 count 统计历史累计逐出key总数。 每秒过期key总数 count/s 统计每秒过期key总数。 每秒淘汰key总数 count/s 统计每秒淘汰key总数。 每秒逐出key总数 count/s 统计每秒逐出key总数。 字符串类型操作命令每秒调用次数 count/s 统计字符串类型操作命令每秒调用次数。 哈希类型操作命令每秒调用次数 count/s 统计哈希类型操作命令每秒调用次数。 keys类型操作命令每秒调用次数 count/s 统计keys类型操作命令每秒调用次数。 列表类型操作命令每秒调用次数 count/s 统计列表类型操作命令每秒调用次数。 发布订阅类型操作命令每秒调用次数 count/s 统计发布订阅类型操作命令每秒调用次数。 集合类型操作命令每秒调用次数 count/s 统计集合类型操作命令每秒调用次数。 有序类型集合操作命令每秒调用次数 count/s 统计有序类型集合操作命令每秒调用次数。 事务类型操作命令每秒调用次数 count/s 统计事务类型操作命令每秒调用次数。 HyperLog类型操作命令每秒调用次数 count/s 统计HyperLog类型操作命令每秒调用次数。 Script类型操作命令每秒调用次数 count/s 统计Script类型操作命令每秒调用次数。

本文介绍类CTyunOS私有镜像制作方法，类CTyunOS（如CentOS、openEuler、Kylin、Rocky、Suse、Redhat等）的私有镜像制作可参考本文。本文适用于x8664标准裸金属和弹性裸金属的私有镜像（弹性裸金属镜像需添加OFED驱动以支持DPU）。 1. 获取系统安装镜像 请通过提交工单以获取CTyunOS的系统安装光盘镜像，下面我们假设您已经获取了CTyunOS 23.01.2的系统安装光盘镜像ctyunos23.01.220230809x8664dvd.iso。 2. 使用virtmanager安装操作系统 2.1 确保有使用virtmanager的权限 注意，使用virtmanager需要必要的权限。如果使用非root用户操作virtmanager，可以把用户加入libvirt组。参考Libvirt，重启后当前用户加入libvirt组生效。 plaintext 把当前用户加入到libvirt组 sudo gpasswd a $USER libvirt 2.2 激活默认的虚拟网络 打开virtmanager，选中QEMU/KVM后，点上方菜单“编辑”> “连接详情”。出现“连接详情”窗口后选择“虚拟网络”标签页，点下方的三角按钮，激活默认的虚拟网络。 2.3 创建新虚拟机 点击工具栏中的“创建新虚拟机”以创建新虚拟机。选择“本地安装介质（ISO映像或者光驱）”后，点“Forward”。

本节主要介绍升级HBlock命令。 ./stor upgrade { filename f } file [ archfile PACKAGE & ] [ key VALUE ] 此命令用来升级HBlock。对于集群，只需要在一台服务器上执行升级即可。 说明 免费版仅支持2年内升级。 升级过程中系统会做检查，如果不符合升级条件，可能会导致升级失败，升级失败的原因可以在执行升级操作的服务器上查看日志upgrade.log（日志路径：HBlock安装目录/logs/ops/upgrade.log）。建议升级之前对系统进行检查，确保： 所有状态正常： 所有HBlock服务器连接正常，没有处于删除状态的服务器。 HBlock处于working、upgrading状态。 如果软件许可证是订阅模式，需在有效期内；如果软件许可证是永久许可模式，需在维保期限内；如果处于试用期，需试用期未结束。 集群版：如果卷是高可用类型，至少保证卷的主备连接正常。 没有处于失败或者任务进行中状态的卷。 系统整体数据冗余度不降级，正常数据百分比为100%。并且，可用故障域数量和健康数量大于所有卷的写入需求。 升级监听服务（stor:ua）正常。 协议解析服务（stor:ps）正常。 集群版：数据服务（stor:dsx）正常。 集群版：基础服务正常：元数据管理服务（stor:mdm）、日志服务（stor:ls）、协调服务（stor:cs）。 注意 执行升级HBlock前，确保每个服务器的HBlock安装路径对应的文件系统，存在至少1 GiB的可用空间。

本章节主要介绍集群（未启用Kerberos认证）安全配置建议。 Hadoop社区版本提供两种认证方式Kerberos认证（安全模式）和Simple认证（普通模式），在创建集群时，MRS支持配置是否启用Kerberos认证。 在安全模式下MRS集群统一使用Kerberos认证协议进行安全认证。 而普通模式下MRS集群各组件使用原生开源的认证机制，一般为Simple认证方式。而Simple认证，在客户端连接服务端的过程中，默认以客户端执行用户（例如操作系统用户“root”等）自动完成认证，管理员或业务用户不显示感知认证。而且客户端在运行时，甚至可以通过注入UserGroupInformation来伪装成任意用户（包括superuser），集群资源管理接口和数据控制接口在服务端无认证和鉴权控制，很容易被黑客利用和攻击。 所以在普通模式下，必须通过严格限定网络访问权限来保障集群的安全。操作建议如下： 尽量将业务应用程序部署在同VPC和子网下的ECS中，避免通过外网访问MRS集群。 配置严格限制访问范围的安全组规则，禁止对MRS集群的入方向端口配置允许Any或0.0.0.0的访问规则。 如需从集群外访问集群内组件原生页面，请参考创建连接MRS集群的SSH隧道并配置浏览器进行配置。

参数名 说明 检索内容 检索的关键字或正则表达式。 服务 选择所需查询日志的服务或模块。 文件 当且仅当选择服务中一个角色时，支持选择指定日志文件进行搜索。 最低日志级别 选择所需查询日志的最低级别，选择某一级别后会显示从本级别到更高级别的日志。级别从低到高依次为：TRACE < DEBUG < INFO < WARN < ERROR < FATAL 主机范围 单击 可勾选所需主机。 请输入所需查询日志的节点主机名或管理平面的IP地址。 各IP地址间用“,”隔开，例如：192.168.10.10,192.168.10.11。 如果IP地址连续，用“”连接。例如：192.168.10.[1020]。 如果IP地址分段连续，连续时用“”连接，各IP地址段间用“,”隔开，例如：192.168.10.[1020,3040]。 说明 如不指定，默认选择所有主机。 一次性输入最多10个表达式。 所有表达式一次性最多匹配2000个主机。 高级配置 最大数量：一次性显示的最大日志条数，如果检索到的日志数量超过设定值，时间较早的将被忽略。不配表示不限制。 检索超时：用于限制每个节点上的最大检索时间，超时后会中止搜索，已经搜索到的结果仍会显示。

本节介绍了查看任意数据库权限变更的相关内容。 操作场景 存储过程可以对指定登录账号设置允许查看任意数据库权限，禁止查看任意数据库后，只能看到master和tempdb数据库，无法看到其他数据库。 注意事项 存储过程只允许rdsuser或者创建出的主账号执行，创建的主账号具有和rdsuser相同的权限。创建主账号的存储过程详情请参见创建主账号。 默认情况下，所有用户都为public角色，可以看到实例上所有的数据库，但无法对没有权限的数据库进行访问或编辑。 不允许对rdsuser和其他内置账户进行查看数据库权限变更。内置账户详细信息请参考数据库安全设置。 前提条件 成功连接RDS for SQL Server实例。通过SQL Server客户端连接目标实例。 操作步骤 执行以下命令，设置用户是否可以看到所有数据库（不包含master和tempdb数据库）。 EXEC master.dbo.rdsviewanydatabase @user, @action ; @user: 指定用户。 @action: 指定操作。 − 'deny'：拒绝用户看到所有数据库。 − 'revoke'：允许用户看到所有数据库。 示例 拒绝用户testuser看到所有数据库，示例如下： EXEC master.dbo.rdsviewanydatabase 'testuser','deny' ; 允许用户testuser看到所有数据库，示例如下： EXEC master.dbo.rdsviewanydatabase 'testuser','revoke' ;

本章节主要介绍分布式消息服务RabbitMQ支持的监控指标。 功能说明 本章节定义了分布式消息服务RabbitMQ上报云监控服务的监控指标的命名空间，监控指标列表和维度定义，用户可以通过云监控服务提供的管理控制台来检索DMS服务产生的监控指标和告警信息，也可以通过分布式消息服务RabbitMQ控制台提供的“监控”页面来检索RabbitMQ实例产生的监控指标。 命名空间 SYS.DMS 实例监控指标 表1 实例支持的监控指标 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始指标） connections 连接数 该指标用于统计RabbitMQ实例中的总连接数。单位：Count > 0 RabbitMQ实例 1分钟 channels 通道数 该指标用于统计RabbitMQ实例中的总通道数。单位：Count 0~2047 RabbitMQ实例 1分钟 queues 队列数 该指标用于统计RabbitMQ实例中的总队列数。单位：Count 0~1200 RabbitMQ实例 1分钟 consumers 消费者数 该指标用于统计RabbitMQ实例中的总消费者数。单位：Count 0~1200 RabbitMQ实例 1分钟 messagesready 可消费消息数 该指标用于统计RabbitMQ实例中总可消费消息数量。单位：Count 0~10000000 RabbitMQ实例 1分钟 messagesunacknowledged 未确认消息数 该指标用于统计RabbitMQ实例中总已经消费但还未确认的消息数量。单位：Count 0~10000000 RabbitMQ实例 1分钟 publish 生产速率 统计RabbitMQ实例中实时消息生产速率。单位：Count/s 0~25000 RabbitMQ实例 1分钟 deliver 消费速率（手工确认） 统计RabbitMQ实例中实时消息消费速率（手工确认）。单位：Count/s 0~25000 RabbitMQ实例 1分钟 delivernoack 消费速率（自动确认） 统计RabbitMQ实例中实时消息消费速率（自动确认）。单位：Count/s 0~50000 RabbitMQ实例 1分钟 connectionsstatesrunning 运行状态的连接个数 该指标用于统计整个实例中的connection，状态是starting/tuning/opening/running状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 connectionsstatesflow flow状态的连接数 该指标用于统计整个实例中的connection，状态是flow状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 connectionsstatesblock block状态的连接数 该指标用于统计整个实例中的connection，状态是blocking/blocked状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 connectionsstatesclose close状态的连接数 该指标用于统计整个实例中的connection，状态是closing/closed状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 channelsstatesrunning 运行状态的通道数 该指标用于统计整个实例中的channel，状态是starting/tuning/opening/running状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 channelsstatesflow flow状态的通道数 该指标用于统计整个实例中的channel，状态是flow状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 channelsstatesblock block状态的通道数 该指标用于统计整个实例中的channel，状态是blocking/blocked状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 channelsstatesclose close状态的通道数 该指标用于统计整个实例中的channel，状态是closing/closed状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 queuesstatesrunning 运行状态的队列数 该指标用于统计整个实例中的queue，状态是running状态的总数。单位：Count > 0 RabbitMQ实例 1分钟 queuesstatesflow flow状态的队列数 该指标用于统计整个实例中的queue，状态是flow状态的总数。单位：Count > 0 RabbitMQ实例 1分钟

接口功能介绍 查看监听器列表 接口约束 无 URI GET /v4/elb/listlistener 路径参数 无 Query参数 参数 是否必填 参数类型 说明 示例 下级对象 clientToken 否 String 客户端存根，用于保证订单幂等性。要求单个云平台账户内唯一, 公共参数不支持修改, 长度 1 64 xxx regionID 是 String 区域ID 81f7728662dd11ec810800155d307d5b projectID 否 String 企业项目ID，默认为'0' 0 IDs 否 String 监听器ID列表，以','分隔 'listener75ex90k9v0,listenercertr4cfhgrsss' name 否 String 监听器名称 test loadBalancerID 否 String 负载均衡实例ID lbxxx accessControlID 否 String 访问控制ID xxx 请求参数 请求头header参数 无 请求体body参数 无 响应参数 参数 参数类型 说明 示例 下级对象 statusCode Integer 返回状态码（800为成功，900为失败） 800 message String statusCode为900时的错误信息; statusCode为800时为success, 英文 success description String statusCode为900时的错误信息; statusCode为800时为成功, 中文 成功 errorCode String statusCode为900时为业务细分错误码，三段式：product.module.code; statusCode为800时为SUCCESS SUCCESS returnObj Array of Objects 接口业务数据 returnObj 表 returnObj 参数 参数类型 说明 示例 下级对象 regionID String 区域ID 81f7728662dd11ec810800155d307d5b azName String 可用区名称 az1 projectID String 项目ID 0 ID String 监听器ID xxx name String 监听器名称 test description String 描述 desc loadBalancerID String 负载均衡实例ID lbxxx protocol String 监听协议: TCP / UDP / HTTP / HTTPS TCP protocolPort Integer 监听端口 8080 certificateID String 证书ID certxxx caEnabled Boolean 是否开启双向认证 false clientCertificateID String 双向认证的证书ID xxx defaultAction Object 默认规则动作 defaultAction accessControlID String 访问控制ID xxx accessControlType String 访问控制类型: Close / White / Black Close forwardedForEnabled Boolean 是否开启x forward for功能 false status String 监听器状态: DOWN / ACTIVE DOWN createdTime String 创建时间，为UTC格式 20221003T09: 44: 22Z updatedTime String 更新时间，为UTC格式 20221003T09: 44: 22Z allPortForward Integer 全端口转发功能开关 0 startPort Integer 全端口转发的起始port 0 endPort Integer 全端口转发的最终port 0 cps Integer 四层最大连接数 0 qps Integer 七层每秒请求数 0 establishTimeout Integer 连接超时时间 300 idleTimeout Integer 空闲超时时间 15 responseTimeout Integer 请求超时时间 60 gzip Integer gzip压缩功能开关 0 nat64 Integer nat64功能开关 0 natMode Integer NAT模式，默认0，0为FULLNAT，1为DNAT 0 表 defaultAction 参数 参数类型 说明 示例 下级对象 type String 默认规则动作类型: forward / redirect FORWARD forwardConfig Object 转发配置 forwardConfig redirectListenerID String 重定向监听器ID XXX 表 forwardConfig 参数 参数类型 说明 示例 下级对象 targetGroups Array of Objects 后端服务组 targetGroup 表 targetGroup 参数 参数类型 说明 示例 下级对象 targetGroupID String 后端服务组ID tgxxx weight Integer 权重 20

问题描述 已经正常开通并使用的裸金属，用户升级CentOS系统内核后，无法连接服务器 (升级内核前使用NetworkManager)。 可能原因 内核升级后NetworkManager未设置开机自启动。 解决方案 联系运营管理员，登录服务器查看NetworkManager状态，是否正常运行； Bash 查看NetworkManager是否开机自启动 systemctl isenabled NetworkManager 如图所示: 其中 disabled 说明NetworkManager服务未启动。 执行下述命令行 Bash systemctl start NetworkManager 开启NetworkManager服务 systemctl enable NetworkManager 设置开机自启动

数据开发中的对象 数据连接：定义访问数据实体存储（计算）空间所需信息的集合，包括连接类型、名称和登录信息等。 解决方案：解决方案为用户提供便捷的、系统的方式管理作业，更好地实现业务需求和目标。每个解决方案可以包含一个或多个业务相关的作业，一个作业可以被多个解决方案复用。 作业：作业由一个或多个节点组成，共同执行以完成对数据的一系列操作。 脚本：脚本（Script）是一种批处理文件的延伸，是一种纯文本保存的程序，一般来说的计算机脚本程序是确定的一系列控制计算机进行运算操作动作的组合，在其中可以实现一定的逻辑分支等。 节点：定义对数据执行的操作。 资源：用户可以上传自定义的代码或文本文件作为资源，以便在节点运行时调用。 表达式：数据开发作业中的节点参数可以使用表达式语言（Expression Language，简称EL），根据运行环境动态生成参数值。数据开发EL表达式包含简单的算术和逻辑计算，引用内嵌对象，包括作业对象和一些工具类对象。 环境变量：环境变量是在操作系统中一个具有特定名字的对象，它包含了一个或者多个应用程序所将使用到的信息。 补数据：手工触发周期方式调度的作业任务，生成某时间段内的实例。

本章节主要介绍如何快速创建一个数据湖集群。 数据湖场景提供更高效、灵活的管理集群，更快地运行大数据的计算引擎，更好地提供数据分析能力。在创建数据湖集群前，需要先创建虚拟私有云。 操作步骤 1、进入集群创建页面 方法一：登录翼MapReduce产品详情页，直接点击“立即开通”。 方法二：进入翼MapReduce产品一类节点资源池的产品控制台，点击“+创建集群”。 2、软件配置 进入“创建集群”页面进行配置与订购，软件配置页面如下图所示，参数说明如下： 区域集群与可用区：集群节点所在的物理位置，根据需要选择区域及可用区，也可以使用默认值。 业务场景：选择“数据湖”场景。 产品版本：选择使用的产品版本，默认值即可。 服务高可用：翼MapReduce默认启用服务高可用且不可关闭高可用模式。 可选服务：由可选组件和必选组件组成，根据业务场景而定。您可根据自身业务场景对可选组件进行选择。 元数据：使用Hive、Ranger、Amoro、Hue与DolphinScheduler组件服务时，需要配置元数据库。请先确认是否已有CTRDS MySQL实例，若尚未创建，可点击提示链接，前往“关系数据库MySQL版”进行开通。若已创建实例，请勾选该选项并进行元数据配置。 元数据配置：勾选“使用已有CTRDS for MySQL”后，请在展开信息中填写所需的5项配置信息。 注意 1、当前仅支持通过内网地址进行数据库连接。请选择关联与当前集群同一虚拟私有云（VPC）下的MySQL数据库。 2、配置Hive、Ranger、Amoro、Hue与DolphinScheduler的元数据信息时，请提前创建数据库，若需要部署多个服务，请创建多个数据库，创建方式可参考创建数据库。 3、元数据配置所需信息可前往数据库控制台查看。 4、请确保配置的数据库用户具有该数据库的读写权限。 5、创建集群时，若元数据库配置错误，将导致Hive/Ranger/Amoro/Hue/DolphinScheduler异常，但不影响集群的创建与部署，集群创建后，您可前往Manager的集群服务，进入集群服务详情，通过运维操作中的“元数据库配置”操作，替换原有元数据库的配置信息。 Kerberos身份认证：集群中的软件以Kerberos安全模式启动，此选项不可关闭。 自定义服务配置：支持指定JSON文件对集群中的组件服务，如HDFS、Spark、Hive等进行参数配置，详细使用方法请参见++自定义服务配置++。默认不开启。

本文介绍如何登录ECI实例。 前提条件 实例中的容器处于运行中状态。 操作步骤 1. 在弹性容器实例控制台左侧导航栏中选择“容器组”，进入容器组列表页。 2. 在容器组列表中找到想要调试的实例，点击实例名称进入实例详情页面。 3. 点击远程连接，进入容器登录终端。

本页介绍天翼云TeleDB数据库监控概览。 操作场景 监控概览支持提供全面的实例监控功能，保证用户实时了解实例的运行状态。默认只保留一个月的监控数据。 操作步骤 1. 以用户名和密码登录分布式数据库TeleDB控制台，在左侧导航树单击实例监控 ，选择监控概览页签。 2. 监控概览页面展示了整个集群的全局信息，包括全局事务管理器、协调节点和数据节点的基本信息，具体如下： 节点运行状态：包括三种状态，运行中/停止/异常 节点基本信息：节点名，主机ip，主备信息等 节点请求量：GTM节点不接受请求，不展示 节点连接数：GTM节点不接受业务连接，不展示 节点CPU占用率 节点内存占用大小

配置项 描述 鉴权名称 唯一标识鉴权规则的名称。 鉴权类型 选择自建服务鉴权。 鉴权服务 选择自建鉴权服务，可以通过下拉选择已接入服务和地址或手动输入服务地址。 鉴权API 鉴权服务提供的鉴权API的路径。 Token配置 从请求获取Token的位置，支持选择header、Cookie，并指定对应的key。 鉴权请求中允许携带的头部 如果需要额外携带客户端请求中的头部，那么需要在字段中按需配置头部。说明： Host、Path头部会被默认添加。 超时时间 请求鉴权服务最大等待时间（单位：秒），默认值：10。 模式 支持宽松模式和严格模式，默认使用宽松模式： 宽松模式：当鉴权服务不可用时（鉴权服务建立连接失败或者返回5xx请求），接受客户端请求。 严格模式：当鉴权服务不可用时（鉴权服务建立连接失败或者返回5xx请求），拒绝客户端请求。 鉴权应用 选择需要鉴权的应用范围。注意 ：应用将验证令牌，并携带令牌信息进行下游调用，因此对于每个鉴权应用，其上游调用链路中的应用需纳入鉴权范围。

本页介绍天翼云TeleDB数据库监控概览。 操作场景 监控概览支持提供全面的实例监控功能，保证用户实时了解实例的运行状态。默认只保留一个月的监控数据。 操作步骤 1. 切换至TeleDB控制台，在左侧导航树单击实例监控 ，选择监控概览页签。 2. 监控概览页面展示了整个集群的全局信息，包括全局事务管理器、协调节点和数据节点的基本信息，具体如下： 节点运行状态：包括三种状态，运行中/停止/异常。 节点基本信息：节点名，主机ip，主备信息等。 节点请求量：GTM节点不接受请求，不展示。 节点连接数：GTM节点不接受业务连接，不展示。 节点CPU占用率：节点CPU占用率。 节点内存占用大小：节点内存占用大小。

本章节主要介绍了在SQL Server实例中使用SQL语句进行数据库管理。 删除数据库 连接sqlserver实例，执行以下命令，删除数据库： DROP DATABASE [TESTDB]; GO 注意 用户需要配置为所有者权限才能执行删除数据库的命令，否则会产生如下报错： "Cannot drop the database 'TESTDB', because it does not exist or you do not have permission."

本节包含了通用计算增强型C7n弹性云主机的概述、规格。 概述 C7n型弹性云主机搭载第三代英特尔® 至强® 可扩展处理器 ，受益于IceLake架构，性能全面提升。 类型 CPU基频/睿频 CPU型号 ::: C7n 2.6GHz/3.4GHz Intel 6348 规格 表 C7n型弹性云主机的规格 规格名称 vCPU 内存(GiB) 最大带宽/基准带宽（Gbps） 最大收发包能力（万PPS） 网络连接数（万） 网卡多队列数 网卡个数上限 虚拟化类型 c7n.large.2 2 4 4/0.8 40 50 2 2 KVM c7n.xlarge.2 4 8 8/1.6 80 50 2 3 KVM c7n.2xlarge.2 8 16 15/3 150 100 4 4 KVM c7n.3xlarge.2 12 24 17/5 200 150 4 6 KVM c7n.4xlarge.2 16 32 20/6 280 150 8 8 KVM c7n.6xlarge.2 24 48 25/9 400 200 8 8 KVM c7n.8xlarge.2 32 64 30/12 550 300 16 8 KVM c7n.12xlarge.2 48 96 35/18 750 400 16 8 KVM c7n.16xlarge.2 64 128 36/24 800 500 28 8 KVM c7n.24xlarge.2 96 192 40/36 850 800 32 8 KVM c7n.large.4 2 8 4/0.8 40 50 2 2 KVM c7n.xlarge.4 4 16 8/1.6 80 50 2 3 KVM c7n.2xlarge.4 8 32 15/3 150 100 4 4 KVM c7n.3xlarge.4 12 48 17/5 200 150 4 6 KVM c7n.4xlarge.4 16 64 20/6 280 150 8 8 KVM c7n.6xlarge.4 24 96 25/9 400 200 8 8 KVM c7n.8xlarge.4 32 128 30/12 550 300 16 8 KVM c7n.12xlarge.4 48 192 35/18 750 400 16 8 KVM c7n.16xlarge.4 64 256 36/24 800 500 28 8 KVM c7n.24xlarge.4 96 384 40/36 850 800 32 8 KVM

runningacommandinashell " ")。 容器的生命周期与启动命令的生命周期一致，即启动命令执行完成后容器的生命周期结束。 下面将以启动一个nginx 为例，介绍容器启动命令典型的三个使用场景： 示例代码如下： nginx c nginx.conf 场景一：容器的“运行命令”和“运行参数”均作设置，界面截图如下： 运行命令和运行参数均设置 所生成的YAML样例如下： command: nginx args: 'c' nginx.conf 场景二：仅设置容器的“运行命令”，界面截图如下： 仅设置运行命令 说明： 运行命令中前后要加英文双引号""，若不加则会按照空格将命令拆分成多条执行。 所生成的YAML样例如下： command: nginx c nginx.conf args: 场景三：仅设置容器的“运行参数”，界面截图如下： 仅设置运行参数 说明： 如果运行命令没有添加到系统路径中，可以使用/bin/sh来执行命令，命令需要加英文双引号""。 所生成的YAML样例如下： command: /bin/sh args: 'c' '"nginx c nginx.conf"' 步骤 3 您可以通过如下方式检查或修改YAML： 创建工作负载时，在“高级设置”步骤中，单击右侧的“YAML创建”。 工作负载创建完成后，在工作负载列表中，单击工作负载名称后的“更多 > 编辑YAML”。 工作负载创建完成后，进入工作负载详情页面，单击右上角的“编辑YAML”。 设置容器启动命令YAML样例 本节以nginx为例，说明通过kubectl设置容器启动命令的方法。 前提条件 请参见通过kubectl操作CCE集群配置kubectl命令，使弹性云主机连接集群。 操作步骤 参见通过kubectl命令行创建无状态工作负载或通过kubectl命令行创建有状态工作负载时，容器启动命令的参数设置如下所示，详细请参见kubernetes官方文档。 apiVersion: extensions/v1beta1 kind: Deployment metadata: name: nginx spec: replicas: 1 selector: matchLabels: app: nginx strategy: type: RollingUpdate template: metadata: labels: app: nginx spec: containers: image: nginx command: sleep '3600'

本文介绍了关系数据库MySQL版的内存使用率过高的一些处理方法以及MySQL的内存分配方式。 对于用户核心业务相关的但是配置相对较低的数据库实例 建议您扩容实例规格，具体请参见规格扩容。 对于非用户核心业务相关的数据库实例 查看实例虚拟机内存使用率的相关监控，内存使用率曲线持续平缓，则无需处理。 对于用户核心业务相关但是数据库规格配置高的数据库实例 1. 通过控制台监控，观察实例的内存使用趋势情况，如果实例的内存使用率仍持续保持较高： 扩容实例规格。 调整数据库参数innodbbufferpoolsize的值： 数据库实例内存为2GB规格，参考值256MB。 数据库实例内存为4GB规格，参考值1GB。 数据库实例内存为8GB规格，参考值3GB。 数据库实例内存大于8GB规格，则无需调整。 说明 根据实际业务实际情况和内存使用情况，调整参数innodbbufferpoolsize的值。 MySQL本身具有内存动态平衡机制，系统内存使用率90%以下时可无需关注。 MySQL的内存分配可划分为Engine层与Server层。 Engine层的内存包括InnoDB Buffer Pool、Log Buffer、Table Cache、Table definition Cache，其中InnoDB Buffer Pool主要用于缓存表数据页、索引页、数据字典等常用数据，数据库的绝大部分内存都被此占用，这类缓存一般都为常驻内存。InnoDB缓冲池是一个内存区域，可以通过参数innodbbufferpoolsize改变缓冲池大小。 Server层的内存占用较高的包括Thread Cache、Binlog Cache、Sort Buffer、Read Buffer、Join Buffer，read buffer等线程缓存，针对每个数据库连接会话独立分配的缓存，独立缓存的总量与连接数成正比，连接数越高，总的独立缓存便越大，但是这类缓存往往会随着连接关闭而释放，并非常驻内存。 以上内存的分配导致MySQL实例运行时内存使用率在80%左右。

失败原因 处理建议 源库为集群的从节点，且logslaveupdates参数不为ON，期间源库重放集群主节点的事务将不会同步到目标库。 如果所连接的源库为集群的从节点，需要将源库的logslaveupdates设置为ON。

本节介绍了内网访问的用户指南。 背景 为了优化用户体验，容器镜像服务现已支持内网访问功能。通过此功能，您可以在指定的虚拟私有云 (VPC) 内建立一条内网访问通道，实现从该 VPC 内网直接访问容器镜像服务。 启用内网访问后，将在您选择的 VPC 中自动完成以下配置： 创建 VPC 终端节点 (VPCE)： 用于建立 VPC 与容器镜像服务公共 VPC 服务之间的内网连接。 配置内网DNS解析：确保 VPC 内的实例能够通过容器镜像服务的内网域名正确解析到VPCE地址。 操作步骤 1. 登录容器镜像服务控制台。 2. 在左侧导航栏，点击内网访问。 首次使用授权：如果您是第一次使用内网访问功能，系统会提示您进行授权委托。这是为了允许容器镜像服务在您的 VPC 内创建必要的网络资源。请仔细阅读授权内容，确认并完成授权。授权成功后，系统将为您创建一个名为 CtyunAssumeRoleForCRS 的服务委托。 3. 选择需要接入的 VPC。 您可以根据实际需求选择以下方式接入 VPC： 单个 VPC 接入： 在 VPC 列表中，找到您需要开通内网访问的 VPC，点击该 VPC 所在行的接入按钮。默认选择该VPC的第一个子网创建VPCE，如需指定子网创建VPCE，可下拉子网列表进行选择。 批量 VPC 接入： 如果您需要为多个 VPC 同时开通内网访问，可以勾选多个 VPC，然后点击列表上方的 批量接入按钮。默认选择每个VPC的第一个子网创建VPCE，如需指定子网创建VPCE，可下拉子网列表进行选择。 4. 取消 VPC 接入 (可选)： 如果您需要取消某个已接入内网访问的 VPC，可以找到该 VPC，点击其所在行的取消接入按钮。 注意 由于创建 VPC 终端节点需要一定时间，接入过程可能需要稍作等待。如果遇到提示 “VPCE 创建中，请稍后重试发起请求，以继续创建内网 DNS 记录” 的报错信息，请稍等片刻后点击 批量重试 按钮，系统将继续为您完成接入操作。

资源类型 资源名称 资源路径 queue DLI队列 queues.queuename database DLI数据库 databases.dbname table DLI表 databases.dbname.tables.tbname column DLI列 databases.dbname.tables.tbname.columns.colname jobs DLI Flink作业 jobs.flink.jobid resource DLI程序包 resources.resourcename group DLI程序包组 groups.groupname datasourceauth DLI跨源认证信息 datasourceauth.name edsconnections DLI增强跨源 edsconnections.连接ID

本章节主要介绍翼MapReduce组件Spark的操作使用说明。 Sparkbeeline连接的目标可以是spark thrift server、也可以是kyuubi server。 我们以spark thrift server为例，提供链接流程如下： 1. 首先配置spark thrift相关配置。 1. Sparkenv.sh 中配置需要配置JAVAHOME、HADOOPHOME、HADOOPCLASSPATH、HADOOPCONFDIR等环境变量。 2. SPARKHOME/conf 路径下的hivesite.xml文件中，需要配置如下： hive.server2.transport.mode Set this to value: http hive.server2.thrift.http.port HTTP port number to listen on; default is 10001 如果hivesite.xml是软连接，且spark和hive混布，那么需要直接cp该文件到SPARKHOME/conf下面。 3. Sparkdefaults.conf中如果hadoop集群开启了Kerberos认证，那么需要配置spark.sql。 2. 启动spark thrift server。 SPARKHOME/sbin/startthriftserver.sh 3. 如果当前集群已启用Kerberos认证，执行以下命令认证当前用户。如果当前集群未启用Kerberos认证，则无需执行此命令。 1. 首先klist kt ，获取keytab文件的principal，例如 klist kt user.keytab 获得 user/hostname@realm。 2. 然后kinit kt ，例如 kinit kt user.keytab user/hostname@realm。 3. Kinit认证完成登录后，可以klist l查看。 4. Beeline链接sparkthriftserver。 SPARKHOME/bin u ‘jdbc:hive2:// : / ;principaluser/hostname@realm?spark.yarn.queueroot.default’ n user 5. 执行如下命令查询所有表，返回结果中存在表test，即表示访问OBS成功。 show databases

本章节介绍普通消息的收发方法和示例代码。其中，普通消息发送方式分为同步发送、异步发送、单向发送。 同步发送：同步发送是指消息发送方发出一条消息后，会在收到服务端同步响应之后才发下一条消息的通讯方式。 异步发送：异步发送是指发送方发出一条消息后，不等服务端返回响应，接着发送下一条消息的通讯方式。 单向发送：发送方只负责发送消息，不等待服务端返回响应且没有回调函数触发。 收发消息前，请参考收集连接信息收集RocketMQ所需的连接信息。 准备环境 开源的Java客户端支持连接分布式消息服务RocketMQ版，推荐使用的客户端版本为4.9.7。 通过以下任意一种方式引入依赖： 1. 使用Maven方式引入依赖。 org.apache.rocketmq rocketmqclient 4.9.7 org.apache.rocketmq rocketmqacl 4.9.7 2. 点击下载依赖JAR包：rocketmqall4.9.7binrelease.zip 同步发送 同步发送是最常用的方式，是指消息发送方发出一条消息后，会在收到服务端同步响应之后才发下一条消息的通讯方式，可靠的同步传输被广泛应用于各种场景，如重要的通知消息、短消息通知等。 参考如下示例代码 import org.apache.rocketmq.acl.common.AclClientRPCHook; import org.apache.rocketmq.acl.common.SessionCredentials; import org.apache.rocketmq.client.producer.DefaultMQProducer; import org.apache.rocketmq.client.producer.SendResult; import org.apache.rocketmq.common.message.Message; import org.apache.rocketmq.remoting.RPCHook; import org.apache.rocketmq.remoting.common.RemotingHelper; public class ProducerNormalExample { private static RPCHook getAclRPCHook() { return new AclClientRPCHook(new SessionCredentials( "accessKey", // 分布式消息服务RocketMQ控制台用户管理菜单中创建的用户ID "accessSecret" // 分布式消息服务RocketMQ控制台用户管理菜单中创建的密钥 )); } public static void main(String[] args) throws Exception { DefaultMQProducer producer new DefaultMQProducer("YOUR GROUP ID", getAclRPCHook()); // 填入控制台获取NAMESRV接入点地址 producer.setNamesrvAddr("XXX:xxx"); ; // 如果需要开启SSL，请增加此行代码 producer.start(); for (int i 0; i < 128; i++) try { { Message msg new Message("YOUR TOPIC", "TagA", "Hello RocketMQ".getBytes(RemotingHelper.DEFAULTCHARSET)); SendResult sendResult producer.send(msg); System.out.println(sendResult); } } catch (Exception e) { e.printStackTrace(); } producer.shutdown(); } }