事件网格 EG-华为云

事件网格 EG-RocketMQ预检查:源端连通性检查

源端连通性检查检查事件流作业所在运行时机器是否能正常连接到源端RocketMQ实例。原因一：无法连接源端RocketMQ实例，请检查网络配置是否正确。解决方案：进入RocketMQ的控制台页面，检查源端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与源端RocketMQ实例网络畅通。原因二：无法连接源端RocketMQ实例，请检查填写的实例信息是否正确。解决方案：进入RocketMQ的控制台页面，检查源端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与源端实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端RocketMQ实例的用户名和密码是否正确。

事件网格 EG

事件网格 EG-RocketMQ预检查:源端和目标端实例规格检查

源端和目标端实例规格检查检查源端和目标端RocketMQ实例的规格是否匹配。原因：源端和目标端RocketMQ实例的节点数量不一致，请检查源端实例和目标端实例的规格信息。解决方案：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端和目标端RocketMQ实例的节点数量是否一致，若不一致，请修改源端或者目标端实例，使二者保持一致。检查源端和目标端RocketMQ实例的规格是否匹配。原因：源端和目标端RocketMQ实例的实例类型不一致，请检查源端实例和目标端实例的规格信息。解决方案：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端和目标端RocketMQ实例的类型是否一致，要求都是集群或者都是单机，若不一致，请修改源端或者目标端实例，使二者保持一致。

事件网格 EG

事件网格 EG-RocketMQ预检查:源端和目标端实例版本检查

源端和目标端实例版本检查检查源端和目标端RocketMQ实例的版本是否符合要求，当前要求RocketMQ实例版本在5.x和4.8.0中，版本不在匹配名单中则提示告警。原因一：源端RocketMQ实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。原因二：目标端RocketMQ实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。检查源端和目标端RocketMQ实例的版本是否一致，版本不一致则提示告警。原因：源端实例和目标端实例的版本不一致，请检查源端实例和目标端实例的版本。解决方式：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端和目标端RocketMQ实例的版本是否一致，若不一致，请修改源端或者目标端实例，使二者保持一致。

事件网格 EG

事件网格 EG-RocketMQ预检查:目标端连通性检查

目标端连通性检查检查事件流作业所在运行时机器是否能正常连接到目标端RocketMQ实例。原因一：无法连接目标端RocketMQ实例，请检查网络配置是否正确。解决方案：进入RocketMQ的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端RocketMQ实例网络畅通。原因二：无法连接目标端RocketMQ实例，请检查填写的实例信息是否正确。解决方案：进入RocketMQ的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端RocketMQ实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的目标端RocketMQ实例的用户名和密码是否正确。

事件网格 EG

事件网格 EG-RocketMQ采集函数错误码

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

事件网格 EG

事件网格 EG-事件流预检查

事件流预检查当前仅支持华南-广州。预检查是创建事件流作业流程中的一环，用来检查用户填写的配置信息是否符合要求。预检查包含多个检查项，详情请参考表1，且每项检查独立执行，检查结果分成功、失败和告警三种类型。表1 检查项目介绍项目内容源端和目标端实例版本检查检查源端实例和目标端实例的版本是否匹配。源端连通性检查检查作业所在运行时机器是否能正常连接到源端实例。目标端连通性检查检查作业所在运行时机器是否能正常连接到目标端实例。源端和目标端实例规格检查检查源端实例和目标端实例的规格是否匹配。对于预检查结果是告警或者失败的事件流作业，都不会阻塞事件流作业的创建流程，检查结果仅做提示用。 Kafka预检查 RocketMQ预检查父主题：事件流

事件网格 EG 事件流

事件网格 EG-Kafka预检查:源端连通性检查

源端连通性检查检查事件流作业所在运行时机器是否能正常连接到源端Kafka实例。原因一：无法连接到源端Kafka实例，请检查网络配置是否正确。解决方案：进入Kafka的控制台页面，检查源端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。原因二：无法连接源端Kafka实例，请检查填写的实例信息是否正确。解决方案：进入Kafka的控制台页面，检查源端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与源端Kafka实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的源端Kafka实例的用户名和密码是否正确。

事件网格 EG 事件流预检查

事件网格 EG-Kafka预检查:目标端连通性检查

目标端连通性检查检查事件流作业所在运行时机器是否能正常连接到目标端Kafka实例。原因一：无法连接目标端Kafka实例，请检查网络配置是否正确。解决方案：进入Kafka的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端Kafka实例网络畅通。原因二：无法连接目标端Kafka实例，请检查填写的实例信息是否正确。解决方案：进入Kafka的控制台页面，检查目标端实例状态是否正常。检查事件流集群创建页面中配置的vpc和子网是否与目标端Kafka实例网络畅通。检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中配置的目标端Kafka实例的用户名和密码是否正确。

事件网格 EG 事件流预检查

事件网格 EG-Kafka预检查:源端和目标端实例版本检查

源端和目标端实例版本检查检查源端和目标端实例的版本是否符合要求，当前要求Kafka实例版本在 3.x和2.7 中，版本不在匹配名单中则提示告警。原因一：源端Kafka实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。原因二：目标端Kafka实例版本不支持，请选择符合要求的实例。解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。检查源端和目标端Kafka实例的版本是否一致，版本不一致则提示告警。原因：源端实例和目标端实例的版本不一致，请检查源端实例和目标端实例的版本。解决方式：检查配置专享版事件流作业的第二步，即“源和目标对象配置”页面中源端和目标端Kafka实例版本是否一致，若不一致，请修改源端或者目标端实例，使二者保持一致。否则，版本不一致可能会存在兼容性和性能风险。

