创建并选择数据集 创建数据集提供两个入口。 在事件流中创建数据集，在看板构建页面中选择数据集。 登录圆桌，在页面右上角单击“轻应用构建”，进入“轻应用构建”平台。 在“我的模板集”首页，单击已创建的模板集名称，或者单击“操作”列的“编辑”，进入模板集详情页面。 如没有已创建的模板集名称，请先创建模板集，具体操作请参见新建模板集。 单击“模板列表”，选择“事件流”页签，单击已创建的事件流名称，进入事件流构建页面。 如需构建事件流，单击“新建事件流”，具体操作请参见构建事件流。 在“配置信息”页签内，选择“数据集”。 创建数据集。 在“数据集”页面，单击“创建数据集”。 输入数据集名称，勾选需展示数据的事件模板。 自定义数据集：需选择同一事件流中的2-3个事件模板，必须选择起始模板，仅可选择1个起始模板。 单击“确定”，数据集创建完成。 您可以单击数据集名称再次编辑，单击“操作”列“删除”可以删除数据集。 创建高码定制数据集。 在“数据集”页面，单击“创建高码定制数据集”。 输入数据集名称，勾选需展示数据的事件模板。 高码定制数据集：支持选择多个事件模板。 单击“确定”，数据集创建完成。 您可以单击数据集名称再次编辑，单击“操作”列“删除”可以删除数据集。 单击“操作”列“定制”，进入cube“定制数据集”页面。 选择事件模板或定制数据集对象，进入自定义对象页面，新增自定义字段。 选择脚本，单击禁用脚本，输入代码，单击保存，单击启用脚本。 定制逻辑：默认按事件模板及其内部包含的字段生成参数。支持修改。 进入“配置”页面，单击“定时任务”页签，点击任务名称，进入定时任务设置页面，设置定时任务执行频率，保存。单击“启用”，开启定时任务。 定时任务：用于每日更新数据集数据。默认生成，且默认不启用，支持修改。 在看板构建中选择数据集。 返回模板集首页，选择“看板”页签。 选择看板模板。单击看板模板名称，或单击“操作”列“编辑”，进入看板构建页面。 如需新建看板，直接单击“新建看板”。具体操作可参见构建看板。 选择“页面构建”页签，在左侧组件库拖拽图表组件至中间画布中。 在右侧属性“数据范围”处单击“选择数据源”。 在“自定义数据集”页签勾选已有数据集，单击“确定”。如图1。 表单：只支持选择同一个事件流的单个事件模板。 自定义数据集：支持选择同一个事件流中2-5个模板合并为数据集。 高码定制数据集：支持选择多个事件模板，通过高码方式定制数据集。 图1 选择自定义数据集 图2 选择高码定制数据集 在“字段设置”处添加组件中需展示的字段。 直接在看板构建页面创建并选择数据集。 模板集首页，单击“模板列表”，选择“看板”页签。 选择看板模板。单击看板模板名称，或单击“操作”列“编辑”，进入看板构建页面。 如需新建看板，直接单击“新建看板”。具体操作可参见构建看板。 选择“页面构建”页签，在左侧组件库“图表组件”处拖拽组件至中间画布中。 在右侧属性“数据范围”处单击“选择数据源”。 在“选择数据集”弹窗勾选事件模板。图3。 表单：只支持选择同一个事件流的单个事件模板。 在“表单”页签，勾选模板，单击“确定”。 图3 选择数据集 自定义数据集：支持选择同一个事件流中2-3个模板合并为数据集。 单击下方“自定义数据集”。 勾选事件流中的事件模板，单击“下一步”。 输入数据集名称，单击“确定”。 自定义数据集中，必须勾选事件流的起始模板。 图4 自定义数据集 高码定制数据集：最少选择2个事件模板，支持跨事件流选择多个事件模板，通过高码方式定制数据集。 单击页面底部“高码定制数据集”。 勾选事件流中的事件模板，单击“下一步”。 输入数据集名称，单击“确认”。 图5 高码定制数据集 单击已创建高码定制数据集后“前往定制页面”，进入cube“定制数据集”页面。 选择事件模板或定制数据集对象，进入自定义对象页面，支持增加自定义字段。 图6 自定义对象 选择脚本，单击禁用脚本，输入代码，单击保存，单击启用脚本。 定制逻辑：默认按事件模板及其内部包含的字段生成参数。支持新增、修改字段。 图7 高码定制数据集定制页面 进入“配置”页面，单击“定时任务”页签，点击任务名称，进入定时任务配置页面，设置定时任务执行频率，保存。单击“启用”，开启定时任务。 定时任务：用于每日更新数据集数据。默认生成，且默认不启用，支持修改。 图8 高码定制数据集定时任务入口 在“字段设置”处添加组件中需展示的字段。

