检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为源端实例。 原因二：目标端RocketMQ实例版本不支持，请选择符合要求的实例。 解决方式：返回配置专享版事件流作业的第二步，即“源和目标对象配置”页面，重新选择符合实例版本要求的实例作为目标端实例。
size Integer 本页数量 最小值：0 最大值：100 items Array of CatalogTargetInfo objects 对象列表 数组长度：0 - 100 表5 CatalogTargetInfo 参数 参数类型 描述 id String 事件目标分类ID name
选择已创建的集群，如未创建，请参见专享版事件流集群。 作业名称 请输入作业名称。 场景类型 当前默认为同步。 描述 请输入对本作业的描述。 单击“下一步：源和目标对象配置”，进入“源和目标对象配置”页面。 “源数据”和“目标数据”中选择好Kafka实例后，单击“测试连通性”，检查通过后，进入步骤6。 图3 源数据和目标数据配置
移动云RocketMQ版 本章节介绍在事件流里添加移动云 RocketMQ版事件源的方法。 目前支持region：上海二 前提条件 已在移动云购买RocketMQ实例。 当源端为移动云RocketMQ时，目标端只支持选择FunctionGraph（函数计算）。 创建移动云 RocketMQ版事件源
"$.data.obs.configurationId", "eTag": "$.data.obs.object.eTag", "sequencer": "$.data.obs.object.sequencer", "key": "$.data.obs.object.key"
目标连接 用户既可以通过default目标连接来连接公网webhook，也可以通过对应虚拟私有云和子网的目标连接来连接私网webhook。 支持添加分布式消息服务Kafka版作为目标连接。 Webhook就是客户端或者代理客户端提供一个webhook的url，服务器有新数据时就往
制台提供的“监控”页面来检索事件通道产生的监控指标和告警信息。 监控指标 表1 监控指标说明 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始值） pub_num 接入事件数量 该指标为单位时间通道接入事件数量 ≥ 0 事件通道 1分钟 pub_success_num
控制台提供的“监控”页面来检索事件流产生的监控指标和告警信息。 监控指标 表1 监控指标说明 指标ID 指标名称 指标含义 取值范围 测量对象 监控周期（原始值） streaming_process_num 处理事件数量 该指标为单位时间处理事件数量 ≥ 0 事件流 1分钟 streaming_success_num
用户轻松构建基于EG的业务。 表1 EG最佳实践一览表 最佳实践 说明 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 基于Serverless版事件流实现Kafka实例之间的数据同步
参考https://tools.ietf.org/html/rfc3339 subject 否 String 事件发生的主题或对象，用以标识哪个具体对象发生了当前事件 响应参数 状态码： 200 表5 响应Header参数 参数 参数类型 描述 X-Request-Id String
参考https://tools.ietf.org/html/rfc3339 subject 否 String 事件发生的主题或对象，用以标识哪个具体对象发生了当前事件 响应参数 状态码： 200 表5 响应Header参数 参数 参数类型 描述 X-Request-Id String
创建事件路由 事件路由概述 事件路由基于SmartConnect实现能力同步数据的同步。 前提条件 业务有自己的源kafka和目标kafka。 需要给EG授权，第一次进入EG时，会自动为用户创建名为EG_EVENT_ROUTER_AGENCY的授权。 确保vpc、子网、kafka等资源充足。
在实例“基本信息>连接信息”页面，单击SSL证书旁的“下载”。 SSL证书将会下载到本地电脑，名字为“kafka-certs.zip”的文件。 参考创建桶，创建一个OBS桶，桶的区域与Kafka实例区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 最新版的事件流支持私有桶获取证书。 参考上传文件，在
管理项目和企业项目 创建项目并授权 创建项目 进入管理控制台页面，单击右上方的用户名，在下拉列表中选择“统一身份认证”，进入统一身份认证服务页面。选择左侧导航中的“项目”，单击“创建项目”，选择区域并输入项目名称。 授权 通过为用户组授予权限（包括资源集和操作集），实现项目和用户
包括查询单个函数的EG触发器、查询单个函数流的EG触发器。 访问端点管理 包括更新访问端点、删除访问端点、创建访问端点、查询访问端点。 obs桶管理 包括获取obs桶列表。 监控指标管理 包括查询事件通道监控指标数据、查询事件订阅监控指标数据。 事件流管理 包括创建事件流、查询事件流列表、
最大长度：16384 表3 请求Body参数 参数 是否必选 参数类型 描述 subscription_ids 否 Array of strings 订阅对象ID列表，单次批量操作最多支持10个订阅 数组长度：1 - 10 operation 否 String 操作类型 枚举值： DISABLE
最大值：100 size Integer 本页数量 最小值：0 最大值：100 items Array of EndpointInfo objects 对象列表 数组长度：0 - 100 表6 EndpointInfo 参数 参数类型 描述 id String 访问端点ID name String
Integer 本页数量 最小值：0 最大值：100 items Array of CustomizeSourceInfo objects 对象列表 数组长度：0 - 100 表5 CustomizeSourceInfo 参数 参数类型 描述 id String 事件源ID name
事件轨迹详情 功能介绍 事件轨迹详情，展示事件源到投递目标的投递情况。 调试 您可以在API Explorer中调试该接口，支持自动认证鉴权。API Explorer可以自动生成SDK代码示例，并提供SDK代码示例调试功能。 URI GET /v1/{project_id}/ev
size Integer 本页数量 最小值：0 最大值：100 items Array of SubscriptionInfo objects 对象列表 数组长度：0 - 100 表5 SubscriptionInfo 参数 参数类型 描述 id String 订阅ID name String
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
