事件网格 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-EG最佳实践汇总

EG最佳实践汇总本文汇总了基于事件网格服务（EG，EventGrid）常见应用场景的操作实践，为每个实践提供详细的方案描述和操作指导，帮助用户轻松构建基于EG的业务。表1 EG最佳实践一览表最佳实践说明基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。基于事件流实现Kafka实例之间的数据同步本章节介绍如何通过事件网格服务的事件流功能实现分布式消息服务Kafka版实例间的数据同步。基于EventGrid事件订阅和Function实现OBS桶数据同步本章节介绍如何通过事件网格服务的事件订阅和函数工作流服务实现OBS桶的数据同步。基于事件流实现RocketMQ推送事件至函数工作流服务本章节介绍如何通过事件网格服务的事件流功能将RocketMQ产生的事件推送至函数工作流服务。

事件网格 EG

事件网格 EG-过滤规则参数说明:匹配字段

匹配字段过滤规则和事件匹配时，使用的匹配字段如表3所示。表3 匹配字段列表字段名条件值类型示例说明 source JSON对象数组事件源，条件值位于JSON数组中，source字段只支持“StringIn” 示例: [{“op”: “StringIn”, “values”: [“HC.OBS”]}] type JSON对象数组事件类型，条件值位于JSON数组中示例: [{“op”: “StringIn”, “values”: [“object:put”]}] subject JSON对象数组事件主体，条件值位于JSON数组中示例: [{“op”: “StringEndsWith”, “values”: [“.jpg”]}] data JSON对象事件数据，条件值位于JSON对象中，条件值为子匹配字段，支持最多5层嵌套结构示例: {“state”: [{“op”: “StringIn”, “values”: [“running”]}]

事件网格 EG 事件规则

事件网格 EG-过滤规则参数说明:匹配规则

匹配规则过滤规则和事件匹配时，需要遵循以下规则：顶级匹配字段只支持source、type、subject、data。顶级匹配必须包括source字段，且source只支持StringIn操作符。 data字段最多支持5个任意匹配字段，每个匹配字段最多嵌套5级。每个匹配字段的匹配条件最多支持5个，多个匹配条件间是“或”的关系。多个匹配字段间是“并且”的关系。同一层级相同的匹配字段定义多次，则以最后一次为准。

事件网格 EG 事件规则

事件网格 EG-过滤规则参数说明:运算操作符

运算操作符过滤规则和事件匹配时，使用的运算操作符如表1所示。表1 运算操作符列表操作符输入值条件值说明 StringIn String/String[] String[] values 检查输入值是否与任一条件值完全匹配 StringNotIn String/String[] String[] values 检查输入值是否与所有条件值都不匹配 StringStartsWith String/String[] String[] values 检查输入值是否与任一条件值前缀匹配 StringNotStartsWith String/String[] String[] values 检查输入值是否与所有条件值前缀都不匹配 StringEndsWith String/String[] String[] values 检查输入值是否与任一条件值后缀匹配 StringNotEndsWith String/String[] String[] values 检查输入值是否与所有条件值后缀都不匹配 NumberIn Number/Number[] Number[] values 检查输入值是否与任一条件值完全匹配 NumberNotIn Number/Number[] Number[] values 检查输入值是否与所有条件值都不匹配 NumberLessThan Number/Number[] Number value 检查输入值是否与小于条件值 NumberNotLessThan Number/Number[] Number value 检查输入值是否与不小于（大于或等于）条件值 NumberGreaterThan Number/Number[] Number value 检查输入值是否与大于条件值 NumberNotGreaterThan Number/Number[] Number value 检查输入值是否与不大于（小于或等于）条件值 NumberInRange Number/Number[] Number[][] values 检查输入值是否在任一条件范围值内 NumberNotInRange Number/Number[] Number[][] values 检查输入值是否不在任一条件范围值内 IsNull - 无检查输入值是否为null或未定义 IsNotNull - 无检查输入值是否不为null或未定义 IsTrue Boolean 无检查输入值是否为true IsNotTrue Boolean 无检查输入值是否不为true，即false

事件网格 EG 事件规则

事件网格 EG-编辑事件订阅:修改事件源

修改事件源登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击待修改事件源参数的订阅名称，进入订阅详情页。单击已有事件源模块，弹出“事件源”对话框。修改事件源配置参数。已创建的订阅，无法修改事件源提供方。当提供方为“华为云”时，设置如表1所示参数。表1 云服务事件源参数说明参数名称说明事件源选择云服务事件源。事件类型（可选）选择事件网格预定义的事件类型。过滤规则输入事件过滤规则。事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。如果需要了解更多过滤规则的信息，请参考过滤规则参数说明和过滤规则示例。图1 云服务事件源配置参数当提供方为“自定义”时，设置如表2所示参数。已创建的订阅，无法修改已绑定的自定义事件通道。表2 自定义事件源参数说明参数名称说明事件源配置配置类型支持以下两种类型：选择：选择一个已关联自定义事件通道的自定义事件源。新建：创建一个新的自定义事件源。事件源 “配置类型”为“选择”时，在下拉列表中选择一个已关联自定义事件通道的自定义事件源，此自定义事件通道为订阅绑定的自定义事件通道（即“通道配置”中“通道”的参数值）。 “配置类型”为“新建”时，输入自定义事件源名称。描述仅在“配置类型”为“新建”时，需要设置此参数。输入自定义事件源的描述信息。过滤规则输入事件过滤规则。事件源产生的事件与过滤规则进行匹配，匹配成功后事件才会被路由到与过滤规则关联的事件目标。如果需要了解更多过滤规则的信息，请参考过滤规则参数说明和过滤规则示例。图2 自定义事件源参数配置单击“确定”。单击“保存”，完成事件源的修改。

事件网格 EG 事件订阅

事件网格 EG-创建事件订阅

创建事件订阅登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”，进入订阅详情页。单击订阅名称旁的，弹出“修改订阅”弹窗。输入订阅名称和描述信息，单击“确定”，完成订阅名称和描述信息输入。配置事件源。配置如下事件源参数：选择提供方：华为云事件源：OBS应用事件源桶：选择OBS桶事件类型：下拉框中事件类型根据用户需求勾选对象名前缀：若填写，符合规范才能触发事件。默认不填写，表示全匹配。对象名后缀：若填写，符合规范才能触发事件。默认不填写，表示全匹配。对象名编码：开启过滤规则：根据默认值配置，无需修改。配置过滤规则请参考过滤规则参数说明。对象名前缀、对象名后缀填写时，对象文件格式必须都符合才能触发事件，当前后缀为空时，任意对象文件都符合。因目前OBS只对白名单用户开放，请在创建事件订阅前添加OBS白名单。创建事件订阅时，如果选择的OBS桶有被其他事件订阅调用，请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名前缀和后缀不一致。否则，保存事件订阅时，会报“OBS桶对象名前缀或后缀冲突”错误。配置事件目标。配置如下事件目标参数：选择提供方：华为云事件目标：分布式消息服务 Kafka版目标连接：选择“kafka-connect” Topic：选择“topic-eg” 启用消息Key：关闭规则配置类型：透传。配置转换规则请参考事件内容转换单击“保存”，完成订阅的配置。父主题：实施步骤

事件网格 EG

事件网格 EG-创建EG事件订阅

创建EG事件订阅登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”，进入订阅详情页。单击订阅名称旁的，弹出“修改订阅”弹窗。输入订阅名称和描述信息，单击“确定”，完成订阅名称和描述信息输入。配置事件源。表1 参数配置说明参数说明选择提供方请选择“华为云”。事件源请选择“OBS应用事件源”。桶请选择“选择OBS桶”。事件类型下拉框中事件类型根据用户需求勾选。对象名前缀若填写，符合规范才能触发事件。对象名后缀若填写，符合规范才能触发事件。对象名编码选择“开启”。过滤规则根据默认值配置，无需修改。配置过滤规则请参考过滤规则参数说明。对象名前缀、对象名后缀填写时，对象文件格式必须都符合才能触发事件，当前后缀为空时，任意对象文件都符合。创建事件订阅时，如果选择的OBS桶有被其他事件订阅调用，请确保当前桶的对象名前缀和后缀与其他事件订阅中配置的对象名前缀和后缀不一致。否则，保存事件订阅时，会报“OBS桶对象名前缀或后缀冲突”错误。配置事件目标。表2 参数配置说明参数说明选择提供方请选择“华为云”。事件目标请选择“FunctionGraph（函数计算）”。函数选择创建的OBS数据同步的函数。版本按需选择。执行方式按需选择。委托选择委托。如无委托，可单击旁边的“创建委托”进行创建，将会创建名为“EG_TARGET_AGENCY”委托。类型按需选择。父主题：实施步骤

事件网格 EG 实施步骤

事件网格 EG-事件网格支持的监控指标:监控指标

监控指标表1 事件投递监控项指标ID 指标名称指标含义取值范围测量对象监控周期（原始指标） num 投递数量该指标用于统计事件投递的调用总数。单位：个 ≥ 0 counts 事件订阅 1分钟 success_num 成功数量该指标用于统计事件投递的调用成功数量。单位：个 ≥ 0 counts 事件订阅 1分钟 process_time 处理时间该指标用于统计事件投递的周期内平均总处理时间。单位：毫秒 ≥ 0 ms 事件订阅 1分钟 fail_num 失败数量该指标用于统计事件投递失败且无需重试的事件数量。单位：个 ≥ 0 counts 事件订阅 1分钟 sub_success_rate 投递事件成功率该指标为单位时间订阅投递事件成功率。单位：% 0%≤x≤100% 事件订阅 1分钟 sub_failed_rate 投递事件失败率该指标为单位时间订阅投递事件失败率。单位：% 0%≤x≤100% 事件订阅 1分钟 sub_retry_num 投递事件重试数量该指标为单位时间订阅投递事件重试数量。单位：个 ≥ 0 counts 事件订阅 1分钟 sub_retry_rate 投递事件重试率该指标为单位时间订阅投递事件重试率。单位：% 0%≤x≤100% 事件订阅 1分钟 sub_process_time 投递事件平均处理耗时该指标为单位时间订阅投递事件平均处理耗时。单位 ≥ 0 ms 事件订阅 1分钟表2 事件接入监控项指标ID 指标名称指标含义取值范围测量对象监控周期（原始指标） num 接入数量该指标用于统计事件接入的调用数量。单位：个 ≥ 0 counts 事件通道 1分钟 success_num 成功数量该指标用于统计事件接入的调用成功数量。单位：个 ≥ 0 counts 事件通道 1分钟 fail_num 失败数量该指标用于统计事件接入的调用失败数量。单位：个 ≥ 0 counts 事件通道 1分钟 process_time 处理时间该指标用于统计事件接入的周期内平均处理时间。单位：毫秒 ≥ 0 ms 事件通道 1分钟 pub_success_rate 接入事件成功率该指标为单位时间通道接入事件成功率。单位：% 0%≤x≤100% 事件通道 1分钟 pub_failed_rate 接入事件失败率该指标为单位时间通道接入事件失败率。单位：% 0%≤x≤100% 事件通道 1分钟

事件网格 EG 事件监控

事件网格 EG-事件内容转换:透传

透传事件网格不对事件进行转换，将CloudEvents标准事件直接路由到事件目标。示例如下：转换前的事件转换类型转换后的事件 { "events":[{ "id": "4b26115b-73e-cf74a******", "specversion": "1.0", "source": "HC.OBS", "type": "object:put", "datacontenttype": "application/json", "subject": "xxx.jpg", "time": "2022-01-17T12:07:48.955Z", "data": { "name": "test01", "state": "enable" } }] } 透传 { "events":[{ "id": "4b26115b-73e-cf74******", "specversion": "1.0", "source": "HC.OBS", "type": "object:put", "datacontenttype": "application/json", "subject": "xxx.jpg", "time": "2022-01-17T12:07:48.955Z", "data": { "name": "test01", "state": "enable" } }] }

事件网格 EG 事件规则

事件网格 EG-事件内容转换:其他示例

其他示例在创建事件订阅-配置事件源为“分布式消息服务RabbitMQ版”或“分布式消息服务RocketMQ版”，消息转换为CloudEvents格式事件后，data字段下将包含context字段，在创建事件订阅-配置事件目标，规则类型配置为“变量”时，规则必须包含context字段，示例如下：转换前的事件转换类型转换后的事件 { "type": "ROCKETMQ:CloudTrace:RocketmqCall", "data": { "context": { "name": "test01", "state": "enable" } }, "source": "zhang_roc", "time": "2023-02-01T10:47:07Z", "datacontenttype": "application/json", "specversion": "1.0", "id": "2f885496-570c-4925-82fd-d1ad09******", "subject": "ROCKETMQ:cn-north-7:eec88b34-9470-483e-8961-edb168******/0de095e33e00d36e2fd2c0019a******:ROCKETMQ:zhang_roc" } 参数 {"name":"$.data.context.name"} 模板 My name is ${name} My name is test01 在创建事件订阅-配置事件目标，事件目标配置为“FunctionGraph（函数计算）”时，若内容转换规则配置为“透传”，无法将事件内容作为输入值传递至事件目标。如需将事件内容作为函数流输入值，可以通过“变量”或“常量”的内容转换规则，规则必须包含input字段，示例如下：表1 变量示例转换前的事件规则配置转换后的事件 { "events":[{ "id": "4b26115b-73cf74a******", "specversion": "1.0", "source": "HC.OBS", "type": "object:put", "datacontenttype": "application/json", "subject": "xxx.jpg", "time": "2022-01-17T12:07:48.955Z", "data": { "name": "test01", "state": "enable" } }] } 变量 {"data": "$.data"} 模板 {"input": ${data}} { "input": { "name": "test01", "state": "enable" } } 表2 常量示例转换前的事件规则配置转换后的事件 { "events":[{ "id": "4b26115b-73cf74a******", "specversion": "1.0", "source": "HC.OBS", "type": "object:put", "datacontenttype": "application/json", "subject": "xxx.jpg", "time": "2022-01-17T12:07:48.955Z", "data": { "name": "test01", "state": "enable" } }] } 常量 { "input": { "name": "test01" } } { "input": { "name": "test01" } }

事件网格 EG 事件规则

云服务器内容精选

事件网格 EG

7*24

备案

专业服务

退订

建议反馈

售前咨询热线