检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
方案概述 本文介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 方案架构 本实践事件订阅架构图如下所示： 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
方案概述 本文介绍如何通过事件网格服务的事件订阅和自定义目标连接功能，实现OBS桶文件进行更新或新增操作时，可将事件订阅信息上报给目标连接。 方案架构 本实践事件订阅架构图如下所示： 图1 事件订阅架构图 父主题： 基于事件订阅将OBS应用事件源消息路由至自定义目标连接
已获取操作OBS服务所需的Tenant Administrator权限。 实践流程 创建事件订阅和事件路由流程如下图所示： 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
在ECS服务器中查看事件消息 返回购买ECS服务器步骤中已打开的CloudShell终端控制台页面。 由于httpsserver.py已启动，此时CloudShell会打印出事件信息。 图1 事件消息 父主题： 实施步骤
实施步骤 创建VPC、子网和安全组 购买ECS服务器 创建OBS桶 创建目标连接 创建事件订阅 发送OBS事件 在ECS服务器中查看事件消息 父主题： 基于事件订阅将OBS应用事件源消息路由至自定义目标连接
实施步骤 创建OBS桶 购买Kafka实例 创建Kafka目标连接 创建事件订阅 发送OBS事件 查看事件消息 父主题： 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
购买Kafka实例 购买实例 登录分布式消息服务Kafka版控制台，单击页面右上方的“购买Kafka实例”。 配置如下实例参数。更多购买实例参数的详细介绍，请参考购买Kafka实例。 计费模式：按需计费 区域：与事件网格所在区域保持一致 项目：选择默认项目 可用区：根据默认项配置
查看事件消息 登录分布式消息服务Kafka版控制台，选择Kafka实例所在的区域。 在“Kafka专享版”页面，单击Kafka实例的名称“eg-kafka”，进入实例详情页面。 选择“消息查询”页签，在消息页签页面，设置查询的Topic名称“topic-eg”、分区以及查询方式。
创建Kafka目标连接 登录事件网格控制台。 在左侧导航栏选择“网络管理>目标连接”，进入“目标连接”页面。 单击“创建目标连接”，弹出“创建目标连接”对话框。 首次创建目标连接时，系统会自动弹出创建委托授权界面，需要您创建授权委托，详情请查看授权委托。 配置如下目标连接参数。更多创建
创建VPC、子网和安全组 登录虚拟私有云控制台。 左侧导航栏选择“我的VPC”，单击右上角“创建虚拟私有云”，具体配置详情请参考创建虚拟私有云和子网。 左侧导航栏选择“安全组”，单击右上角“创建安全组”，具体配置详情请参考创建安全组。同时，在“入方向规则”中请配置一条允许访问8000
创建目标连接 登录事件网格控制台。 左侧导航栏选择“网络管理 > 目标连接”，右上角单击“创建目标连接”。更多关于目标连接的详情请参考目标连接。 类型：选择“WEBHOOK”。 名称：自定义。 描述：自定义。 虚拟私有云：选择创建VPC、子网和安全组步骤中创建的VPC。 子网：选择创建
查询专业版事件流作业列表 功能介绍 查询专业版事件流作业列表 URI GET /v1/{project_id}/eventrouter/jobs 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID 表2 Query参数 参数 是否必选
表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
scene_type 是 String 场景类型，DISASTER_BACKUP：同步任务 source_config 否 EventRouterJobSource object 专业版事件流作业源端配置 sink_config 否 EventRouterJobSink object
操作专业版事件流作业 功能介绍 操作专业版事件流作业 URI POST /v1/{project_id}/eventrouter/jobs/{job_id}/action 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
查询专业版事件流作业详情 功能介绍 查询专业版事件流作业详情 URI GET /v1/{project_id}/eventrouter/jobs/{job_id} 表1 路径参数 参数 是否必选 参数类型 描述 project_id 是 String 租户资源空间ID job_id
source String 是 HC.OBS 事件源。标明事件的来源。 type String 是 object:put 事件类型。标明与事件源相关的事件类型。 datacontenttype String 否 application/json 参数“data”的内容格式。
参考创建桶，创建一个OBS桶，桶的区域与Kafka实例区域保持一致，其“桶策略”需为“公共读”或“公共读写”。 参考上传文件，在桶的根目录下上传“kafka-certs.zip”文件。 参考如下格式获取SASL证书地址: https://{bucketname}.obs.
