检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
事件流作为一种更为实时、轻量和高效的端到端的流式数据处理通道，对事件源产生的事件实时拉取、过滤及转换，并路由至事件目标。源端分布式消息Kafka版生产的消息可以通过事件流这个通道被路由到目标端的分布式消息Kafka版，无需定义事件网格。详情请参见事件流概述。 父主题： 基于Serverless版事件流实现Kafka实例之间的数据同步
入门实践 实践 描述 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 基于事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版
自定义分布式消息服务事件源功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 自定义分布式消息服务事件源功能需要使用函数工作流服务打通用户VPC网络，需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表4 响应Body参数
入，作为事件源。 支持分布式消息服务RabbitMQ版和分布式消息服务RocketMQ版作为自定义事件源。 事件目标 事件目标负责处理事件，是事件发送的终端。事件网格支持以下事件目标： 华为云服务：函数工作流 FunctionGraph/分布式消息服务 Kafka版 自定义事件目标：HTTP
本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 基于Serverless版事件流实现Kafka实例之间的数据同步 本章节介绍如何通过事件网格服务的事件流功能实现分布式消息服务Kafka版实例间的数据同步。 基于EventGrid事件订
事件源 分布式消息服务Kafka版 移动云RocketMQ版 社区版RocketMQ 分布式消息服务RocketMQ版 父主题： 事件流
nt-type对应，传递除请求消息头之外的内容。若请求消息体中参数支持中文，则中文字符必须为UTF-8编码。 每个接口的请求消息体内容不同，也并不是每个接口都需要有请求消息体（或者说消息体为空），GET、DELETE操作类型的接口就不需要消息体，消息体具体内容需要根据具体接口而定。
选择子网，需提前创建。 目标连接创建成功后，子网不支持修改。 单击“确定”，完成目标连接的创建。 创建分布式消息服务Kafka版目标连接 在创建目标连接前，已准备好分布式消息服务Kafka版实例。 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。
事件目标 路由到函数工作流 路由到分布式消息服务Kafka版 路由到对象存储服务OBS 父主题： 事件流
变量”。 类型：消息标题的类型。支持以下两种类型。 常量：将指定的常量作为消息标题。若选择常量，所有消息的消息标题都是相同的。 变量：从CloudEvents标准事件中获取变量值，将变量值代入模板中作为消息标题，如果生成的消息标题超长则会截取前512个字符。 消息标题配置非必填项，可选择填写。
Key）加密调用请求。推荐使用AK/SK认证，其安全性比Token认证要高。 约束与限制 AK/SK签名认证方式仅支持消息体大小12M以内，12M以上的请求请使用Token认证。 使用AK/SK认证时，签名SDK只提供签名功能，与服务提供的SDK不同，使用时请注意。 Token认证 Token的有效期为24小时，需
单击“创建Serverless版事件流”，然后单击左上角图标，输入事件流名称和描述，完成后单击“确定”。 请参考配置分布式消息服务 Kafka版，配置事件源。 配置事件目标。 单击“事件目标”，右侧弹出“事件目标”弹窗。 目标服务选择“FunctionGraph（函数计算）”。 设置事件目标参数。 图1 事件目标-FunctionGraph
事件规则 事件流支持配置规则，默认会将消息透传至目标。 事件规则是指事件流转到事件目标之前，将CloudEvents标准事件转换成事件目标可以接受的事件类型。 事件流支持事件过滤和转换，具体规则请参考事件规则。 父主题： 事件流
获取API版本列表 功能介绍 获取服务支持的API版本列表。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET / 请求参数 无 响应参数 状态码： 200 表1
后的事件结果如下： {"name": "test01"} 其他示例 在创建事件订阅-配置事件源为“分布式消息服务RabbitMQ版”或“分布式消息服务RocketMQ版”，消息转换为CloudEvents格式事件后，data字段下将包含context字段，在创建事件订阅-配置事件
当选择“精确匹配”时需选择“Topics”。 副本数 是。 自动创建的Topic副本数，不能超过目标端Kafka的Broker数量。 同步消费进度 是。 说明： 开启时表示将消息消费进度同步到目标Kafka。 启动偏移量 否。 压缩算法 是，可选择压缩算法为“none”、“gzip”、“snappy”、“lz4”或“zstd”。
的权限隔离。 将EG资源委托给更专业、高效的其他华为云账号或者云服务，这些账号或者云服务可以根据权限进行代运维。 如果华为云账号已经能满足您的要求，不需要创建独立的IAM用户，您可以跳过本章节，不影响您使用EG服务的其它功能。 本章节为您介绍对用户授权的方法，操作流程如图1所示。
请输入Tag。 说明： 表示订阅指定Topic下的Tags。 * 表示订阅所有消息。 TagA || TagB || TagC 表示订阅TagA或TagB或TagC的消息。 开启保存消息轨迹 请选择是否开启保存消息轨迹。 启用鉴权认证 请选择是否启用鉴权认证。 Access Key（启用鉴权认证）
云审计服务支持的EG操作列表 通过云审计服务，您可以记录与事件网格相关的操作事件，便于日后的查询、审计和回溯。 表1 云审计服务支持的事件网格操作列表 操作名称 资源类型 事件名称 创建自定义事件通道 channel CreateChannel 更新自定义事件通道 channel
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