相关操作 在“事件流”页签内，单击列表“操作”列的对应操作，还可编辑、删除事件流。 表6 相关操作 操作 说明 编辑事件流 单击“操作”列“编辑”，或直接单击事件流名称，编辑已创建的事件流信息。 删除事件流 仅支持删除状态为“编辑中”的事件流。单击“操作”列“删除”进行删除事件流操作，事件流删除后，事件流内的事件模板会同步删除。 调测事件流 所有状态都支持调测。单击“操作”列“调测”跳转至开发环境调测团队页面，测试已创建的事件流。 查看事件流 单击“操作”列“查看”，查看事件流信息。查看功能是对内容可见不可编辑。

调测事件流 新建事件流支持进入调测页面进行调测功能，提供虚拟用户，支持切换不同用户视角查看、处理事件。 单击已建事件流“操作”列“调测”按钮，进入开发环境的调测团队页面。 表3 调测团队介绍 操作 说明 团队 仅保留“调测用团队”，不可添加新团队。 应用管理 团队应用管理页面显示“已选应用”页签，展示已添加的应用。 看板管理 团队看板管理页面显示“已添加看板”及“看板库”页签。 表4 事件流调测团队界面操作 操作 说明 切换虚拟用户 调测团队页面右上角显示虚拟用户，支持切换其他用户。 虚拟用户按照事件流设置的预置角色显示，默认选择角色数据表第一个角色。 仅单击事件流后“调测”进入调测团队显示虚拟用户按钮，单击看板后“调测”进入调测团队不显示该按钮。 清除调测数据 可清理调测团队下的数据。 仅清除实例数据：清空事件列表中的事件，保留测试团队下的事件流及看板。 清除实例数据并清空调测团队：清空事件列表中的事件，同时清空测试团队下所有的事件流和看板。 退出调测环境 关闭调测页面，返回轻应用构建页面。 图3 调测页面 进入“调测用团队”，单击左上角调测用团队头像，单击“应用管理”页签。 如果在“已选应用”页签的应用中显示事件流模板，表示事件流模板已添加成功。 未添加的事件流自动添加至调测用团队，已添加过事件流不会重复添加。 选择需调测的事件流模板，单击“操作”列。 进入“预置数据”页面，在左侧栏选择数据表，单击“新增”，预置初始数据。 角色数据表是系统默认数据表，无需模板构建者构建，表内的角色和业务流模板内创建的角色一致。调测模式不支持设置角色预置数据。 其他数据表是模板构建者自定义创建。调测模式支持设置其他数据表数据。 创建事件流。 在调测团队“事件列表”，在页面左上角单击“新建”右侧的，选择构建的事件流模板。 事件流模板默认显示设为起始模板的事件模板。 仅可创建调测事件流的起始模板。 填写起始事件信息，设置发布设置，单击“发布”。发布成功后，表示构建的事件流模板已可以正常使用。 发布设置仅可设置事件接收人。 表5 事件相关操作 操作 说明 事件接收人 支持选择当前调测事件流中的预置角色及调测人租户内成员。 成员组件 支持选择当前调测事件流中的预置角色及调测人租户内成员。 部门组件 支持选择调测人租户中的组织架构。 事件评论点赞 不支持评论、点赞。 根据业务场景测试流程。单击右上角虚拟用户按钮，选择其他用户，查看、处理事件。 单击页面右上角“退出调测环境”，关闭调测页面，返回轻应用构建页面。 退出调测环境时调试数据保留。

