您需要在部署天翼云TeleDB数据库之前，规划相关的硬件、网络及基础环境。 在部署环境之前，硬件、网络及基础环境必须满足如下要求： 服务器芯片：支持国产鲲鹏、海光、龙芯 服务器规格：4C8G及以上 磁盘：推荐1T及以上，实例节点服务器建议使用SSD 网络:千兆网络，实例节点服务器建议万兆网卡 操作系统版本：麒麟V10 SP3、统信V20 部署机器SSH 版本要求 7.4以上 最小化部署主机数量：TeleDB控制台一台主机，实例主机至少两台， 最小化资源部署需要三台主机 主机规格要求：控制台主机系统为centos7.6+intelx86 ，8c16g以上，建议为8c32g，实例主机系统可选择centos7.6+intelx86或者ctyunos201+鲲鹏920 准备一个数据盘，控制台主机建议500G，实例主机根据数据量判断 主机名 规格 目录及大小 系统及CPU类型 说明 A机器 8C32G 系统盘500G/app1T centos7.6+intelx86 用于安装TeledbDB控制台 B机器 8C32G 系统盘500G/app1T centos7.6+intelx86 用于安装实例主机 C机器 8C32G 系统盘500G/app1T centos7.6+intelx86 用于安装实例主机

项目 描述 存储池名称 存储池名称。 ：表示是基础存储池。 状态 存储池状态： 正常。 删除中。 故障域级别 存储池故障域级别： 数据目录级别。 服务器级别。 机架级别。 机房级别。 容量 存储池总容量。 缓存存储池卷 使用该存储池作为缓存存储池的卷。 存储池卷 使用该存储池作为存储池的卷。 卷存储模式：个数/容量 各种模式卷对应的个数及卷总容量。

本节介绍了查看迁移对象的相关内容。 当迁移任务配置成功并启动后即可查看迁移对象详情。 前提条件 已登录数据复制服务控制台。 操作步骤 步骤 1 在“实时迁移管理”界面，选择指定的迁移任务，单击任务名称。 步骤 2 页面跳转至“基本信息”，切换到“对象明细”页签，查看当前迁移任务的迁移对象。 说明 在对象展示的时候，对象名称的前后空格不显示，中间如有多个空格只显示一个空格。 结束

本文介绍弹性文件服务安全监控告警方面的内容。 云监控服务是天翼云针对云网资源的一项监控服务，弹性文件通过云监控服务提供监控和告警能力。通过查看文件系统的监控数据，您可以了解到文件系统的使用情况。通过设置告警规则可以监控文件系统实例异常情况，保障业务正常进行。 关于弹性文件服务支持的监控指标，以及如何创建监控告警规则等内容，请参见监控。

参数 参数类型 说明 示例 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 接口业务数据 见下表

点播模式下的媒资删除完成回调事件。 事件名称 DeleteComplete 事件说明 媒资删除完成。 示例 json { "eventTime":"20170320T07:49:17Z", "eventType":"DeleteComplete", "videoID":"45caa4a6488844a3aaa2ea1334a7b806", "mediaType":"Video" } 返回数据描述 名称 示例值 描述 ::: eventTime 20170320T07:49:17Z 事件触发时间，为 UTC 时间，如 yyyyMMddTHH:mm:ssZ。 eventType DeleteComplete 回调事件类型。 videoID 45caa4a6488844a3aaa2ea1334a7b806 视频上传到【媒体库】的唯一标识ID。 mediaType Video 删除媒资类型：Video视频类型;Image图片类型。

物理机异常重启后无法挂卷，如何处理？ 问题现象 携数据卷的本地盘发放物理机，异常重启后发现操作系统内没有卷信息，也无法在管理控制台上挂卷。 这里的异常重启指的是除租户在控制台上操作之外的其他非正常上下电。 解决方案 在待处理的物理机所在行，单击“更多 > 重启”，重启之后卷就会自动挂载。 如果重启后仍无法挂卷，可以提交工单，联系客服处理。

本章节介绍如何设置安全组规则。 操作场景 安全组是一个逻辑上的分组，为同一个虚拟私有云内具有相同安全保护需求，并相互信任的弹性云服务器和关系型数据库实例提供访问策略。 为了保障数据库的安全性和稳定性，在使用关系型数据库实例之前，您需要设置安全组，开通需访问数据库的IP地址和端口。 通过弹性公网IP连接RDS实例时，需要为RDS所在安全组配置相应的 入方向规则 。 注意事项 因为安全组的默认规则是在出方向上的数据报文全部放行，同一个安全组内的弹性云服务器和关系型数据库实例可互相访问。安全组创建后，您可以在安全组中定义各种访问规则，当关系型数据库实例加入该安全组后，即受到这些访问规则的保护。 默认情况下，一个租户可以创建500条安全组规则。 为一个安全组设置过多的安全组规则会增加首包延时，因此，建议一个安全组内的安全组规则不超过50条。 当需要从安全组外访问安全组内的关系型数据库实例时，需要为安全组添加相应的 入方向规则 。 说明 源地址默认的IP地址0.0.0.0/0是指允许所有IP地址访问安全组内的关系型数据库实例。 操作步骤 步骤 1 登录管理控制台。 步骤 2 在系统首页，单击“网络 > 虚拟私有云”。 步骤 3 在左侧导航树选择“访问控制 > 安全组”。 步骤 4 在安全组界面，单击操作列的“配置规则”，进入安全组详情界面。 步骤 5 在安全组详情界面，单击“添加规则”，弹出添加规则窗口。 步骤 6 根据界面提示配置安全组规则。 步骤 7 单击“确定”。