事件网格 EG 事件流预检查

事件网格 EG-创建事件流:操作步骤

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

事件网格 EG 管理事件流

事件网格 EG-云服务事件源:查看事件类型

查看事件类型登录事件网格控制台。在左侧导航栏选择“事件源”，进入“事件源”页面。在“云服务事件源”页签，单击待查看事件类型的事件源名称，弹出“查看云服务事件源”对话框。在“事件类型”区域，查看事件类型和对应的描述信息，如图2所示。图1 事件类型单击操作列“查看示例”，可在弹窗查看示例详情，若事件实例如果有多个实例，弹窗里可以查询实例。图2 查看示例图3 多个示例目前只支持云服务事件模型列表中的六个场景，除此以外的点开暂无示例。

事件网格 EG 事件源

事件网格 EG-云服务事件源:云服务事件源列表

云服务事件源列表事件网格支持的云服务事件源列表如下：表1 云服务事件源云应用引擎 CAE 数据库和应用迁移 UGO Classroom 内容审核 Moderation 虚拟私有云 VPC 代码检查 CodeCheck 云数据库 GaussDB NoSQL GaussDB API网关 APIG 数据仓库服务 DWS 部署 CloudDeploy 统一身份认证 IAM 事件网格 EG 华为云 U CS 弹性文件服务 SFS CloudIDE 人脸识别 FRS 微服务引擎 CSE 云专线 DC 数据可视化 DLV NAT网关 NAT 云桌面 Workspace 设备接入服务 IoTDA 分布式消息服务 DMS 知识图谱 KG IoT边缘 IoTEdge 云日志服务 LTS 编译构建 CloudBuild 对象存储迁移服务 OMS 云备份服务 CBR 消息&短信服务 MSG SMS 弹性公网IP EIP 云审计服务 CTS 云搜索服务 CSS 视频分析服务 VAS 数据管理服务 DAS 裸金属服务器 BMS 云测 CloudTest VPC终端节点 VPCEP 云存储网关服务 CSG 虚拟专用网络 VPN 企业路由器 ER 推荐系统 RES 云服务器备份服务 CSBS 内容分发网络服务 CDN 容器安全服务 CGS 态势感知 SA 代码托管 CodeHub 表格存储服务 CloudTable 云硬盘备份服务 VBS 云速建站 CloudSite 云手机 CPH 云性能测试服务 CPTS 智能边缘云 IEC 函数工作流服务 FunctionGraph 主机迁移服务 SMS 标签管理服务 TMS 对话机器人服务 CBS 关系型数据库 RDS 云解析服务的Region级 DNS 存储容灾服务 SDRS 语音通话 VoiceCall 应用性能管理 APM 应用编排服务 AOS 数据接入服务 DIS 数据库安全服务 DBSS 慧眼HiLens HiLens 云数据迁移 CDM 多活高可用服务 MAS 流水线 CloudPipeline 图像识别 Image OBS应用事件源对象存储服务 OBS 智能边缘平台 IEF 容器镜像服务 SWR 分布式缓存服务 DCS 弹性伸缩 AS 漏洞扫描服务 VSS 图引擎服务 GES 数据湖探索 DLI 云容器实例 CCI 需求管理 CodeArts Req 文档数据库服务 DDS 数据复制服务 DRS AI平台ModelArts 分布式数据库中间件 DDM 消息通知服务 SMN 应用管理与运维平台 ServiceStage 软件开发生产线 CodeArts 区块链服务 BCS 应用运维管理 AOM MapReduce服务 MRS 云堡垒机 CBH 企业主机安全 HSS Web应用防火墙 WAF 弹性负载均衡 ELB 云硬盘 EVS 应用与数据集成平台 ROMA Connect 云容器引擎 CCE 镜像服务 IMS 弹性云服务器 ECS 目前只支持写事件，不支持读事件。

事件网格 EG 事件源

事件网格 EG-在CTS事件列表查看云审计事件:使用限制

使用限制单账号跟踪的事件可以通过云审计控制台查询。多账号的事件只能在账号自己的事件列表页面去查看，或者到组织追踪器配置的OBS桶中查看，也可以到组织追踪器配置的CTS/system日志流下面去查看。用户通过云审计控制台只能查询最近7天的操作记录。如果需要查询超过7天的操作记录，您必须配置转储到对象存储服务(OBS)或云日志服务(LTS)，才可在OBS桶或LTS日志组里面查看历史事件信息。否则，您将无法追溯7天以前的操作记录。云上操作后，1分钟内可以通过云审计控制台查询管理类事件操作记录，5分钟后才可通过云审计控制台查询数据类事件操作记录。

事件网格 EG 云审计服务支持的关键操作

事件网格 EG-实施及验证:目标端配置操作步骤

目标端配置操作步骤登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”。配置事件目标。单击“事件目标”，右侧弹出“事件目标”弹窗。目标服务选择“分布式消息服务 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条消息配置完成后，单击“确定”。单击“事件流列表”操作列的“启用”，待状态列显示为“运行中”则代表整个链路创建成功。

事件网格 EG 基于事件流实现Kafka实例之间的数据同步

事件网格 EG-实施及验证:源端配置操作步骤

源端配置操作步骤登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”。在弹窗中输入事件流名称和描述，单击“确定”，完成事件流名称和描述信息输入。配置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时可见，输入实例用户密码。单击“保存”，完成配置事件源。

事件网格 EG 基于事件流实现Kafka实例之间的数据同步

云服务器内容精选

事件网格 EG

7*24

备案

专业服务

退订

建议反馈

售前咨询热线