事件网格 EG-华为云

事件网格 EG-授权委托:委托场景

委托场景首次创建目标连接时，系统会自动弹出创建委托授权界面，同意授权后，EG将在统一身份认证服务为您创建名为EG_DELEGATE_FG_AGENCY的委托。授权成功后，您可以在 IAM 控制台的委托列表中查看已创建的委托。表2 EG_DELEGATE_FG_AGENCY的委托权限权限名称描述 VPC Administrator 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。首次创建自定义事件源“事件源类型”选择“分布式消息服务RabbitMQ版”或“分布式消息服务RocketMQ版”时，系统会自动弹出创建委托授权界面，同意授权后，EG将在统一身份认证服务为您创建名为EG_DELEGATE_FG_AGENCY和EG_AGENCY的委托。授权成功后，您可以在IAM控制台的委托列表中查看已创建的委托。表3 EG_DELEGATE_FG_AGENCY和EG_AGENCY的委托权限权限名称描述 VPC Administrator 自定义分布式消息服务事件源功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 自定义分布式消息服务事件源功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 EG Publisher 自定义分布式消息服务事件源功能需要将消费到的消息发布事件到事件通道，需要用户必须为事件网格服务配置具备事件发布权限的委托。

事件网格 EG

事件网格 EG-入门实践

入门实践当您购买了事件网格后，可通过华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助您轻松构建松耦合、分布式的事件驱动架构。本文介绍事件网格服务的常见实践，帮助您更好的使用事件网格服务。表1 入门实践实践描述基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版基于事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版

事件网格 EG

事件网格 EG-按需计费:计费周期

计费周期华为云事件网格EG按照实际使用量付费，没有最低消费。计费模式采用累计分档计费，按天结算，即每日3点后对前一日使用量进行扣费。例如，2023-05-11 00:00:00至2023-05-11 23:59:59期间产生的费用，通常会在2023-05-12 03:00:00左右完成扣费。标准计费：根据使用时长（次数，量）“单位价格”计算出价格后，截取到“分”扣费。阶梯计费：例如对象存储，根据“使用量”单位价格“时长”计算出价格后，截取到“分”扣费。在按需付费模式下，价格计算器上的金额如果遇小数点，则保留小数点后两位，第三位四舍五入。如遇四舍五入后不足￥0.01 ，则按￥0.01 展示。

事件网格 EG 计费模式

事件网格 EG-创建OBS桶

创建OBS桶登录OBS控制台。单击“创建桶”，进入“创建桶”页面。参考图1，设置桶参数。关于桶参数的详细介绍，请参考创建桶。区域：与事件网格所在区域保持一致桶名称：输入示例如“eg-obs” 默认存储类别：选择“标准存储” 桶策略：选择“私有” 默认加密：不勾选归档数据直读：选择“关闭” 企业项目：选择“default” 图1 创建桶配置完成后，单击“立即创建”，根据提示信息完成桶的创建。父主题：实施步骤

事件网格 EG

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

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

事件网格 EG

事件网格 EG-查看事件消息

查看事件消息登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。单击“搜索”，查询消息。单击“查看消息正文”，弹出“查看消息正文”对话框，查看消息的具体内容。图1 事件消息父主题：实施步骤

事件网格 EG

事件网格 EG-资源和成本规划

资源和成本规划本实践涉及到的资源和成本规划，如下表所示。表1 资源和成本规划资源资源说明数量费用（元）虚拟私有云VPC 创建一个虚拟私有云VPC。 1 00.00 虚拟私有云子网创建一个虚拟私有云子网。 1 00.00 安全组创建一个安全组。 1 00.00 对象存储服务 OBS 创建一个OBS桶。说明：创建OBS桶免费，使用阶段请参考OBS计费说明。 1 00.00 分布式消息服务 Kafka版购买一个Kafka实例，按需计费。 1 例如：kafka.2u4g.cluster 4.35元/小时事件网格EventGrid 创建一个事件订阅，事件源为OBS应用事件源，事件目标为分布式消息服务Kafka版。创建一个目标连接，类型为“分布式消息服务 Kafka版”。 1 00.00 本文提供的成本预估费用仅供参考，资源的实际费用以华为云管理控制台显示为准。父主题：基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版

事件网格 EG 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版

事件网格 EG-购买Kafka实例:购买实例