本节介绍了云数据库GaussDB 的产品价格。 云数据库GaussDB提供企业版和基础版两种产品类型，均支持分布式版和集中式版两种部署形态，同时也支持X86和鲲鹏平台。 云数据库GaussDB的计费项由GaussDB实例费用、存储空间费用、备份空间费用（仅超出部分收费）和公网带宽费用（可选）组成。 包年优惠政策一年85折、两年7折、三年5折。 详细规格价格如下： 一、实例费用 1、企业版实例 云数据库GaussDB企业版的规格，根据X86和鲲鹏平台进行划分。其中分布式版和集中式版两种部署模式的节点的规格相同，仅根据部署模式的不同，采用不同的节点计量方法。 说明 分布式版：以默认配置3分片，3副本，3个协调节点（CN，Coordinator Node）为例，1个分片，3副本有3个数据节点（DN，Data Node），则3个分片共有9个DN，则收费节点的数量为 CN + DN 3 + 9 12。 集中式版：以默认1主2备为例，无协调节点CN，即共计3个DN，则收费节点的数量为 3 。 节点的规格配置及定价如下表。 （1）X86独享型1:8 实例规格 按需(元/小时) 包周期(元/月) 8 vCPUs / 64 GB 20.83 10,000 16 vCPUs/ 128 GB 41.67 20,000 32 vCPUs/ 256 GB 83.33 40,000 64 vCPUs / 512 GB 166.67 80,000

本页介绍天翼云TeleDB数据库告警模板相关操作。 操作步骤 1. 以用户名和密码登录TeleDBDCP数据库管理平台，在左侧导航树单击告警中心 > 告警模版 ，进入告警模版页面。 2. 创建告警模版。 1. 在告警模版页面，单击 新建模版 ，弹出新建模版对话框。 2. 在新建模版对话框，根据以下内容填写基本信息 和 告警规则 。 告警对象选择 实例TELEDBX 。 阈值告警包括：节点连接数、节点CPU占用率、节点内存占用大小、节点磁盘占用量、节点wal日志占用空间、节点QPS、主备xlog同步差异、节点剩余xid数量、集群总请求数、集群读请求数、集群写请求数、集群其他请求数、集群总连接数。 事件告警包括：实例状态、全局事务管理器状态、协调节点状态、数据节点状态。 3. 单击确定完成新建模版。 3. 告警模版管理 1. 单击已创建的告警模版所在行的操作列的编辑可修改告警模版。 2. 单击已创建的告警模版所在行的操作列的删除可删除告警模版。 3. 也可勾选多条告警模版，单击 批量删除 ，同时删除多条告警模版。

本节主要介绍GeminiDB Influx接口的计费概述。 通过阅读本文，您可以快速了解GeminiDB Influx的计费模式、计费项、续费、欠费等主要计费信息。 计费模式 GeminiDB Influx提供包年/包月和按需计费两种计费模式，以满足不同场景下的用户需求。 包年/包月是一种预付费模式，即先付费再使用，按照订单的购买周期进行结算，因此在购买之前，您必须确保账户余额充足。 按需计费是一种后付费模式，即先使用再付费，按照数据库实例实际使用时长计费。 关于两种计费模式的详细介绍请参见计费模式概述。 在购买云数据库后，如果发现当前计费模式无法满足业务需求，您还可以变更计费模式。详细介绍请参见变更计费模式概述。 计费项 GeminiDB Influx的计费项由实例规格费用、存储空间费用、备份空间费用、冷存储空间费用和公网带宽费用组成。了解每种计费项的计费因子、计费公式等信息，请参考计费项。 如需了解实际场景下的计费样例以及各计费项在不同计费模式下的费用计算过程，请参计费样例。 续费 包年/包月数据库实例在到期后会影响数据库实例的正常运行。如果您想继续使用数据库实例，需要在规定的时间内为数据库实例进行续费，否则计算、存储等资源将会自动释放，数据也可能会丢失。 续费包括手动续费和自动续费两种方式，您可以根据需求选择。了解更多关于续费的信息，请参见续费概述。

