检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
购买ECS服务器 登录弹性云服务器控制台。 左侧导航栏选择“弹性云服务器”，右上角单击“购买弹性云服务器”，具体配置详情请参考快速购买和使用ECS。虚拟私有云和安全组请选择创建VPC、子网和安全组步骤中创建VPC、子网和安全组。 返回至弹性云服务器列表，在操作列单击“远程登录”。
查看事件消息 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。
创建VPC、子网和安全组 登录虚拟私有云控制台。 左侧导航栏选择“我的VPC”，单击右上角“创建虚拟私有云”，具体配置详情请参考创建虚拟私有云和子网。 左侧导航栏选择“安全组”，单击右上角“创建安全组”，具体配置详情请参考创建安全组。同时，在“入方向规则”中请配置一条允许访问8000
购买Kafka实例 购买实例 登录分布式消息服务Kafka版控制台，单击页面右上方的“购买Kafka实例”。 配置如下实例参数。更多购买实例参数的详细介绍，请参考购买Kafka实例。 计费模式：按需计费 区域：与事件网格所在区域保持一致 项目：选择默认项目 可用区：根据默认项配置
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更多创建
在ECS服务器中查看事件消息 返回购买ECS服务器步骤中已打开的CloudShell终端控制台页面。 由于httpsserver.py已启动，此时CloudShell会打印出事件信息。 图1 事件消息 父主题： 实施步骤
华为云对象存储服务（Object Storage Service，简称OBS）作为云服务事件源将产生的云服务事件发送到事件网格，事件规则对云服务事件进行过滤和转换，通过转换后的事件触发事件目标（即函数工作流服务中的函数）。 前提条件 已开通事件网格服务并授权。
表4 请求Body参数 参数 是否必选 参数类型 描述 cluster_id 是 String 集群ID source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink
scene_type 是 String 场景类型，DISASTER_BACKUP：同步任务 source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink object
删除专业版事件流作业 功能介绍 删除专业版事件流作业 URI DELETE /v1/{project_id}/eventrouter/jobs/{job_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
查询专业版事件流作业列表 功能介绍 查询专业版事件流作业列表 URI GET /v1/{project_id}/eventrouter/jobs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID 表2 Query参数 参数 是否必选
操作专业版事件流作业 功能介绍 操作专业版事件流作业 URI POST /v1/{project_id}/eventrouter/jobs/{job_id}/action 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
scene_type 是 String 场景类型，DISASTER_BACKUP：同步任务 source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink object
查询专业版事件流作业详情 功能介绍 查询专业版事件流作业详情 URI GET /v1/{project_id}/eventrouter/jobs/{job_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
查看专业版事件流作业同步情况 功能介绍 查看专业版事件流作业同步情况 URI POST /v1/{project_id}/eventrouter/jobs/{job_id}/syncDetail 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String
如下表所示，过滤规则匹配“source”为“HC.OBS”的事件。
", "eTag": "$.data.obs.object.eTag", "sequencer": "$.data.obs.object.sequencer", "key": "$.data.obs.object.key", "size": "$.data.obs.object.size
请检查证书下载地址 400 EGS.00516012 Download OBS file failed. 下载OBS文件失败。 请联系管理员 400 EGS.00516013 Upload file to OBS failed. 文件上传OBS失败。
表1 EG最佳实践一览表 最佳实践 说明 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 本章节介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。
图2 云服务事件源配置参数 如果“事件源”选择“OBS应用事件源”，请参考表2。同时，需用户的华为云账号添加“Tenant Administrator”权限，如何授权请参见依赖角色的授权方法。 表2 OBS应用事件源参数说明 参数名称 说明 事件源 选择事件源。
