华为云用户手册

应用场景 本文介绍如何使用 MRS 集群运行Spark Streaming作业以消费Kafka数据。 假定某个业务Kafka每1秒就会收到1个单词记录。基于业务需要，开发的Spark应用程序实现实时累加计算每个单词的记录总数的功能。 Spark Streaming样例工程的数据存储在Kafka组件中，向Kafka组件发送数据。 MRS服务提供了Spark服务多种场景下的样例开发工程，本章节对应示例场景的开发思路： 接收Kafka中数据，生成相应DStream。 对单词记录进行分类统计。 计算结果，并进行打印。

方案架构 生产者（Producer）将消息发布到Kafka主题（Topic）上，消费者（Consumer）订阅这些主题并消费这些消息。 在Kafka集群上一个服务器称为一个Broker。对于每一个主题，Kafka集群保留一个用于缩放、并行化和容错性的分区（Partition）。每个分区是一个有序、不可变的消息序列，并不断追加到提交日志文件。分区的消息每个也被赋值一个称为偏移顺序（Offset）的序列化编号。 图1 Kafka结构

应用场景 Kafka是一个分布式的消息发布-订阅系统。它采用独特的设计提供了类似JMS的特性，主要用于处理活跃的流式数据。 Kafka有很多适用的场景：消息队列、行为跟踪、运维数据监控、日志收集、流处理、事件溯源、持久化日志等。 Kafka有如下几个特点： 高吞吐量 消息持久化到磁盘 分布式系统易扩展 容错性好 MRS服务提供了Kafka多种场景下的样例开发工程，本章节以最常见的WordCount样例Demo进行说明，对应示例场景的开发思路： 使用Kafka客户端创建两个Topic，用于输入Topic和输出Topic。 开发一个Kafka Streams完成单词统计功能，通过读取输入Topic中的消息，统计每条消息中的单词个数，从输出Topic消费数据，将统计结果以Key-Value的形式输出。