敏感数据识别任务扫描完成后，可通过DSC服务的“识别结果”页面，查看数据资产的风险分布、风险等级以及敏感数据存在的位置。 前提条件 已至少执行过一次敏感数据识别任务。 操作步骤 1. 单击左上角的，选择区域或项目。 2. 在左侧导航树中，单击，选择“安全>数据安全中心”，进入数据安全中心总览界面。 3. 选择左侧导航树中的“敏感数据识别 > 识别结果”，进入识别结果页面。 数据安全中心DSC统计了高风险、中风险和低风险对象的数量及分布图，分别包括大数据、数据库、OBS三个服务。 数据安全中心DSC针对扫描对象提供了详细的识别结果列表，同时，您可以在检测结果列表右上角筛选您想要查看的敏感数据识别结果，可通过风险等级、任务名称、数据类型或者对象名称进行筛选，识别结果列表参数说明如下表所示。 参数名称 参数说明 资产名称 敏感数据识别的对象名称。 数据类型 OBS、数据库、大数据 、MRS。 所属任务 任务名称，检测结果对象隶属的敏感数据检测任务名称。 未知风险信息 根据您设置的识别规则，经检测，未发现风险的资产数量。 低风险敏感信息 根据您设置的识别规则，经检测，统计的低风险（风险等级：1~3级）的资产数量。 中风险敏感信息 根据您设置的识别规则，经检测，统计的中风险（风险等级：4~7级）的资产数量。 高风险敏感信息 根据您设置的识别规则，经检测，统计的高风险（风险等级：8~10级）的资产数量。 上次识别时间 最近扫描该对象的时间。 操作 单击“查看详情”，查看该对象的识别结果明细。 4. 单击扫描对象所在行的“操作”列的“查看详情”，然后进入“结果明细”页面。 在页面的左上角的下拉框中选择任务名称、数据类型或者对象名称，可以通过筛选来查看具体扫描对象的识别结果。 单击页面的右上角的“下载识别结果”，下载风险结果报表。 敏感信息分布 可查看敏感信息的风险分布情况、对应风险等级资产的数量及其占比、Top10命中规则。 血缘图 可查看资产中敏感数据的具体名称、路径、风险等级。

本节主要介绍通过数据库复制服务管理控制台创建备份迁移任务的配置流程。 介绍RDS全量备份场景下的备份迁移。您可以通过本云上Microsoft SQL Server数据库实例的全量备份，对已有的Microsoft SQL Server实例进行备份数据迁移。 前提条件 已登录数据库复制服务控制台。 账户余额大于等于100元。 满足备份移支持的数据库类型，参见备份迁移。 满足备份迁移的限制条件，参见使用须知。 操作步骤 1、在“备份迁移管理”页面，单击“创建迁移任务”。 2、在“选定备份”页面输入任务名称和描述，填选备份文件信息，单击“下一步” 图 任务信息 表 任务信息 参数 描述 任务名称 任务名称在450位之间，必须以字母开头，不区分大小写，可以包含字母、数字、中划线或下划线，不能包含其他特殊字符。 描述 描述不能超过256位，且不能包含! & ' " 特殊字符。 图 备份文件信息 表 备份文件信息 参数 描述 数据库类型 选择Microsoft SQL Server数据库引擎。 备份文件来源 选择RDS全量备份。说明：请选择状态为“备份完成”的RDS备份文件。 3、 在“选定目标”页面，填选数据库信息，单击“下一步”。 图 数据库信息 表 数据库信息 参数 描述 目标RDS实例名称 选择目标RDS实例。若没有合适的目标数据库实例，请先创建目标数据库实例。 待还原数据库名称 选中目标RDS实例后，自动展示该实例的所有待还原数据库，可根据需要选择待还原的数据库，并且支持重命名。 待还原数据库名称：待还原数据库的原名称。 数据库新名称：区分大小写，长度在1~64个字符之间，可以包含字母，数字、中划线和下划线，不能包含其他特殊字符。不设置，则使用原数据库名称备份恢复，设置后，使用新名称备份恢复。 说明 待还原数据库支持重命名，最大配额为100个。 4、在“信息确认”页面核对配置详情后，勾选协议，单击“下一步”。 5、在“备份迁移管理”页面任务列表中，观察对应的恢复任务的状态为“恢复中”，恢复成功后，任务状态显示“成功”。

支持绑定负载均衡 支持非负载均衡场景和负载均衡场景下的弹性伸缩服务。 支持健康检查 天翼云弹性伸缩服务提供健康检查功能，保证使用健康云主机负载业务。 支持云主机健康检查和负载均衡健康检查两种检查方式，自动替换不健康实例。 支持查看伸缩数据 用户可按照图形或表格的方式查看伸缩组的云主机实例数量变化情况，并能看到伸缩组内所有云主机实例的资源利用情况平均值变化曲线。

相关操作 导出域名组：单击列表上方的“导出”，选择需要的数据范围。 批量删除域名：在“域名组”界面，批量勾选域名后，单击列表上方的“删除”。 编辑域名组：单击目标所在行的名称，修改参数。 域名组在防护规则里设置后才会生效，添加防护规则请参见“通过添加防护规则拦截/放行流量”。 查看网络域名组类型解析出的IP地址：单击目标所在行的名称，进入“基本信息”页，单击域名列表中的“操作”列的“IP地址”。