操作权限 事件流状态包含“编辑中”和“运行中”，不同的事件流状态对应不同的操作权限。 编辑中：事件流没有被应用绑定的状态。该状态有如下操作权限： 支持编辑、删除、调测事件流。 “编辑中”状态模板支持在业务规则、页面赋值、表单触发、按钮触发、定时触发、关联模板组件和关联子表组件中引用“编辑中”状态和“运行中”状态模板。 运行中：上架应用时，事件流被应用绑定后，事件流状态自动转变为“运行中”。该状态有如下操作权限： 支持编辑、调测事件流，但不支持删除事件流。 “运行中”状态模板支持在业务规则、页面赋值、表单触发、按钮触发、定时触发、关联模板组件和关联子表组件中引用“编辑中”状态和“运行中”状态模板。 不支持更改、删除事件流中的起始模板。

新建事件流 登录圆桌，在页面右上角单击“轻应用构建”，进入“轻应用构建”平台。 在“我的模板集”首页，单击已创建的模板集名称，或者单击“操作”列的“编辑”，进入模板集详情页面。 单击“模板列表”，选择“事件流”页签，单击“新建事件流”。 填写事件流信息。包含“事件流/业务流程名称”和“描述”，完成后单击“确定”。 构建业务流程。在事件流“页面构建”页面，根据业务场景构建业务流程。 从左侧组件库拖拽组件至中间角色泳道内，使用连接线将组件连接起来，体现信息流转。如图1所示。 图1 事件流构建页面 表1 页面介绍 序号 区域 说明 1 组件库 包含按钮组件和事件模板组件。 按钮组件：用于事件之间的连接。 事件模板组件：用于构建事件模板。 2 工具栏 工具栏依次提供选择工具、移动工具、连接线、缩放功能。 ：选择工具，默认鼠标选中此工具，用于编辑、拖拽、删除组件或角色等操作。 ：移动工具，用于调整整个流程图在泳道内的具体位置。 ：连接线，用于连接两个组件，体现业务流转方向。 缩放功能：位于工具栏最右侧，用于调整泳道大小。默认100% ，调整幅度10%，支持ctrl+鼠标滚轮调整泳道大小。 3 泳道 每个角色对应一个泳道，通过拖拽组件至泳道内设计业务流程。 表2 页面相关操作 操作 说明 添加泳道 根据角色设定可以添加泳道。在角色列单击，添加新泳道。 删除泳道 选中角色卡片，单击卡片右上角，单击“删除角色”。 说明： 如当前角色泳道内存在事件模板，当前泳道不可删除。 编辑角色名称 选中角色卡片，单击角色名称处，修改角色名称。 编辑角色图标 选中角色卡片，单击卡片上的图标修改角色图标。支持本地上传角色图标。 添加事件模板组件 在角色泳道内添加“事件模板组件”。 从左侧组件库拖拽“事件模板组件”至中间相应的角色泳道内。 在“新建事件模板”弹窗，输入“事件模板名称”和“开发者版本说明”，单击“确定”。 说明： 最多可以添加20个事件模板。 删除事件模板组件 在泳道内选中某个事件模板组件，单击组件右上角，确认后删除。 说明： 事件模板删除后将无法恢复，请谨慎操作。 构建事件模板入口 在泳道内双击某个事件模板组件，即可跳转到事件模板构建页面。 调整事件模板组件位置 在泳道内选中某个事件模板组件，拖动组件至具体位置。 添加按钮组件 给角色泳道内某个事件模板组件添加“按钮”组件。 从左侧组件库拖拽“按钮”组件至泳道内的事件模板组件内。 双击“按钮”组件。修改“按钮”名称。 删除按钮组件 选中按钮组件，单击。 设为起始模板 将某个事件模板设置为业务流程开始的第一个事件模板。选中某个事件模板，单击“设为起始模板”。 说明： 至少设置1个起始模板，事件流才能正常发布。 一个事件流最多支持设置5个起始模板。 取消起始模板 选中某个起始模板，单击“取消起始模板”。 配置信息，包含基础设置、事件模板、预置数据和数据集。 基础设置：您可以根据实际需求，编辑事件流名称、事件流图标和描述。编辑完成后，单击右上角“保存”。 事件模板：查看并构建当前事件流包含的所有事件模板。单击“操作”列，进入事件模板构建页面。具体构建操作请参见构建事件模板。 支持根据关键字搜索事件模板信息。 预置数据：预置公共初始数据，事件流内的所有事件模板均可使用。具体操作请参见预置数据。 数据集：用于收集选中表单的业务数据。具体操作请参见数据集。 设置模板可见范围。在“可见范围”页面设置参数，单击“保存”。 模板可见范围：提供全部可见、不可见和部分可见三种类型，选择部分可见时，该模板仅创建人和选择的接收人可见。 保存成功后，事件流模板构建成功。 图2 模板可见范围

