检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
已创建虚拟私有云和子网。 已创建安全组。 实践流程 创建事件订阅和事件路由流程如下图所示： 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助您轻松构建松耦合、分布式的事件驱动架构。 使用条件 已注册华为账号并开通华为云。 当前登录账号拥有使用事件网格的权限。账号权限授权与绑定，请参考创建用户并授权使用EG。
查看事件消息 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。
您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更多创建Kafka目标连接参数的详细介绍，请参考创建目标连接。 类型：选择“分布式消息服务 Kafka版” 名称：kafka-connect 实例：选择“eg-kafka” SASL_SSL 认证机制：SCRAM-SHA-512
过滤规则：根据默认值配置，无需修改。配置过滤规则请参考过滤规则参数说明。 配置事件目标。 配置如下事件目标参数： 选择提供方：华为云 事件目标：分布式消息服务 Kafka版 目标连接：选择“kafka-connect” Topic：选择“topic-eg” 启用消息Key：关闭 规则配置
角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“FunctionGraph（函数计算）”。 设置事件目标参数。 图1 事件目标-FunctionGraph
SDK和API。 高并发&高可用 支持千万级事件并发。 服务可用性99.99%，采用分布式集群化部署，具备极强的容灾能力。 安全可靠 对接统一身份认证服务、云日志服务、云监控服务和云审计服务等安全管理服务，全方位保护事件的存储与访问。 持久化数据支持磁盘和用户指定密钥加密，进一步提高数据的安全性。
发送OBS事件 在OBS管理控制台左侧导航栏选择“桶列表”。 在桶列表单击已创建的桶“eg-obs”，进入“对象”页面。 进入待上传的文件夹，单击“上传对象”，系统弹出“上传对象”对话框。 上传一个本地已准备好的文件，单击“上传”。 更多上传对象文件的方法请参考上传对象。 图1 上传对象
墨西哥城二。 前提条件 进行本实践操作需要提前完成的事项： 已开通事件网格服务并授权。 已创建虚拟私有云和子网。 已创建安全组。 已购买分布式消息服务RocketMQ实例。 已创建函数，函数以Python3.9运行时为例介绍。 创建Serverless版事件流 登录事件网格控制台，左侧导航栏选择“事件流
单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“分布式消息服务 Kafka版”。 设置事件目标参数。 图2 分布式消息服务 Kafka版 表2 分布式消息服务Kafka版参数说明 参数名称 说明 目标连接 选择目标连接。如果还未创建目标连接，请先创建分布式消息服务Kafka版目标连接。 Topic
选择创建的函数，单击进入函数详情页。 选择“设置 > 触发器”，单击“创建触发器”，弹出“创建触发器”对话框。 图3 创建触发器 设置以下信息。 触发器类型：选择“分布式消息服务（Kafka）”。 实例：选择与死信队列相同的Kafka实例。 主题：选择与死信队列相同的Topic。 批处理大小：每次从Topic消费的消息数量，建议设置为10。
前提条件 已开通事件网格服务并授权。 已购买Kafka实例。 已创建分布式消息Kafka版类型的目标连接，具体方式请参考目标连接。 单条消息不超过256KB。 公测期间无商用SLA承诺。 当前暂不支持跨Region、Kafka-OBS（规划中）。 云上云下、跨云厂商需用户侧拉专线。
子网 选择子网，需提前创建。 目标连接创建成功后，子网不支持修改。 单击“确定”，完成目标连接的创建。 创建分布式消息服务Kafka版目标连接 在创建目标连接前，已准备好分布式消息服务Kafka版实例。 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。
1.4。 前提条件 已有社区版RocketMQ集群实例。 当源端为社区版RocketMQ时，目标端只支持选择FunctionGraph（函数计算）。 创建社区版RocketMQ事件源 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，进入“Serverless版事件流”页面。
目前支持region：上海二 前提条件 已在移动云购买RocketMQ实例。 当源端为移动云RocketMQ时，目标端只支持选择FunctionGraph（函数计算）。 创建移动云 RocketMQ版事件源 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”，进入“Serverless版事件流”页面。
事件目标 路由到函数工作流 路由到分布式消息服务Kafka版 路由到对象存储服务OBS 父主题： 事件流
以标准化、中心化的方式接入事件网格，通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件，帮助您轻松构建松耦合、分布式的事件驱动架构。 文档 图说ECS 立即使用 立即使用 成长地图 由浅入深，带您玩转EG 01 了解 了解事件网格的产品功能、业务使用场景和基本
华为云服务事件源：华为云服务作为事件源，华为云服务包含弹性云服务器、对象存储服务和云容器引擎等等。 自定义事件源： 支持自定义应用通过事件网格提供的SDK接入，作为事件源。 支持分布式消息服务RabbitMQ版和分布式消息服务RocketMQ版作为自定义事件源。 事件目标 事件目标负责
DLV NAT网关 NAT 云桌面 Workspace 设备接入服务 IoTDA 分布式消息服务 DMS 知识图谱 KG IoT边缘 IoTEdge 云日志服务 LTS 编译构建 CloudBuild 对象存储迁移服务 OMS 云备份服务 CBR 消息&短信服务 MSGSMS 弹性公网IP
${name} 当事件目标为“FunctionGraph（函数计算）”，模板需为JSON格式，示例如下： {"name":"${name}"} My name is test01 说明： 当事件目标为“FunctionGraph（函数计算）”，转换后的事件结果如下： {"name": "test01"}
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
