检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
续请求，服务器可能会关闭连接。如果只是服务器暂时无法处理，则会包含一个Retry-After的响应信息。 414 Request-URI Too Large 请求的URI过长（URI通常为网址），服务器无法处理。 415 Unsupported Media Type 服务器无法处理请求附带的媒体格式。
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型
单击“下一步：高级配置”，进入“高级配置”页面。 图4 高级配置 RocketMQ同步事件流当前仅支持同步普通消息和顺序消息。若您配置Topic的消息类型是其它类型时，则该消息类型的Topic消息将不会被同步。 表3 作业对象配置参数说明 参数 说明 Topic匹配类型 选择“正则匹配”或“精确匹配”。
创建Kafka实例时的Topic。 分区数 创建Topic时设置的分区数，分区数越大消费的并发度越大。 待同步数 当前Topic分区数中未同步的消息数量。 同步速率：当前作业同步消息时的速率，单击“限流”可跳转至源端Kafka实例的“流控列表”页面，用户可通过配置流控进而实现限流目的。 父主题： 创建专享版事件流作业
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表3 响应Body参数
东-上海二 云服务事件源 创建自定义事件源 事件通道 事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下： 云服务事件通道：由事件网格自动创建、且不可修改的一条默认的云服务事件通道，用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定
请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表4 响应Body参数
String 用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型 描述 type 是 String 服务委托应用场景类型 枚举值： TARGET_CONNECTION
用户Token。通过调用IAM服务获取用户Token接口获取（响应消息头中X-Subject-Token的值）。 最小长度：1 最大长度：16384 响应参数 状态码： 200 表4 响应Body参数 参数 参数类型 描述 agencies Array of strings 服务委托授权记录。 状态码：
查看事件消息 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。
云审计服务支持的EG操作列表 通过云审计服务，您可以记录与事件网格相关的操作事件，便于日后的查询、审计和回溯。 表1 云审计服务支持的事件网格操作列表 操作名称 资源类型 事件名称 创建自定义事件通道 channel CreateChannel 更新自定义事件通道 channel
基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 方案概述 资源和成本规划 操作流程 实施步骤
方案概述 本文介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 方案架构 本实践事件订阅架构图如下所示： 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。
服务委托管理 查询服务委托 创建服务委托 父主题： API
误。 配置事件目标。 配置如下事件目标参数： 选择提供方：华为云 事件目标：分布式消息服务 Kafka版 目标连接：选择“kafka-connect” Topic：选择“topic-eg” 启用消息Key：关闭 规则配置类型：透传。配置转换规则请参考事件内容转换 单击“保存”，完成订阅的配置。
表1 云服务事件模型列表 标识 事件源 格式 描述 MRS:Cluster:JobAction MapReduce服务 MRS OPENAPI 3.0 MRS作业事件，仅限页面或API提交的作业。 MRS:Cluster:OperationAction MapReduce服务 MRS
创建OBS桶 登录OBS控制台。 单击“创建桶”，进入“创建桶”页面。 参考图1，设置桶参数。关于桶参数的详细介绍，请参考创建桶。 区域：与事件网格所在区域保持一致 桶名称：输入示例如“eg-obs” 默认存储类别：选择“标准存储” 桶策略：选择“私有” 默认加密：不勾选 归档数据直读：选择“关闭”
授权委托，详情请查看授权委托。 配置如下目标连接参数。更多创建Kafka目标连接参数的详细介绍，请参考创建目标连接。 类型：选择“分布式消息服务 Kafka版” 名称：kafka-connect 实例：选择“eg-kafka” SASL_SSL 认证机制：SCRAM-SHA-512
云审计服务支持的关键操作 云审计服务支持的EG操作列表 在CTS事件列表查看云审计事件
开通事件网格服务并授权 使用事件网格服务前，您需要： 已注册华为账号并开通华为云。 当前登录账号拥有使用事件网格的权限。账号权限授权与绑定，请参考创建用户并授权使用EG。 如果您的账号为IAM用户，请先联系华为云账号拥有者为IAM用户授权，然后才能使用事件网格服务。 登录事件网格控制台
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