创建空间 前提条件： 开通华为云账号，若未开通，可前往华为云官网注册并开通账号； 注册成为解决方案工作台用户。如何成为解决方案工作台用户请参考访问解决方案工作台； 登录解决方案工作台控制台-首页，新建运维工作空间。 点击【新建】按钮 图1 首页 工作场景选择“事件流程管理“，点击下一步 图2 新建运维空间 填写空间名称（必填）、空间描述（选填） 添加本企业用户到空间（可选，空间创建后也可以添加空间成员），点击【添加】按钮，选择添加的 IAM 用户名和角色。 图3 空间创建人默认是管理员角色，管理员角色可以编辑空间已经管理空间成员。 点击【确定】 父主题： 使用解决方案工作台进行事件流程管理

源端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流”，进入“事件流”页面。 单击“创建事件流”。 在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。 配置Kafka事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 事件提供方选择“分布式消息服务 Kafka版”。 设置事件源参数。 图1 事件源-Kafka 表1 配置参数说明 参数名称 说明 实例 选择Kafka实例。 Topic 选择Topic。 消费组 输入消费组。 并发数 输入并发数，输入值范围1~1000。 建议并发数与选择的Topic的分区数保持一致，如果不一致可能会影响消息消费速率。当您选择Topic时，如果并发数为空会读取您选择的Topic的分区数作为并发数。 消费点位 选择消费点位。 最新点位：将会从消息队列的最新消息开始消费。 最早点位：将会从消息队列的最早消息开始消费。 SASL认证机制 当Kafka实例开启SASL SSL时可见，选择SASL认证机制。 PLAIN：一种简单的用户名密码校验机制。 SC RAM -SHA-512：采用哈希算法对用户名与密码生成凭证，进行身份校验的安全认证机制，比PLAIN机制安全性更高。 SASL证书地址 当Kafka实例开启SASL SSL时可见，输入SASL证书地址。获取地址请参考如何获取分布式消息服务Kafka实例的SASL证书地址。 说明： 必须使用zip压缩包，压缩包内的文件数量不超过两个，压缩包和文件大小均不可超过1M； 压缩包里证书的名称必须是固定的：client.jks。 SASL证书密钥 当Kafka实例开启SASL SSL时可见，输入SASL证书密钥。 用户名 当Kafka实例开启SASL SSL时可见，输入实例用户名。 用户密码 当Kafka实例开启SASL SSL时可见，输入实例用户密码。 单击“保存”，完成配置事件源。