获取备份配置列表 getBackupConfigList 查询RDS实例备份设置 getBackupConfig 获取备份任务列表 getBackupList 删除数据备份文件 deleteBackupFile 创建备份集 createManualBackup 修改备份设置 updateBackupConfig 获取备份任务信息 getBackup 终止备份集 cancelBackup 获取对象存储下载链接 getZosObjDownloadLink 创建恢复任务 createNewRecoveryJob 获取可恢复时间点 getRecoverableTimeRange 获取实例所有非系统schema和对应table的集合 getSchemaTablesByProdId 获取恢复记录 getBrRecoveryRecordList 获取实例所有非系统schema getSchemaByProdId 获取可恢复的实例 getListToBeRecovery 获取恢复预检查详情 getBrRecoveryRecordDetail

云专线的路由模式是否支持修改？ 支持。 修改云专线路由模式需要联系您的客户经理或提交工单进行申请。 需要注意，修改路由模式需要先删除VPC子网，再重新建立路由，在此期间，您的业务会发生中断，建议您创建专线网关时根据实际业务需求谨慎配置路由模式。 一条物理专线与多个VPC互连时，这些VPC网络在此线路上是否相互隔离？ 通过在物理专线上划分VLAN子接口，可以实现网络数据互相隔离。具体操作，请参见创建专线网关。 物理专线支持NAT吗？ 目前物理专线暂不支持配置NAT，如果因特殊场景必须使用NAT，需要您在本地数据中心配置NAT。 物理专线接入的过程是什么？ 物理专线接入的过程请联系客户经理。如果没有专属客户经理可拨打天翼云客服电话（4008109889）进行咨询。 如何测试线路是否接好？ 当完成物理专线接入施工后，由工程师和您进行配合操作，检测线路接入情况。 物理专线施工后，本地数据中心无法访问云上资源，如何解决？ 请您通过提工单方式，由专业的工程师进行故障排查。 本地数据中心到天翼云的线路中断，如何解决？ 请在本地数据中心的网关设备上测试物理专线的客户端侧IP到天翼云侧IP是否可达，即此物理专线的直连IP是否可以ping通。如果不通，则需您向客户经理报告故障。

触发器管理 1. 在“对象列表”下选择“触发器”页签。单击“新建触发器”，输入触发器名称、触发表、触发时机、和触发事件、触发器语句等信息。 2. 确认无误后，单击“立即创建”并在“请确认触发器定义脚本”窗口再次确认，有误请单击“返回修改”，无误请单击“执行脚本”即可创建成功。 函数管理 1. 在“对象列表”下选择“函数”页签。单击“新建函数”，输入函数名称、返回值类型和描述等信息。 2. 确认无误后，单击“确定”。页面跳转到创建函数的SQL预览页面。 3. 在SQL预览页面中单击“选项”，对存储过程的SQL Security、确定性、数据访问等进行配置。 4. 确认无误后，单击“保存”。若您需要修改，请在SQL窗口修改SQL语句，若您确认无误，请单击“执行”即可创建成功。

本节介绍了云容器引擎的最佳实践:使用存储子目录为工作负载提供存储。 当需要将存储的特定子目录直接挂载至工作负载以实现高效数据存储时，云容器引擎提供了多种实现方式以支持该能力。 需求场景 当用户创建大容量文件存储时，为充分利用现有资源，可将不同子目录分配给多个工作负载使用。 若需实现数据层面的权限控制，可限制容器仅访问指定子目录。 对于习惯开源NFS使用方式的用户，可在已有文件存储基础上，通过为不同子目录创建独立的PVC并分配给对应工作负载，实现资源隔离。 每个工作负载拥有不同的子目录的方式便于管理，且可通过Pod名称区分子目录，提升运维效率。 方案选择 有以下两种方案： （1）复用现有存储：用户已有的存储对应一个PVC，无需额外创建PVC，可将同一PVC下的不同子目录分配给多个工作负载使用。 （2）动态分配子目录：用户使用海量文件存储时，每次可为不同工作负载动态分配一个子目录作为独立PVC。（注：此功能仅海量文件存储支持，其他存储产品不适用于子目录挂载场景。） 方案一：子目录挂载（多个子目录共享同一PVC） 在工作负载的数据存储配置界面，设置挂载路径为 /test，即存储卷将挂载至容器内的 /test 目录。子路径可选择 subPath 或 subPathExpr 模式。 subPath：简单直接，工作负载的所有副本均使用存储卷的同一子目录。 subPathExpr：支持通过环境变量动态调整子目录路径，实现同一工作负载中不同副本使用独立子目录。 若选择 subPath，直接填写子目录名称即可；若目录不存在，K8S会自动创建。若选择 subPathExpr，需按以下方式配置： 在第二个绿色箭头所指的框中，根据实际需求填写路径表达式。例如可使用 $(PODNAMESPACE)/$(PODNAME) 或 $(PODNAME)，也支持自定义格式。此处以 $(PODNAMESPACE)/$(PODNAME) 为例，需确保相关变量已在环境变量中预先定义。 根据以上示例，红框处需正确填写变量名，绿框处需选择变量值的来源。即从Pod的metadata.name字段获取PODNAME变量值，从metadata.namespace字段获取PODNAMESPACE变量值，并组合为存储的子目录路径。 例如：一个两副本的无状态工作负载位于命名空间cstor下，Pod名称分别为podA和podB。按此配置后，一个副本会将PVC对应存储下的cstor/podA子目录挂载至容器内的/test路径，另一副本则挂载cstor/podB子目录至相同路径。 若通过工作负载的YAML文件实现，相关字段配置如下： plaintext volumeMounts: name: workdir1 mountPath: /logs subPathExpr: $(PODNAMESPACE)/$(PODNAME) yaml的env的设置如下： plaintext spec: containers: name: container1 env: name: PODNAME valueFrom: fieldRef: apiVersion: v1 fieldPath: metadata.name name: PODNAMESPACE valueFrom: fieldRef: apiVersion: v1 fieldPath: metadata.namespace

