检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 方案概述 资源和成本规划 操作流程 实施步骤
基于事件订阅将OBS应用事件源消息路由至自定义目标连接 方案概述 操作流程 实施步骤
路由到对象存储服务OBS 本章节介绍在创建事件流时如何配置对象存储服务OBS为事件目标。 前提条件 已开通对象存储服务OBS作为事件目标。 事件源选择为“分布式消息服务 Kafka版”。 操作步骤 登录事件网格控制台。
obs桶管理 获取obs桶列表 翻新obs 父主题: API
创建OBS桶 登录OBS控制台。 单击“创建桶”,进入“创建桶”页面。 参考图1,设置桶参数。关于桶参数的详细介绍,请参考创建桶。
创建OBS桶 登录对象存储服务控制台。 左侧导航栏选择“桶列表”,右上角单击“创建桶”,具体配置详情请参考创建桶。 配置完成后,单击“立即创建”,完成OBS桶的创建。 父主题: 实施步骤
发送OBS事件 登录对象存储服务控制台。 左侧导航栏选择“桶列表”,单击创建OBS桶步骤中创建的桶的名称,进入对象详情页面。 在对象详情页面中,左侧导航栏选择“对象”,单击“上传对象”,弹出“上传对象”对话框。 上传一个本地已准备好的文件,单击“上传”。
发送OBS事件 在OBS管理控制台左侧导航栏选择“桶列表”。 在桶列表单击已创建的桶“eg-obs”,进入“对象”页面。 进入待上传的文件夹,单击“上传对象”,系统弹出“上传对象”对话框。 上传一个本地已准备好的文件,单击“上传”。 更多上传对象文件的方法请参考上传对象。
通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。
通过调用IAM服务获取用户Token接口获取(响应消息头中X-Subject-Token的值)。
1 00.00 对象存储服务OBS 创建一个OBS桶。 说明: 创建OBS桶免费,使用阶段请参考OBS计费说明。 1 00.00 分布式消息服务 Kafka版 购买一个Kafka实例,按需计费。
选择提供方:选择“云服务”。 事件源:选择“OBS应用事件源”。 桶:选择创建OBS桶步骤中创建的桶。 事件类型:下拉框中事件类型根据用户需求勾选。 对象名前缀:若填写,符合规范才能触发事件。默认不填写,表示全匹配。 对象名后缀:若填写,符合规范才能触发事件。
配置如下事件目标参数: 选择提供方:华为云 事件目标:分布式消息服务 Kafka版 目标连接:选择“kafka-connect” Topic:选择“topic-eg” 启用消息Key:关闭 规则配置类型:透传。配置转换规则请参考事件内容转换 单击“保存”,完成订阅的配置。
创建目标连接 登录事件网格控制台。 左侧导航栏选择“网络管理 > 目标连接”,右上角单击“创建目标连接”。更多关于目标连接的详情请参考目标连接。 类型:选择“WEBHOOK”。 名称:自定义。 描述:自定义。 虚拟私有云:选择创建VPC、子网和安全组步骤中创建的VPC。 子网:选择创建
操作流程 约束与限制 创建各服务资源时,请确保资源所在“区域”保持一致。 前提条件 已开通事件网格 EG服务并授权。 已开通对象存储 OBS服务并授权。 已开通弹性云服务器 ECS服务并授权。 已开通虚拟私有云 VPC服务并授权。
已获取操作OBS服务所需的Tenant Administrator权限。 实践流程 创建事件订阅和事件路由流程如下图所示: 父主题: 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
方案概述 本文介绍如何通过事件网格服务的事件订阅和自定义目标连接功能,实现OBS桶文件进行更新或新增操作时,可将事件订阅信息上报给目标连接。 方案架构 本实践事件订阅架构图如下所示: 图1 事件订阅架构图 父主题: 基于事件订阅将OBS应用事件源消息路由至自定义目标连接
方案概述 本文介绍如何通过事件网格服务的事件订阅功能将OBS应用事件源产生的事件路由至分布式消息服务Kafka版。 方案架构 本实践事件订阅架构图如下所示: 父主题: 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
实施步骤 创建VPC、子网和安全组 购买ECS服务器 创建OBS桶 创建目标连接 创建事件订阅 发送OBS事件 在ECS服务器中查看事件消息 父主题: 基于事件订阅将OBS应用事件源消息路由至自定义目标连接
实施步骤 创建OBS桶 购买Kafka实例 创建Kafka目标连接 创建事件订阅 发送OBS事件 查看事件消息 父主题: 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版