目标端配置操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流”，进入“事件流”页面。 单击“创建事件流”。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图2 分布式消息服务 Kafka版 表2 分布式消息服务 Kafka版参数说明 参数名称 说明 目标连接 选择目标连接。如果还未创建目标连接，请先创建分布式消息服务Kafka版目标连接。 Topic 选择Topic。先选目标连接以加载Topic选项。 消息Key配置 关闭 不启用消息Key。 开启 变量：从CloudEvents标准事件中获取变量值，将变量值作为Key值。 常量：将指定的常量作为key值。若选择常量，所有消息将发送至同一分区。 规则配置 类型 变量：data.value 如果需要了解更多转换类型的信息，请参考事件内容转换。 消息推送 批量推送 配置是否开启批量推送，批量推送可帮您批量聚合多个事件。 批量推送条数 推送间隔 开启批量推送可见，每次批量推送的最大聚合条数，默认值100，输入值范围1~10000。 开启批量推送可见，输入批量推送间隔，默认值1，输入值范围0~15，单位：秒。 事件目标kafka不支持自定义证书。 表3 批量推送示例 批量推送条数 推送间隔 实际发送效果 100条 1s 每隔1s批量推送100条消息 200条 5s 每隔5s批量推送500条消息 配置完成后，单击“确定”。 单击“事件流列表”操作列的“启用”，待状态列显示为“运行中”则代表整个链路创建成功。

操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流”，进入“事件流”页面。 单击“创建事件流”。 在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。 配置事件源。 单击“事件源”，右侧弹出“事件源”弹窗。 选择事件源提供方。 设置事件源参数。 完成后单击“下一步”。 配置规则。 单击“规则”，右侧弹出“规则”弹窗。 配置规则模式内容。 完成后单击“下一步”。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 选择目标服务。 设置事件目标参数。 完成后单击“确定”。 单击“保存”，完成事件流的创建。 事件流创建成功后，状态默认为“停用”。

RocketMQ采集函数错误码 错误码 错误码说明 运维说明 操作建议 200 心跳成功 设置事件流状态为RUNNING，清除告警。 正常提示。 601 未知致命异常 设置事件流状态为ERROR，上报告警，自动重启事件流。 建议联系华为工程师处理。 602 网络异常 502 消费者不存在 401 目标端投递认证失败 主动刷新token，设置事件流状态为ERROR，自动重启事件流。 等待自动恢复。 600 升级中 无动作。 采集函数正在升级，等待升级即可。 403 目标函数被禁用 设置事件流状态为ERROR，上报告警。 检查函数是否正常。 516 topic不存在 检查topic。 510 开启ACL的rocketMq认证失败 其他未识别错误码 检查用户密码是否发生变化，确认无误请联系华为工程师处理。 父主题： 管理事件流

响应示例 状态码： 400 { "error_code" : "EG.00014000", "error_msg" : "Bad request" } 状态码： 401 { "error_code" : "EG.00014010", "error_msg" : "Incorrect token or token resolution failed" } 状态码： 403 { "error_code" : "EG.00014030", "error_msg" : "No permissions to request this method" } 状态码： 404 { "error_code" : "EG.00014040", "error_msg" : "Not request resource found" } 状态码： 500 { "error_code" : "EG.00015000", "error_msg" : "Internal Server Error" }