本节主要介绍初始化的错误码。 HTTP status 错误码 错误信息 描述 400 BadUserName Value 'value ' at 'argument' failed to satisfy constraint: Argument can only contain letters and digits, and has length between 5 and 16. 用户名不合法。取值：字符串形式，长度范围是5~16，只能由数字和字母组成，字母区分大小。 400 CanNotConnectToIP Can not connect to the IP IP. 无法连接指定的IP。 400 CanNotConnectToServer Can not connect to the server IP[:port]. 无法连接指定的服务器。 400 ClusterNetworkDoesNotMatch All IPs on the server serverIP do not match the 'cluster network' clusterNetwork. 服务器的IP和cluster network不匹配。 400 DuplicateIP The IP IP of 'argument' is duplicated. 服务的IP地址重复。 400 InconsistentIPformat The server IPs in the cluster should be unified as IPv4 or IPv6 format when cluster network is not specified. 如果不指定集群网络，集群内服务器IP应统一为IPv4或IPv6格式。 400 InsufficientPath The base storage pool must have at least one disk path. 基础存储池至少要有一个数据目录。 400 InsufficientPorts Insufficient available ports for server server . Expand the port range to support N additional ports. 服务器X端口范围中可用端口数量不足，请调整范围使之至少增加N个端口。 400 InvalidCIDR Value CIDR at 'networkType network' failed to satisfy constraint: Argument does not match the IP of the 'localhost'/'127.0.0.1'/'0:0:0:0:0:0:0:1' server. 当server ip包含localhost、127.0.0.1或0:0:0:0:0:0:0:1时，用户指定的'cluster/public network和服务器IP不匹配。 400 InvalidClusterNetwork Value clusterNetwork at 'cluster network' failed to satisfy constraint: Argument must satisfy CIDR specifications. 集群网格式错误。 400 InvalidDiskPath The disk paths do not exist: serverIP :diskPaths [,diskPaths ...][; serverIP :diskPaths [,diskPaths...]]. The available disk space must be greater than or equal to 1 GiB for each disk path: serverIP :diskPaths [,diskPaths ...][; serverIP :diskPaths [,diskPaths...]]. The disk paths can not access: serverIP :diskPaths [,diskPaths ...][; serverIP :diskPaths [,diskPaths...]]. The disk paths must be directory: serverIP :diskPaths [,diskPaths ...][; serverIP :diskPaths [,diskPaths...]]. The disk paths include incompatible data: serverIP :diskPaths [,diskPaths ...] [; serverIP :diskPaths [,diskPaths...]]. The disk paths include unsupported symbols: serverIP :diskPaths [,diskPaths ...] [; serverIP :diskPaths [,diskPaths...]]. 初始化过程中，因数据目录有问题而导致的失败。 400 InvalidDiskPathCapacityQuota The capacity quota for the following disk paths failed to satisfy constraint. It must be integer and not greater than the total capacity of disk path. serverIP:diskPaths [,diskPaths...] [;serverIP:diskPaths[,diskPaths...]..]. 容量配额参数错误。 400 InvalidEnumValue Value value at 'argument ' failed to satisfy constraint: Argument must satisfy enum value set: [value1, value2... ]. 枚举参数不合法。 400 InvalidIP Value IP at 'argument' failed to satisfy constraint: Argument must satisfy IPv4 or IPv6 specifications. IP格式错误。 400 InvalidLong Value value at 'argument' failed to satisfy constraint: Argument must be of type long. 参数填写错误，必须为长整型。 400 InvalidMetaDir The meta directory serverIP :metaDir is invalid. reason 服务数据目录无效，请修改后重试。 400 InvalidNewPassword Value 'value' at 'new password' failed to satisfy constraint: Argument must have length between 8 and 16, and must contain 3 of the following: uppercase letters, lowercase letters, digits, special symbols (~ ! @