步骤1：创建MRS集群 创建并购买一个包含有Kafka组件的MRS集群，详情请参见购买自定义集群。 本文以购买的MRS 3.1.0版本的集群为例，组件包含Hadoop、Kafka组件，集群未开启Kerberos认证。 集群购买成功后，在MRS集群的任一节点内，安装集群客户端，具体操作可参考安装并使用集群客户端。 例如客户端安装在主管理节点中，安装目录为“/opt/client”。 客户端安装完成后，在客户端内创建“lib”目录，用于放置相关jar包。 将安装客户端过程中解压的目录中Kafka相关jar包复制到“lib”目录。 例如客户端软件包的下载路径为主管理节点的“/tmp/ FusionInsight -Client”目录，执行以下命令： mkdir /opt/client/lib cd /tmp/FusionInsight-Client/FusionInsight_Cluster_1_Services_ClientConfig scp Kafka/install_files/kafka/libs/* /opt/client/lib

检查CNAME是否生效 视频直播 服务默认开启直播上行加速服务，即推流加速。若您的推流 域名 未配置CNAME解析，则会由于无法解析推流域名，从而导致推流失败。请您参照如下步骤，验证推流域名的CNAME是否配置成功。 登录视频直播控制台。 在左侧导航树中，选择“域名管理”。 在域名列表中，获取推流域名的CNAME。 图2 域名管理 打开Windows操作系统中的cmd程序，通过nslookup加速域名的方式进行查询。 若回显的是系统分配的CNAME域名，则表示已配置CNAME。否则您需要参考CNAME配置完成配置。

检查推流地址是否正确 您需要根据是否配置了Key防盗链的情况来拼接对应的原始推流地址或鉴权推流地址。若开启了Key防盗链加密鉴权，则需要使用鉴权后的推流地址，否则，请使用原始推流地址进行推流。 请您对照推流地址拼接规则，确认当前的推流地址是否正确，若不正确，请使用正确的地址进行推流。 原始推流地址拼接规则如下： rtmp://推流域名/AppName/StreamName 请您按照实际使用的“AppName”和“StreamName”拼接推流地址。 华为云视频直播服务的推流协议暂只支持RTMP，推流地址必须以rtmp开头。 鉴权推流地址请参见推流鉴权进行拼接。

原因3解决方法 播放域名和推流域名必须在同一Region的直播源站才能关联。如果不在相同Region，关联时会报错“配置参数region校验失败”。 登录视频直播控制台。 在左侧导航树中，选择“域名管理”，如图3所示。 在域名列表中，检查播放域名和推流域名的直播源站是否在同一Region，需同为“华北-北京四”或同为“亚太-新加坡”。 若是，则直播域名关联失败，非本原因导致。 若不是，需重新创建推流域名，且推流域名选择的“直播源站”所在Region必须与播放域名保持一致。 图3 域名管理

原因2解决方法 若推流域名不是“云直播”类型，则关联推流域名时会失败，界面报错“不支持媒体直播域名”。 登录视频直播控制台。 在左侧导航树中，选择“域名管理”，如图2所示。 在域名列表中，检查推流域名的“子服务类型”是否为“云直播”。 若是，则直播域名关联失败，非本原因导致。 若不是，则推流域名的“子服务类型”是“媒体直播”。需重新创建域名，且推流域名的“子服务类型”必须选择“云直播”。 图2 域名管理

检查播放端 在第三方播放器中输入播放地址进行播放，检查播放器是否存在问题，建议可以使用VLC播放器检测。 检查播放设备是否存在问题，建议可以换一个手机和PC进行检测。 检查播放器是否支持对应的格式。 以下为华为云视频直播播放器对直播流格式的支持情况： Web端播放器：支持的格式有M3U8和FLV。 移动端播放器：支持的格式有RTMP、FLV和M3U8。 若检查是播放器不支持导致，建议切换播放器播放。

检查播放地址是否正确 您需要根据是否配置了Key防盗链的情况来拼接对应的原始播放地址和鉴权播放地址。若开启了Key防盗链加密鉴权，则需要使用鉴权后的播放地址，否则，请使用原始播放地址进行播放。 请您对照播放地址拼接规则，确认当前的播放地址是否正确，若不正确，请使用正确的地址进行播放。 原始播放地址支持FLV、M3U8、RTMP三种格式，对应的拼接规则如下所示： RTMP格式：rtmp://播放域名/AppName/StreamName FLV格式：http://播放域名/AppName/StreamName.flv M3U8格式：http://播放域名/AppName/StreamName.m3u8 请您按照实际使用的AppName和StreamName拼接播放地址。 鉴权播放地址请参见播放Key防盗链拼接对应的播放地址。 播放地址中的AppName和StreamName必须与推流地址中的一致。

检查CNAME是否生效 由于视频直播服务默认开启直播下行加速服务，即播放加速，若您未配置CNAME解析，将由于无法解析播放域名，导致播放失败。请您参照如下方法，验证播放CNAME是否配置成功。 登录视频直播控制台。 在左侧导航树中，选择“域名管理”。 在域名列表中，获取播放域名的CNAME。 图2 域名管理 打开Windows操作系统中的cmd程序，通过nslookup加速域名的方式进行查询。 若回显的是系统分配的CNAME域名，则表示已配置CNAME。否则，您需要参考CNAME配置完成配置。

SDK概述 华为云提供了直播服务端SDK，您可以直接集成服务端SDK来调用直播的相关API，从而实现对直播服务的快速操作。目前视频直播提供了Java、Python、Go和PHP四种语言SDK供开发者使用，如表1所示。 SDK已知安全漏洞及修复版本、规避方案，请单击表1中的SDK对应语言的Github地址进行查看。 表1 服务端SDK 语言 Github地址 参考文档 JAVA huaweicloud-sdk-java-v3 Java SDK使用指导 Python huaweicloud-sdk-python-v3 Python SDK使用指导 Go huaweicloud-sdk-go-v3 Go SDK使用指导 PHP huaweicloud-sdk-php-v3 PHP SDK使用指导 支持的直播API如表2所示，后续SDK将会持续升级，支持所有直播API。 表2 SDK与API对应关系 Java SDK Python SDK Go SDK API参考 createDomain create_domain CreateDomain 创建直播域名 deleteDomain delete_domain DeleteDomain 删除直播域名 updateDomain update_domain UpdateDomain 修改直播域名 showDomain show_domain ShowDomain 查询直播域名 createDomainMapping create_domain_mapping CreateDomainMapping 域名映射 deleteDomainMapping delete_domain_mapping DeleteDomainMapping 删除直播域名映射关系 createTranscodingsTemplate create_transcodings_template CreateTranscodingsTemplate 创建直播转码模板 updateTranscodingsTemplate update_transcodings_template UpdateTranscodingsTemplate 修改直播转码模板 deleteTranscodingsTemplate delete_transcodings_template DeleteTranscodingsTemplate 删除直播转码模板 showTranscodingsTemplate show_transcodings_template ShowTranscodingsTemplate 查询直播转码模板 createStreamForbidden create_stream_forbidden CreateStreamForbidden 禁止直播推流 updateStreamForbidden update_stream_forbidden UpdateStreamForbidden 修改禁推属性 deleteStreamForbidden delete_stream_forbidden DeleteStreamForbidden 禁推恢复 listStreamForbidden list_stream_forbidden ListStreamForbidden 查询禁止直播推流列表 showBandwidth show_bandwidth ShowBandwidth 查询直播加速的带宽数据 listLiveSampleLogs list_live_sample_logs ListLiveSampleLogs 获取直播播放日志 createRecordRule create_record_rule CreateRecordRule 创建录制规则 listRecordRules list_record_rules ListRecordRules 查询录制规则列表 updateRecordRule update_record_rule UpdateRecordRule 修改录制规则 deleteRecordRule delete_record_rule DeleteRecordRule 删除录制规则 showRecordRule show_record_rule ShowRecordRule 查询录制规则配置 runRecord run_record RunRecord 提交录制控制命令 createRecordCallbackConfig create_record_callback_config CreateRecordCallbackConfig 创建录制回调配置 listRecordCallbackConfigs list_record_callback_configs ListRecordCallbackConfigs 查询录制回调配置列表 updateRecordCallbackConfig update_record_callback_config UpdateRecordCallbackConfig 修改录制回调配置 showRecordCallbackConfig show_record_callback_config ShowRecordCallbackConfig 查询录制回调配置 deleteRecordCallbackConfig delete_record_callback_config DeleteRecordCallbackConfig 删除录制回调配置 showTraffic show_traffic ShowTraffic 查询直播加速的流量数据 showOnlineUsers show_online_users ShowOnlineUsers 查询直播播放在线人数 listBandwidthDetail list_bandwidth_detail ListBandwidthDetail 查询播放带宽趋势接口 listDomainTrafficDetail list_domain_traffic_detail ListDomainTrafficDetail 查询播放流量趋势接口 listDomainBandwidthPeak list_domain_bandwidth_peak ListDomainBandwidthPeak 查询播放带宽峰值接口 listDomainTrafficSummary list_domain_traffic_summary ListDomainTrafficSummary 查询播放流量汇总接口 listUsersOfStream list_users_of_stream ListUsersOfStream 查询观众趋势接口 listQueryHttpCode list_query_http_code ListQueryHttpCode 查询直播拉流HTTP状态码接口 listTranscodeData list_transcode_data ListTranscodeData 查询转码用量接口 listRecordData list_record_data ListRecordData 查询录制用量接口 listSnapshotData list_snapshot_data ListSnapshotData 查询截图用量接口 showUpBandwidth show_up_bandwidth ShowUpBandwidth 查询上行带宽数据接口 showStreamCount show_stream_count ShowStreamCount 查询域名维度推流路数接口 listHistoryStreams list_history_streams ListHistoryStreams 查询历史推流列表接口 showStreamPortrait show_stream_portrait ShowStreamPortrait 查询播放画像信息接口 listSingleStreamFramerate list_single_stream_framerate ListSingleStreamFramerate 查询推流帧率数据接口 listSingleStreamBitrate list_single_stream_bitrate ListSingleStreamBitrate 查询推流码率数据接口 listLiveStreamsOnline list_live_streams_online ListLiveStreamsOnline 查询直播中的流信息

安装SDK 视频直播服务端SDK支持PHP 5.6及以上版本。执行“ php --version”，检查当前PHP的版本信息。 推荐使用Composer安装SDK。 Composer是PHP的依赖管理工具，允许您在项目中声明依赖关系并安装这些依赖。 1 2 3 4 # 安装 Composer curl -sS https://getcomposer.org/installer | php # 安装 PHP SDK composer require huaweicloud/huaweicloud-sdk-php 安装完毕后，您需要引入Composer的自动加载文件。 1 require 'path/to/vendor/autoload.php';

H.265 H.265是ITU-T VCEG继H.264之后所制定的新的视频编码标准。H.265标准围绕着现有的视频编码标准H.264，保留原来的某些技术，同时对一些相关的技术加以改进。新技术使用先进的技术用以改善码流、编码质量、延时和算法复杂度之间的关系，达到最优化设置。H.264由于算法优化，可以低于1Mbps的速度实现标清（分辨率在1280P*720以下）数字图像传送。H.265则可以实现利用1~2Mbps的传输速度传送720P（分辨率1280*720）普通高清音视频传送。

H.264 H.264，是由ITU-T视频编码专家组（VCEG）和ISO/IEC动态图像专家组（MPEG）联合组成的联合视频组（JVT，Joint Video Team）提出的高度压缩数字视频编解码器标准，同时也是MPEG-4第十部分。 H.264标准的主要目标是：与其它现有的视频编码标准相比，在相同的带宽下提供更加优秀的图像质量。它既保留了以往压缩技术的优点和精华又具有其他压缩技术无法比拟的许多优点。

为什么提交代码时会触发执行没有监听代码提交事件的流水线？ 提交代码时触发执行了没有监听代码提交事件的流水线（即没有监听push事件的流水线），可能是以下原因导致： 修改并提交了合并请求的源分支代码，且该合并请求没有关闭。 在流水线上配置了合并请求时触发，且监听了更新事件。 图1 合并请求触发事件 综合上述两个条件，修改未关闭合并请求的源分支代码，且在流水线监听了合并请求的更新事件，提交代码时，会触发该合并请求的更新事件，如果该合并请求的目标分支在流水线监听范围内，则会触发执行相应的流水线。 父主题： 功能使用

配额说明 配额是指您引擎实例中可创建的资源数量限制。如需使用更大配额，请提交工单申请扩大配额。 Nacos引擎实例中可创建的资源数量限制如表1所示。 表1 Nacos引擎资源配额限制 资源 最大配额 是否支持修改配额 注意事项 Nacos单实例命名空间数量 50个 否 - Nacos单个配置文件大小上限 100KB 否 - Nacos单个命名空间配置总计大小 10MB 否 - 带宽（网络流出+流入之和） 2Mbit/s 否 - Nacos单实例配置文件数量上限 10,000个 否 - ServiceComb引擎实例中可创建的资源数量限制如表2所示。 表2 ServiceComb引擎资源配额限制 功能 资源 最大配额 是否支持修改配额 注意事项 微服务管理 微服务版本数量（个） 10,000 暂不支持 - 单个实例数据量（KB） 200 支持 扩大配额后，将增加微服务发现的时延。 单个微服务契约数量（个） 500 暂不支持 - 配置管理 单个配置数据量（KB） 128 暂不支持 - 单个应用级配置数量（个） 2,000 暂不支持 - 微服务治理 应用级的治理策略 1,000 暂不支持 所有的应用的治理策略总和不能超过1000条。 单个治理策略包含：治理规则和业务场景。治理规则和业务场景实际会等量占用配置中心的配额。 微服务版本数：微服务场景中版本用来标记微服务的迭代记录，方便对微服务的不同迭代进行管理。 微服务实例数：实例是一个微服务的最小运行和部署单元，通常对应一个应用进程。同一个微服务通过部署在多个容器或虚机，可以实现多个实例同时运行。 配置条目数：微服务场景中的配置是指对程序代码中某些变量的取值控制。比如，动态配置就是通过在微服务运行过程中对某些变量的取值进行动态变更。

ServiceComb引擎微服务开发框架版本要求 微服务开发框架推荐版本如下表所示。 如果已经使用低版本的微服务开发框架构建应用，建议升级到推荐版本，以获取最稳定和丰富的功能体验。 如果已使用Spring Cloud微服务开发框架开发了应用，推荐使用Spring Cloud Huawei接入应用。 如果基于开源开放和业界生态组件新开发微服务应用，可选择Spring Cloud框架。 如果希望使用ServiceComb引擎提供的开箱即用的治理能力和高性能的RPC框架，可选择Java Chassis框架。 框架 推荐版本 说明 Spring Cloud Huawei 1.10.9-2021.0.x及以上 采用Spring Cloud Huawei项目提供接入支持： 适配的Spring Cloud版本为2021.0.5 适配的Spring Boot版本为2.6.13 Spring Cloud微服务开发框架的版本说明请参见：https://github.com/huaweicloud/spring-cloud-huawei/releases。 Java Chassis 2.7.10及以上 可以直接使用开源项目提供的软件包接入，不需要引用其他第三方软件包。 Java Chassis微服务开发框架的版本说明请参见：https://github.com/apache/servicecomb-java-chassis/releases。 系统升级、改造过程中，三方软件冲突是最常见的问题。随着软件迭代速度越来越快，传统的软件兼容性管理策略已经不适应软件的发展，您可以参考三方软件版本管理策略来解决版本冲突。

Spring-cloud-huawei、Servicecomb及Sermant功能对比 一级特性 二级特性 serviccomb-java-chassis spring-cloud-huawei sermant agent 备注 微服务网关 服务端限流 √ √ √ - 服务端隔离仓 √ √ √ - 客户端熔断 × √ × - 客户端容错 × √ × - 客户端降级 × × × - 客户端故障注入 × × × - 负载均衡策略 √ √ × - 灰度发布 × √ √ - 优雅停机 √ √ × - 微服务治理 优雅上下线 √ √ √ - 无损升级 √ √ √ - 服务端限流 √ √ √ - 客户端容错 √ √ √ - 客户熔断 √ √ √ - 客户端降级 √ √ √ - 服务端隔离仓 √ √ √ - 客户端隔离仓 √ √ √ - 负载均衡策略 √ √ √ - 灰度发布 √ √ √ - 全链路日志追踪 √ √ × - 服务治理状态上传 √ √ × - 快速失败 √ √ × - 故障注入 √ × √ - 黑白名单 √ √ × - 注册发现 本地注册发现 √ √ × - 单注册- CS E √ √ √ - 单注册-ServiceCenter √ √ √ - 双注册 × × √ 双注册指同时注册到两个注册中心，当前sermant支持同时注册到cse和宿主原生注册中心。 配置中心支持 servicecomb引擎 √ √ √ 可基于配置中心下发配置, 例如服务治理规则、业务配置。 Nacos引擎 √ √ √ servicecomb-kie √ √ √ zookeeper × × √ 轻量化配置中心（zero-config） √ × × apollo × × × 安全特性 安全认证 √ √ × 服务实例与注册中心以及消费端与生产端之间的认证。 开发 多协议支持 √ × × JavaChassis针对消费与生产端支持多种通信协议，如下： 生产端：JAX-RS、SpringMVC、透明RPC。 消费端：透明RPC、RestTemplate、InvokerUtils。 拓展 支持用户自定义处理链处理流量。 支持用户扩展流量治理。 支持Spring Cloud原生扩展。 支持用户扩展流量治理。 基于插件开发模式新增能力。 -

Nacos引擎与微服务框架版本关系 CSE Nacos引擎版本 Spring Cloud Alibaba版本 Spring Cloud版本 Spring Boot版本 2.1.0.x 2022.0.0.0-RC* Spring Cloud 2022.0.0 3.0.0 2021.0.4.0* Spring Cloud 2021.0.4 2.6.11 2021.0.1.0 Spring Cloud 2021.0.1 2.6.3 2021.1 Spring Cloud 2020.0.1 2.4.2 2.2.10-RC1* Spring Cloud Hoxton.SR12 2.3.12.RELEASE 2.2.9.RELEASE Spring Cloud Hoxton.SR12 2.3.12.RELEASE 2.2.8.RELEASE Spring Cloud Hoxton.SR12 2.3.12.RELEASE 2.2.7.RELEASE Spring Cloud Hoxton.SR12 2.3.12.RELEASE 2.2.6.RELEASE Spring Cloud Hoxton.SR9 2.3.2.RELEASE 2.2.1.RELEASE Spring Cloud Hoxton.SR3 2.2.5.RELEASE 2.2.0.RELEASE Spring Cloud Hoxton.RELEASE 2.2.X.RELEASE 2.1.4.RELEASE Spring Cloud Greenwich.SR6 2.1.13.RELEASE 2.1.2.RELEASE Spring Cloud Greenwich 2.1.X.RELEASE 2.0.4.RELEASE(停止维护，建议升级) Spring Cloud Finchley 2.0.X.RELEASE 1.5.1.RELEASE(停止维护，建议升级) Spring Cloud Edgware 1.5.X.RELEASE

Nacos引擎版本兼容性说明 CSE Nacos引擎版本 兼容Nacos社区版本 兼容性 2.1.0.x 2.1.0 100% CSE Nacos引擎很好地兼容社区Nacos 2.1.0及其以下版本，且向下兼容。例如：微服务使用开源Nacos 1.x.x版本，也可以使用CSE Nacos引擎。 配置中心兼容Nacos 1.0起所有的客户端版本，服务发现兼容Nacos 1.2起的所有客户端版本， 因此建议使用Nacos 1.2.0之后客户端版本。 Nacos 2.x.x版本新增了长连接功能，需要使用长连接能力请升级至2.x.x版本。 Nacos 2.1.0版本后，默认关闭了双写能力，因此无法支持从Nacos 1.x版本平滑升级到2.1.0+的能力，如需要使用平滑升级能力，从Nacos 1.x直接升级到Nacos 2.1.0+版本，需要在application.properties文件中配置参数nacos.core.support.upgrade.from.1x=true。

URI URL格式 GET /v3/{project_id}/instances/{instance_id}/processes-audit-log?offset={offset}&limit={limit}&start_time={start_time}&end_time={end_time} 参数说明 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户在某一region下的project ID。 获取方法请参见获取项目ID。 instance_id 是 String DDM实例ID或关联RDS实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 索引位置，偏移量。 从第一条数据偏移offset条数据后开始查询，默认为0。 取值必须为数字，且不能为负数。 limit 否 Integer 查询个数上限值。 取值范围：1~128。 不传该参数时，默认值为10。 start_time 是 String 开始时间，UTC time，精确到毫秒。格式为“yyyy-mm-ddThh:mm:ssZ”。其中，T指某个时间的开始；Z指时区偏移量，例如北京时间偏移显示为+0800。 end_time 是 String 结束时间，UTC time，精确到毫秒。格式为“yyyy-mm-ddThh:mm:ssZ”。其中，T指某个时间的开始；Z指时区偏移量，例如北京时间偏移显示为+0800。结束时间与开始时间，间隔不能超过7天。

响应消息 正常响应参数说明 表4 响应Body参数 参数 参数类型 描述 total_count Integer 总条数。 process_audit_logs Array of 表4 UserProcessAuditLog objects 实例的kill会话审计日志列表。 表5 UserProcessAuditLog 参数 参数类型 描述 instance_id String 实例ID。 instance_name String 实例名称。 process_id String 会话ID。 execute_user_name String 执行操作的用户名。 excute_time String 操作时间，UTC time。 正常响应示例 { "total_count": 1, "process_audit_logs": [ { "instance_id": "5af0884170a84164980f79f9f5bf230c****", "instance_name": "UTS-ddm-name", "process_id": 6708736, "execute_user_name": "user_name", "execute_time": "2024-06-18T03:08:15+0800VGltZQ==" } ] } 异常响应 请参见异常请求结果。

URI URL格式 GET /v3/{project_id}/instances/{instance_id}/groups?offset={offset}&limit={limit} 参数说明 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户在某一region下的project ID。 获取方法请参见获取项目ID。 instance_id 是 String DDM实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 索引位置，偏移量。 从第一条数据偏移offset条数据后开始查询，默认为0。 取值必须为数字，且不能为负数。 limit 否 Integer 查询个数上限值。 取值范围：1~128。 不传该参数时，默认值为10。

响应消息 正常响应参数说明 表4 响应Body参数 参数 参数类型 描述 total_count Integer 总条数。 group_list Array of 表5 objects 实例的组信息列表。 表5 GroupInfo 参数 参数类型 描述 id String 组ID。 name String 组名称。 role String 组角色类型，分为读写组和只读组。 返回值： rw：读写组 r：只读组 endpoint String 组的连接地址。如果没有开启负载均衡，则返回的是组内节点的连接地址串。 ipv6_endpoint String 组IPv6的连接地址。 is_load_balance Boolean 是否开启负载均衡。 is_default_group Boolean 是否为默认组。 cpu_num_per_node Integer 单节点CPU的核数。 mem_num_per_node Integer 单节点的内存大小，单位为GB。 architecture String CPU架构。 返回值： X86 ARM node_list Array of 表6 objects 节点信息列表。 表6 GroupNodeInfo 参数 参数类型 描述 id String 节点ID。 name String 节点名称。 az String 节点所在的可用区。 正常响应示例 { "group_list":[ { "id":"****gr09", "name":"group-default", "role":"rw", "endpoint":"**.**.**.**:5066", "is_load_balance":true, "is_default_group":false, "architecture":"X86", "cpu_num_per_node":4, "mem_num_per_node":8, "node_list":[ { "id":"****no09", "name":"node_01", "az":"some_az" } ] } ], "total_count":1 } 异常响应 请参见异常请求结果。

响应消息 正常响应参数说明 表4 响应Body参数 参数 参数类型 描述 total_count Integer 总条数。 logical_processes Array of 表5 objects 实例的逻辑会话列表。 表5 logicalProcessesInfo 参数 参数类型 描述 id String 逻辑会话ID。 user String 当前连接的用户。 host String 所属的IP和端口。 db String 数据库名。 command String 连接状态，一般是休眠（sleep），查询（query），连接（connect）。 time String 连接状态持续的时间，单位是秒（s）。 state String 当前SQL语句的状态。 info String 当前所执行的SQL语句。 正常响应示例 { "logical_processes": [ { "id": "4564224", "user": "drdsagent", "host": "127.0.0.1:54486", "db": "None", "command": "Query", "time": "0", "state": "starting", "info": "show processlist" } ], "total_count": 1 } 异常响应 请参见异常请求结果。

URI URL格式 GET /v3/{project_id}/instances/{instance_id}/logical-processes?offset={offset}&limit={limit} 参数说明 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户在某一region下的project ID。 获取方法请参见获取项目ID。 instance_id 是 String DDM实例ID。 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 索引位置，偏移量。 从第一条数据偏移offset条数据后开始查询，默认为0。 取值必须为数字，且不能为负数。 limit 否 Integer 查询个数上限值。 取值范围：1~128。 不传该参数时，默认值为10。 keyword 否 String 会话结果筛选关键字，支持返回结果全字段模糊匹配，长度最大255。

前提条件 Linux系统的主机。 查询API相关接口文档。 通过查询日志转储API获取到所有转储任务的信息。 通过更新日志转储API将转储任务配置的时区修改。 在 API Explorer 中测试API功能，API Explorer提供API检索及平台调试能力。 参考API Explorer示例代码，在主机上安装Python SDK。 Python的SDK依赖包地址以及SDK使用说明。 pip install huaweicloudsdklts API Explore提供Python调用API的示例代码，以下示例仅供参考： # coding: utf-8 import os from huaweicloudsdkcore.auth.credentials import BasicCredentials from huaweicloudsdklts.v2.region.lts_region import LtsRegion from huaweicloudsdkcore.exceptions import exceptions from huaweicloudsdklts.v2 import * if __name__ == "__main__": # The AK and SK used for authentication are hard-coded or stored in plaintext, which has great security risks. It is recommended that the AK and SK be stored in ciphertext in configuration files or environment variables and decrypted during use to ensure security. # In this example, AK and SK are stored in environment variables for authentication. Before running this example, set environment variables CLOUD_SDK_AK and CLOUD_SDK_SK in the local environment /* 认证用的ak和sk硬编码到代码中或者明文存储都有很大的安全风险, 建议在配置文件或者环境变量中密文存放, 使用时解密, 确保安全; ak = os.environ["CLOUD_SDK_AK"] sk = os.environ["CLOUD_SDK_SK"] credentials = BasicCredentials(ak, sk) client = LtsClient.new_builder() \ .with_credentials(credentials) \ .with_region(LtsRegion.value_of("xx")) \ .build() try: request = ListTransfersRequest() response = client.list_transfers(request) print(response) except exceptions.ClientRequestException as e: print(e.status_code) print(e.request_id) print(e.error_code) print(e.error_msg)

方案介绍 日志流是通过日志组管理的，给日志组添加标签时，默认开启应用到日志流，这样日志流就自动添加标签。即可通过日志流统计不同部门在LTS的费用开销。 本实践以aa和bb部门为例子，首先在aa部门的日志组添加group=groupaa标签，bb部门的日志组添加group=groupbb标签，然后在费用明细中导出账单，通过Excel进行统计分析。 以下提到的价格仅为示例，实际计算请以价格计算器中的价格为准。

策略语法 给用户组选择策略时，单击策略下方的，可以查看策略的详细内容，以“BSS Administrator”为例，说明RBAC策略的语法。 { "Version": "1.0", "Statement": [ { "Effect": "Allow", "Action": [ "BSS:*:*" ] } ] }