响应参数 状态码： 200 表4 响应Header参数 参数 参数类型 描述 X-Request-Id String This field is the request ID number for task tracking. Format is request_uuid-timestamp-hostname. 表5 响应Body参数 参数 参数类型 描述 total Integer 总数 size Integer 本页数量 items Array of EventStreamingDetail objects 对象列表 数组长度：0 - 100 表6 EventStreamingDetail 参数 参数类型 描述 name String 事件流名称，租户下唯一，由字母、数字、点、下划线和中划线组成，必须字母或数字开头 最小长度：1 最大长度：128 description String 事件流描述 最大长度：255 source EventStreamingSource object 事件源，一个事件流中事件源只有一个 sink EventStreamingSink object 事件目标，一个事件流中只有一个 rule_config rule_config object 事件规则，包括过滤规则和转换规则 option RunOption object 运行时配置信息 status String 事件流状态 最小长度：1 最大长度：128 枚举值： CREATED RUNNING ERROR STOPPED id String 事件流ID created_time String 创建时间 updated_time String 更新时间 表7 EventStreamingSource 参数 参数类型 描述 source_kafka SourceKafkaMQParameters object 华为云DMS版kafka类型事件源 source_mobile_rocketmq SourceMobileMQParameters object 移动云版rocketMQ类型事件源 source_community_rocketmq SourceCommunityMQParameters object 社区版rocketMQ类型事件源 source_dms_rocketmq SourceDMSMQParameters object 华为云DMS版rocketMQ事件源 name String 事件源类型名称 枚举值： HC.Kafka HC.COMMUNITY_ROCKETMQ HC.DMS_ROCKETMQ HC.MOBILE_ROCKETMQ 表8 SourceKafkaMQParameters 参数 参数类型 描述 addr String kafka连接地址 group String kafka消费组 最小长度：1 最大长度：256 instance_name String kafka实例名称 最小长度：4 最大长度：64 security_protocol String 安全协议 instance_id String kafka实例ID 最小长度：1 最大长度：256 topic String kafka topic名称 最小长度：3 最大长度：200 seek_to String 消费点位 枚举值： latest earliest enable_sasl_ssl Boolean SASL_SSL是否开启 sasl_mechanism String SASL认证机制 枚举值： SCRAM-SHA-512 PLAIN ssl_certificate_url String SASL证书地址，配置的obs地址 最小长度：1 最大长度：512 ssl_certificate_pwd String SASL证书密码 最小长度：1 最大长度：256 user_name String 用户名 最小长度：1 最大长度：256 password String 用户密码 最小长度：1 最大长度：256 表9 SourceMobileMQParameters 参数 参数类型 描述 group_id String 消费组id 最小长度：3 最大长度：128 instance_id String 实例id 最小长度：3 最大长度：128 topic String topic 最小长度：3 最大长度：128 tag String 标签 最大长度：128 authentication_required Boolean 鉴权认证 msg_trace_switch Boolean 保存消息轨迹 access_key String AccessKey 最大长度：128 secret_key String SecretKey 最大长度：128 message_model String 订阅方式 缺省值：CLUSTERING 枚举值： CLUSTERING BROADCASTING addr_type String 接入点类型 缺省值：PUBLIC 枚举值： PUBLIC PRIVATE addr String 地址 最大长度：256 sdk_url String 依赖SDK 最大长度：256 consume_timeout Integer 消费超时时间 最小值：1000 最大值：900000 缺省值：30000 message_type String 消息类型 枚举值： NORMAL suspend_time Integer 失败重试的等待时间 最小值：10 最大值：1800 缺省值：1800 max_reconsumer_times Integer 最大重试次数 最小值：1 最大值：16 缺省值：3 consumer_thread_nums Integer 消费线程数 最小值：20 最大值：64 缺省值：20 consumer_batch_max_size Integer 批量消费最大消息数 最小值：1 最大值：1024 缺省值：20 consumer_max_wait Integer 批量消费最大等待时长，单位：秒 最小值：0 最大值：450 缺省值：5 vpc_id String 虚拟私有云 subnet_id String 子网 表10 SourceCommunityMQParameters 参数 参数类型 描述 instance_name String 实例名称，仅dms的rockectMq需要该字段 最大长度：128 instance_id String 实例ID，仅dms的rockectMq需要该字段 最大长度：128 addr String rockectMq连接地址 group String 消费组 最小长度：3 最大长度：64 topic String topic名称 最小长度：3 最大长度：64 tag String 标签 最大长度：128 vpc_id String 虚拟云id 最大长度：256 subnet_id String 子网id 最大长度：256 ssl_enable Boolean 开启SSL enable_acl Boolean ACL访问控制 access_key String 用户名 最大长度：128 secret_key String 密码 message_type String 消息类型 枚举值： normal consume_timeout Integer 消费超时时间 最小值：1000 最大值：900000 缺省值：30000 consumer_thread_nums Integer 线程消费数 最小值：20 最大值：64 缺省值：20 consumer_batch_max_size Integer 批量消费最大消息数 最小值：1 最大值：32 缺省值：1 表11 SourceDMSMQParameters 参数 参数类型 描述 instance_name String 实例名称，仅dms的rockectMq需要该字段 最大长度：128 instance_id String 实例ID，仅dms的rockectMq需要该字段 最大长度：128 group String 消费组 最小长度：3 最大长度：64 topic String topic名称 最小长度：3 最大长度：64 tag String 标签 最大长度：128 ssl_enable Boolean 开启SSL enable_acl Boolean ACL访问控制 access_key String 用户名 最大长度：128 secret_key String 密码 message_type String 消费方式，针对不同生产顺序消息类型，选择消费方式会导致不同结果，请严格按照需求选择消费方式。1、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：顺序消费，实际消息处理结果：按照消息组粒度，严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。2、生产顺序为：设置消息组，保证消息顺序发送。消费方式为：并发消费，实际消息处理结果：并发消费，尽可能按时间顺序处理。3、生产顺序为：未设置消息组，消息乱序发送。消费方式为：顺序消费，实际消息处理结果：按队列存储粒度，严格顺序。 基于 Apache RocketMQ 本身队列的属性，消费顺序和队列存储的顺序一致，但不保证和发送顺序一致。4、生产顺序为：未设置消息组，消息乱序发送。消费方式为：并发消费，实际消息处理结果：并发消费，尽可能按照时间顺序处理。 枚举值： NORMAL ORDER engine_version String mq实例版本 枚举值： 4.x 5.x consume_timeout Integer 消费超时时间 最小值：1000 最大值：900000 缺省值：30000 consumer_thread_nums Integer 线程消费数 最小值：20 最大值：64 缺省值：20 consumer_batch_max_size Integer 批量消费最大消息数 最小值：1 最大值：32 缺省值：1 表12 EventStreamingSink 参数 参数类型 描述 sink_fg SinkFGParameters object 函数目标参数 sink_kafka SinkKafkaParameters object kafka目标参数 name String 事件目标类型名称 枚举值： HC.FunctionGraph HC.Kafka 表13 SinkFGParameters 参数 参数类型 描述 invoke_type String 函数执行方式,同步/异步 枚举值： SYNC，ASYNC urn String 函数链接 最小长度：1 最大长度：512 agency String 租户委托 表14 SinkKafkaParameters 参数 参数类型 描述 topic String topic名称 keyTransform Array of TransForm objects key的转换规则 connectionId String 目标连接id 表15 TransForm 参数 参数类型 描述 type String 转换规则类型 枚举值： ORIGINAL CONSTANT VARIABLE value String 常量类型规则时，字段为常量内容定义； 变量类型规则时，为变量定义，内容必须为JsonObject字符串。 变量最多支持100个，且不支持嵌套结构定义； 变量名由字母、数字、点、下划线和中划线组成，必须字母或数字开头不能以HC.开头，长度不超过64个字符； 变量值表达式支持常量或JsonPath表达式，字符串长度不超过1024个字符。 最大长度：1024 template String 变量类型规则时，规则内容的模板定义，支持对已定义变量的引用。 最大长度：2048 表16 rule_config 参数 参数类型 描述 transform TransForm object 转换规则 filter Object 过滤规则 表17 RunOption 参数 参数类型 描述 thread_num Integer 并发数 最小值：1 最大值：1000 batch_window BatchWindow object 批量推送 表18 BatchWindow 参数 参数类型 描述 count Integer 批量推送条数 最小值：1 最大值：10000 缺省值：1 time Integer 重试次数 最小值：0 最大值：15 缺省值：3 interval Integer 批量推送间隔，单位秒 最小值：0 最大值：15 缺省值：0 状态码： 400 表19 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度：1 最大长度：128 error_msg String 错误消息 最小长度：1 最大长度：512 error_details String 具体错误消息 最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 401 表20 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度：1 最大长度：128 error_msg String 错误消息 最小长度：1 最大长度：512 error_details String 具体错误消息 最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 403 表21 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度：1 最大长度：128 error_msg String 错误消息 最小长度：1 最大长度：512 error_details String 具体错误消息 最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 404 表22 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度：1 最大长度：128 error_msg String 错误消息 最小长度：1 最大长度：512 error_details String 具体错误消息 最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128 状态码： 500 表23 响应Body参数 参数 参数类型 描述 error_code String 错误码 最小长度：1 最大长度：128 error_msg String 错误消息 最小长度：1 最大长度：512 error_details String 具体错误消息 最小长度：1 最大长度：1024 request_id String 请求处理ID 最小长度：1 最大长度：128