购买实例登录分布式消息服务Kafka版控制台，单击页面右上方的“购买Kafka实例”。配置如下实例参数。更多购买实例参数的详细介绍，请参考购买Kafka实例。计费模式：按需计费区域：与事件网格所在区域保持一致项目：选择默认项目可用区：根据默认项配置实例名称：输入“eg-kafka” 企业项目：选择“default” 规格类型：默认版本：3.x CPU架构：x86计算代理规格：kafka.2u4g.cluster.small 代理数量：配置为“3” 存储空间：高I/O，100GB 磁盘加密：关闭容量阈值策略：自动删除虚拟私有云：vpc-default/subnet-default，此处选择前提条件中已准备好的vpc-default 安全组：default，此处选择前提条件中已准备好的安全组default “更多配置”中配置如下参数： Kafka SASL_SSL：开启 kafka安全协议：SASL_SSL SASL PLAIN 机制：开启用户名：kafka-name 密码：填写密码默认密码：确认密码单击“立即购买”，完成Kafka实例的创建。

事件网格 EG

事件网格 EG-购买Kafka实例:创建Topic

创建Topic 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。在“Kafka专享版”页面，单击已创建的Kafka实例的名称，进入实例详情页面。在“Topic管理”页签，单击“创建Topic”，弹出“创建Topic”对话框。参考图1配置Topic参数，Topic名称配置为“topic-eg”，其他参数保持默认即可。更多创建Topic参数的详细介绍，请参考创建Topic。图1 创建Topic 单击“确定”，完成创建Topic。

事件网格 EG

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

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

事件网格 EG

事件网格 EG-创建OBS源桶和目标桶

创建OBS源桶和目标桶登录OBS控制台。单击“创建桶”，进入“创建桶”页面。设置桶参数。关于桶参数的详细介绍，请参考创建桶。表1 桶参数配置参数说明区域事件网格与所在区域保持一致。桶名称输入示例如“eg-test”。默认存储类别按需选择。桶策略按需选择。默认加密按需选择。归档数据直读按需选择。企业项目按需选择。图1 桶参数配置配置完成后，单击“立即创建”，根据提示信息完成桶的创建。以上述流程构建源桶与目标桶。父主题：实施步骤

事件网格 EG 实施步骤

事件网格 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-实施及验证:目标端配置操作步骤

目标端配置操作步骤登录事件网格控制台。在左侧导航栏选择“事件流”，进入“事件流”页面。单击“创建事件流”。配置事件目标。单击“事件目标”，右侧弹出“事件目标”弹窗。目标服务选择“分布式消息服务 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-跨账号事件发送流程:步骤四：在账号B中创建订阅去处理目标通道的事件

步骤四：在账号B中创建订阅去处理目标通道的事件登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”。单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。提供方选择“自定义”。通道：选择账号A创建的通道。事件源：输入账号A创建的事件源（与账号A的订阅的事件源保持一致）。图5 事件源配置单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”（此处目标以函数为例）。提供方选择“华为云”。事件目标：选择FunctionGraph（函数计算）。函数：选择函数。版本：选择版本。委托：选择委托。类型：选择透传、变量或常量。图6 事件目标配置图7 生成的订阅全量配置方式可参考《创建事件订阅》。进入目标通道的事件轨迹页面，查看投递状态。图8 投递状态投递状态显示“投递成功”，跨账号事件发送成功。

事件网格 EG

事件网格 EG-跨账号事件发送流程:步骤二：在账号A下创建事件订阅

步骤二：在账号A下创建事件订阅登录事件网格控制台。在左侧导航栏选择“事件订阅”，进入“事件订阅”页面。单击“创建事件订阅”。单击“事件源”，在配置弹窗进行配置，配置完成单击“确定”。提供方选择“华为云”。事件源：选择消息通知 SMN。单击“事件目标”，在配置弹窗进行配置，配置完成单击“确定”。提供方选择“华为云”。事件目标：选择事件网格EG。目标类型：选择跨账号。项目ID：项目ID填写账号B同地域下的项目ID。通道：选择账号B创建的通道。委托：选择带有事件发送权限的委托。图2 配置事件目标创建成功后，单击“保存”。

事件网格 EG

云服务器内容精选

事件网格 EG

7*24

备案

专业服务

退订

建议反馈

售前咨询热线