消费消息 import org.apache.kafka.clients.CommonClientConfigs; import org.apache.kafka.clients.consumer.ConsumerConfig; import org.apache.kafka.clients.consumer.ConsumerRecord; import org.apache.kafka.clients.consumer.ConsumerRecords; import org.apache.kafka.clients.consumer.KafkaConsumer; import org.apache.kafka.clients.producer.ProducerConfig; import org.apache.kafka.common.config.SslConfigs; import java.util.ArrayList; import java.util.List; import java.util.Properties; public class KafkaConsumerDemo { public static void main(String args[]) { //加载kafka.properties Properties kafkaProperties JavaKafkaConfigurer.getKafkaProperties(); Properties props new Properties(); //设置接入点，请通过控制台获取对应Topic的接入点 props.put(ProducerConfig.BOOTSTRAPSERVERSCONFIG, kafkaProperties.getProperty("bootstrap.servers")); //设置SSL根证书的路径，请记得将XXX修改为自己的路径 props.put(SslConfigs.SSLTRUSTSTORELOCATIONCONFIG, kafkaProperties.getProperty("ssl.truststore.location")); //根证书store的密码，保持不变 props.put(SslConfigs.SSLTRUSTSTOREPASSWORDCONFIG, "c24f5210"); //接入协议，目前支持使用SSL协议接入 props.put(CommonClientConfigs.SECURITYPROTOCOLCONFIG, "SSL"); //两次poll之间的最大允许间隔 //可更加实际拉去数据和客户的版本等设置此值，默认30s props.put(ConsumerConfig.SESSIONTIMEOUTMSCONFIG, 30000); //设置单次拉取的量，走公网访问时，该参数会有较大影响 props.put(ConsumerConfig.MAXPARTITIONFETCHBYTESCONFIG, 32000); props.put(ConsumerConfig.FETCHMAXBYTESCONFIG, 32000); //每次poll的最大数量 //注意该值不要改得太大，如果poll太多数据，而不能在下次poll之前消费完，则会触发一次负载均衡，产生卡顿 props.put(ConsumerConfig.MAXPOLLRECORDSCONFIG, 30); //消息的反序列化方式 props.put(ConsumerConfig.KEYDESERIALIZERCLASSCONFIG, "org.apache.kafka.common.serialization.StringDeserializer"); props.put(ConsumerConfig.VALUEDESERIALIZERCLASSCONFIG, "org.apache.kafka.common.serialization.StringDeserializer"); //当前消费实例所属的消费组，请在控制台申请之后填写 //属于同一个组的消费实例，会负载消费消息 props.put(ConsumerConfig.GROUPIDCONFIG, kafkaProperties.getProperty("group.id")); //hostname校验改成空 props.put(SslConfigs.SSLENDPOINTIDENTIFICATIONALGORITHMCONFIG, ""); //构造消息对象，也即生成一个消费实例 KafkaConsumer consumer new org.apache.kafka.clients.consumer.KafkaConsumer (props); //设置消费组订阅的Topic，可以订阅多个 //如果GROUPIDCONFIG是一样，则订阅的Topic也建议设置成一样 List subscribedTopics new ArrayList (); //如果需要订阅多个Topic，则在这里add进去即可 //每个Topic需要先在控制台进行创建 subscribedTopics.add(kafkaProperties.getProperty("topic")); consumer.subscribe(subscribedTopics); //循环消费消息 while (true){ try { ConsumerRecords records consumer.poll(1000); //必须在下次poll之前消费完这些数据, 且总耗时不得超过SESSIONTIMEOUTMSCONFIG //建议开一个单独的线程池来消费消息，然后异步返回结果 for (ConsumerRecord record : records) { System.out.println(String.format("Consume partition:%d offset:%d", record.partition(), record.offset())); } } catch (Exception e) { try { Thread.sleep(1000); } catch (Throwable ignore) { } e.printStackTrace(); } } } }

说明：本章节会介绍如何设置安全组规则 操作场景 安全组是一个逻辑上的分组，为同一个虚拟私有云内具有相同安全保护需求，并相互信任的弹性云服务器和关系型数据库实例提供访问策略。 为了保障数据库的安全性和稳定性，在使用关系型数据库实例之前，您需要设置安全组，开通需访问数据库的IP地址和端口。 通过弹性公网IP连接RDS实例时，需要为RDS所在安全组配置相应的入方向规则。 注意事项 因为安全组的默认规则是在出方向上的数据报文全部放行，同一个安全组内的弹性云服务器和关系型数据库实例可互相访问。安全组创建后，您可以在安全组中定义各种访问规则，当关系型数据库实例加入该安全组后，即受到这些访问规则的保护。 默认情况下，一个租户可以创建500条安全组规则。 为一个安全组设置过多的安全组规则会增加首包延时，因此，建议一个安全组内的安全组规则不超过50条。 当需要从安全组外访问安全组内的关系型数据库实例时，需要为安全组添加相应的入方向规则。 源地址默认的IP地址0.0.0.0/0是指允许所有IP地址访问安全组内的关系型数据库实例。 操作步骤 步骤 1 登录管理控制台。 步骤 2 在系统首页，单击“网络 > 虚拟私有云”。 步骤 3 在左侧导航树选择“访问控制 > 安全组”。 步骤 4 在安全组界面，单击操作列的“配置规则”，进入安全组详情界面。 步骤 5 在安全组详情界面，单击“添加规则”，弹出添加规则窗口。 步骤 6 根据界面提示配置安全组规则。 步骤 7 单击“确定”。

本章节会介绍如何删除按需实例。 操作场景 对于“按需计费”模式的主实例或只读实例，您可根据业务需要，在关系型数据库“实例管理”页面手动删除来释放资源。 使用限制 删除实例有如下约束： 执行操作中的实例不能手动删除，只有在实例操作完成后，才可删除实例。 “按需计费”类型的实例删除后将不再产生费用，自动备份会被同步删除，保留的手动备份会继续收取费用。 删除主实例时，会同步删除其对应的只读实例，请您谨慎操作。 实例删除后，不可恢复，请谨慎操作。如需保留数据，请务必确认完成数据备份后再删除实例。 删除按需主实例 步骤 1 登录管理控制台。 步骤 2 单击管理控制台左上角的，选择区域和项目。 步骤 3 选择“数据库 > 关系型数据库”。进入关系型数据库信息页面。 步骤 4 在“实例管理”页面的实例列表中，选择需要删除的主实例，在“操作”列，选择“更多 > 删除实例”。 步骤 5 在“删除实例”弹框，单击“是”下发请求。 步骤 6 稍后刷新“实例管理”页面，查看删除结果。 删除按需只读实例 步骤 1 登录管理控制台。 步骤 2 单击管理控制台左上角的，选择区域和项目。 步骤 3 选择“数据库 > 关系型数据库”。进入关系型数据库信息页面。 步骤 4 在“实例管理”页面的实例列表中，选择对应主实例，单击实例名称前的，可查看到该主实例下的全部只读实例。 步骤 5 选择目标只读实例，在“操作”列，选择“更多 > 删除实例”。 步骤 6 在“删除实例”弹框，单击“是”下发请求。 步骤 7 稍后刷新“实例管理”页面，查看删除结果。

RocketMQ无法避免消息重复，原因主要有以下几点： 签收的偏移量是定时（每5秒/次）同步到服务端的。 为保证消息不丢失，SDK每次提交的总是队列未签收的最小偏移量（比如无序消费，offset为1、2、3、4、5 的消息，1、3、4、5消费并已签收，2未签收，签收时最后提交的偏移量将会是2，如果此时客户端重启，会从2这个位置开始消费）。 有网络交互就不能确保每一次的交互数据都是送达的，为保证数据不丢失就要进行重试，有重试就存在重复的可能。 如果业务对消费重复非常敏感，务必要注意，建议可以采用以下两种方式处理： 业务层面可以根据msgId做去重处理，如果key字段为业务唯一字段，也可采用key去重。 业务逻辑实现消费幂等，即多次处理同一消息，对业务的影响是幂等的。

您需要在部署天翼云TeleDB数据库之前，检查相关的机器、安装包、操作系统、端口等信息。 确保您的安装包与操作系统版本匹配。 检查机器之间是否存在通信问题或者拦截问题，确保主机之间网络互通。 确保已获取主机超级用户。 确保所有主机不能拥有teledbx用户，当安装或者开通实例会自动创建，无需手动创建。 若为高可用则需要配置vip，每组cn一个。 检查部署机器是否有空闲数据盘提供使用，已经挂载好磁盘不需要重新挂载。 安装之前请确保所有需要使用的服务端口未被占用。 安装的系统预先装好jdk 环境，建议 1.8.0201 版本及以上。 检查主机是否自带libaio0.3.10913.el7.x8664.rpm lz41.7.53.el7.x8664.rpmpv1.4.61.el7.x8664.rpm sshpass1.062.el7.x8664.rpm 依赖 perl 依赖。

您需要在部署天翼云TeleDB数据库之前，检查相关的机器、安装包、操作系统、端口等信息。 确保您的安装包与操作系统版本匹配。 检查机器之间是否存在通信问题或者拦截问题，确保主机之间网络互通。 确保已获取主机超级用户。 确保所有主机不能拥有teledbx用户，当安装或者开通实例会自动创建，无需手动创建。 若为高可用则需要配置vip，每组cn一个。 检查部署机器是否有空闲数据盘提供使用，已经挂载好磁盘不需要重新挂载。 安装之前请确保所有需要使用的服务端口未被占用。 安装的系统预先装好jdk 环境，建议 1.8.0201 版本及以上。 检查主机是否自带libaio0.3.10913.el7.x8664.rpm lz41.7.53.el7.x8664.rpmpv1.4.61.el7.x8664.rpm sshpass1.062.el7.x8664.rpm 依赖 perl 依赖。

您需要在部署天翼云TeleDB数据库之前，检查相关的机器、安装包、操作系统、端口等信息。 确保您的安装包与操作系统版本匹配。 检查机器之间是否存在通信问题或者拦截问题，确保主机之间网络互通。 确保已获取主机超级用户。 确保所有主机不能拥有teledbx用户，当安装或者开通实例会自动创建，无需手动创建。 若为高可用则需要配置vip，每组cn一个。 检查部署机器是否有空闲数据盘提供使用，已经挂载好磁盘不需要重新挂载。 安装之前请确保所有需要使用的服务端口未被占用。 安装的系统预先装好jdk 环境，建议 1.8.0201 版本及以上。 检查主机是否自带libaio0.3.10913.el7.x8664.rpm lz41.7.53.el7.x8664.rpmpv1.4.61.el7.x8664.rpm sshpass1.062.el7.x8664.rpm 依赖 perl 依赖。

本章介绍文件备份操作流程。 文件备份操作流程如下图所示： 1. 创建混合云备份存储库：创建用于存放文件备份的存储库。在安装文件备份客户端前需要先完成存储库的创建。 2. 下载并安装客户端：进行文件备份前需要先在目标服务器上下载和安装客户端，安装完成后，云服务备份系统会自动发现已安装客户端的主机，显示在文件备份客户端列表中。 3. 配置存储库：将目标客户端配置至对应的备份存储库，文件目录产生的备份将存放在存储库中。 4. 新增备份文件：添加目标客户端中需要备份的文件目录路径。 5. 创建文件备份：可为资源创建手动备份和自动备份，备份将存放在存储库中。 6. 使用文件备份恢复数据：可以使用云上备份将数据恢复至原服务器或新服务器均可。

服务名称 重启时长 启动时长 附加说明 ClickHouse 4min ClickHouseServer：2min ClickHouseBalancer：2min HDFS 10min+x NameNode：4min+x DataNode：2min JournalNode：2min Zkfc：2min x为NameNode元数据加载时长，每千万文件大约耗时2分钟，例如5000万文件x为10min。由于受DataNode数据块上报影响启动时间有一定浮动。 Yarn 5min+x ResourceManager：3min+x NodeManager：2min x为ResourceManager保留任务数恢复时长，每1万保留任务大约需要1分钟 Mapreduce 2min+x JobHistoryServer：2min+x x为历史任务扫描时长，每10万任务大约2.5min ZooKeeper 2min+x quorumpeer：2min+x x为加载znode节点时长，每100万znode大约1min Hive 3.5min HiveServer：3min MetaStore：1min30s WebHcat：1min Hive整体服务：3min Spark2x 5min JobHistory2x：5min SparkResource2x：5min JDBCServer2x：5min Flink 4min FlinkResource：1min FlinkServer：3min Kafka 2min+x Broker：1min+x x为数据恢复时长，单实例20000 partition启动所需时长大约2mins。 Storm 6min Nimbus：3mins UI：1min Supervisor：1min Logviewer：1min Flume 3min Flume：2 min MonitorServer：1min

本文介绍了API业务监测的相关功能。 功能介绍 API业务监测功能帮助用户实时查看API的业务运行数据包括QPS趋势图、源站状态码响应趋势图、天翼云节点状态码响应趋势图、响应时长趋势图、QPS峰值排行、响应时长排行，同时帮助用户发现和分析业务异常。 前提条件 已经订购边缘安全加速平台安全与加速服务，若未订购，请参见服务开通。 在控制台新增域名，请参见添加服务域名。 操作步骤 1. 登录边缘安全加速平台控制台。 2. 在左侧导航栏中选择【安全能力】，进入【API安全】菜单，并在左侧域名列表选择您要管理的域名。 3. 您可以在资产列表中选择具体一项API资产，在操作栏中点击【业务监测】跳转查看单一API粒度的业务监测数据；也可以在API资产表头右侧点击【业务监测】查看域名粒度业务监测数据。

本页介绍天翼云TeleDB数据库的开发相关规范。 1. 建议对表、视图、列添加备注，可以通过阅读备注信息，快速了解相关对象定义，了解相关业务关联逻辑。 2. 在对象命名时，取名应与该对象表达的意义相匹配，做到见名知义。 3. 建议update更新时尽量增加 <> 判断条件，例如update tablea set columnb c ；可以更改为update tablea set columnb c where columnb <> c；更新列时，已经是更新后值的记录不会再去更新，不会新增1个版本记录，可以减少vacuum回收工作量。 4. 建议不要使用大事务，大事务会锁更多的资源，锁的时间会更长，应将大事务按业务需要拆分成多个小事务，拆分成小事务后可以有效降低锁冲突概率。 5. 建议大批量数据入库时，使用copy代替insert、upsert，可以显著提高效率。 6. 不使用外键，外键会让数据库逻辑变的更复杂，还有一些使用限制，应通过业务逻辑代替外键。 7. 不使用触发器，触发器严重影响性能，应通过业务逻辑代替触发器。

本页介绍天翼云TeleDB数据库如何设置告警模版。 操作步骤 1. 以用户名和密码登录TeleDBDCP数据库管理平台，在左侧导航树单击告警中心 > 告警模版 ，进入告警模版页面。 2. 创建告警模版。 1. 在告警模版页面，单击新建模版 ，弹出新建模版对话框。 2. 在新建模版对话框，根据以下内容填写基本信息 和告警规则。 告警对象选择实例TELEDBX。 阈值告警包括：节点连接数、节点CPU占用率、节点内存占用大小、节点磁盘占用量、节点wal日志占用空间、节点QPS、主备xlog同步差异、节点剩余xid数量、集群总请求数、集群读请求数、集群写请求数、集群其他请求数、集群总连接数。 事件告警包括：实例状态、全局事务管理器状态、协调节点状态、数据节点状态。 3. 单击确定 完成新建模版。 3. 告警模版管理 1. 单击已创建的告警模版所在行的操作列的编辑 可修改告警模版。 2. 单击已创建的告警模版所在行的操作列的删除 可删除告警模版。 3. 也可勾选多条告警模版，单击批量删除 ，同时删除多条告警模版。