URI GET /v1/{project_id}/eventstreamings 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户项目ID 表2 Query参数 参数 是否必选 参数类型 描述 offset 否 Integer 偏移量，表示从此偏移量开始查询，偏移量不能小于0 最小值：0 最大值：100 缺省值：0 limit 否 Integer 每页显示的条目数量，不能小于1或大于1000 最小值：1 最大值：1000 缺省值：15

前提条件 进行应用改造需要提前完成的事项： 已开通MAS“同城多活”版本功能模块，功能点包括“MySQL”。具体详情请参见开通功能模块。 创建好“同城多活”类型的命名空间，分区类型选择“华为云”。具体详情请参见创建命名空间。 在已创建的命名空间下购买MAS多活管理中心，即创建好多活实例。具体详情请参见购买多活管理中心。 已在华为云购买RDS for MySQL两个数据库实例，且与MAS多活实例配置为相同VPC、子网、安全组，与多活实例网络互通；数据库实例需配置为相同的用户名和密码。 商城应用部署在已创建的命名空间下的可用区，且业务部署架构需要和MAS多活分区保持一致；与多活实例配置为相同VPC、子网、安全组，与多活实例网络互通。

创建并选择数据集 创建数据集提供两个入口。 在事件流中创建数据集，在管理视图构建页面中选择数据集。 登录圆桌，在页面右上角单击“轻应用构建”，进入“轻应用构建”平台。 在“我的模板集”首页，单击已创建的模板集名称，或者单击“操作”列的“编辑”，进入模板集详情页面。 如没有已创建的模板集名称，请先创建模板集，具体操作请参见新建模板集。 单击“模板列表”，选择“事件流”页签，单击已创建的事件流名称，进入事件流构建页面。 如需构建事件流，单击“新建事件流”，具体操作请参见构建事件流。 在“配置信息”页签内，选择“数据集”。 创建数据集，如图1。 在“数据集”页面，单击“创建数据集”。 输入数据集名称，勾选需展示数据的事件模板。 只支持选择当前事件流中的事件模板。 数据集中需选择事件流中的2-5个事件模板。 单击“确定”，数据集创建完成。 您可以单击数据集名称再次编辑，单击“操作”列“删除”可以删除数据集。 图1 创建数据集 在管理视图构建中选择数据集。 返回模板集首页，选择“管理视图”页签。 选择管理视图模板。单击管理视图模板名称，或单击“操作”列“编辑”，进入管理视图构建页面。 如需新建管理视图，直接单击“新建管理视图”。具体操作可参见构建管理视图。 选择“页面构建”页签，在左侧组件库拖拽图表组件至中间画布中。 在右侧属性“数据范围”处单击“选择数据源”。 在“自定义数据集”页签勾选已有数据集，单击“确定”。如图2。 表单：只支持选择同一个事件流的单个事件模板。 自定义数据集：支持选择同一个事件流中2-5个模板合并为数据集。 图2 选择数据集 在“字段设置”处添加组件中需展示的字段。 直接在管理视图构建页面创建并选择数据集。 模板集首页，单击“模板列表”，选择“管理视图”页签。 选择管理视图模板。单击管理视图模板名称，或单击“操作”列“编辑”，进入管理视图构建页面。 如需新建管理视图，直接单击“新建管理视图”。具体操作可参见构建管理视图。 选择“页面构建”页签，在左侧组件库“图表组件”处拖拽组件至中间画布中。 在右侧属性“数据范围”处单击“选择数据源”。如图3。 图3 新建数据集 在“选择数据集”弹窗勾选事件模板。图4。 表单：只支持选择同一个事件流的单个事件模板。 在“表单”页签，勾选模板，单击“确定”。 图4 选择数据集 自定义数据集：支持选择同一个事件流中2-5个模板合并为数据集。 单击下方“自定义数据集”。 勾选事件流中的事件模板，单击“下一步”。 输入数据集名称，单击“确定”。 自定义数据集中，必须勾选事件流的起始模板。 图5 自定义数据集 在“字段设置”处添加组件中需展示的字段。