检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
需要用户必须为函数工作流服务配置具备VPC管理权限的委托。 DNS ReadOnlyAccess 目标连接功能需要使用函数工作流服务打通用户VPC网络,需要用户必须为函数工作流服务配置具备读取云解析服务资源权限的委托。 首次创建自定义事件源“事件源类型”选择“分布式消息服务Ra
事件规则 事件流支持配置规则,默认会将消息透传至目标。 事件规则是指事件流转到事件目标之前,将CloudEvents标准事件转换成事件目标可以接受的事件类型。 事件流支持事件过滤和转换,具体规则请参考事件规则。 父主题: 事件流
事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下: 云服务事件通道:由事件网格自动创建、且不可修改的一条默认的云服务事件通道,用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道:您自行创建的事件通道,用于接收自定义事件源产生的事件。
事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下: 云服务事件通道:由事件网格自动创建、且不可修改的一条默认的云服务事件通道,用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道:您自行创建的事件通道,用于接收自定义事件源产生的事件。
您可以根据业务需要创建一个自定义事件源。 API调用方法请参考如何调用API。 前提条件 已获取IAM的Endpoint,具体请参见地区和终端节点。 已获取事件网格的Endpoint,具体请参见地区和终端节点。 创建自定义事件源 调用创建自定义事件通道接口,创建一个自定义通道。 POST
单击“创建事件路由任务”,进入创建详情页。 配置“任务基本配置”。 图2 任务基本配置 表1 任务基本配置参数说明 参数 说明 任务名称 请输入任务名称 描述 请输入对本任务的描述。 配置“源端和目标端配置”。 当源端和目标端均为Kafka时: 图3 源端和目标端配置 源端类型:Kafka 目标端类型:Kafka
单击订阅名称旁的,弹出“修改订阅”弹窗。 输入订阅名称和描述信息,单击“确定”,完成订阅名称和描述信息输入。 配置事件源。 表1 参数配置说明 参数 说明 选择提供方 请选择“华为云”。 事件源 请选择“OBS应用事件源”。 桶 请选择“选择OBS桶”。 事件类型 下拉框中事件类型根据用户需求勾选。 对象名前缀
件目标。 自定义事件源:您自定义的应用作为事件源,通过自定义的事件通道发布事件到事件网格,事件规则对事件进行过滤,然后将过滤后的事件路由到事件目标。 发布区域:华北-北京四、华东-上海一、华东-上海二 云服务事件源 创建自定义事件源 事件通道 事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下:
停用”,完成事件流状态的修改。 修改事件流的事件源 登录事件网格控制台。 在左侧导航栏选择“事件流”,进入“事件流”页面。 单击待修改事件源的事件流名称,进入事件流详情页。 单击已有事件源模块,弹出“事件源”对话框。 修改事件源配置参数。 修改事件流的事件目标 登录事件网格控制台。
源配额限制如下表所示。 表1 事件网格配额 资源名称 配额(个) 自定义事件源 100 自定义事件源-RabbitMQ 5 自定义事件源-RocketMQ 5 事件通道 10 事件订阅 20 单个事件订阅能够配置的事件目标 5 事件流 20 目标连接 3 私网访问端点 10 如果
EG自定义策略 如果系统预置的EG权限,不满足您的授权要求,可以创建自定义策略。 目前华为云支持以下两种方式创建自定义策略: 可视化视图创建自定义策略:无需了解策略语法,按可视化视图导航栏选择云服务、操作、资源、条件等策略内容,可自动生成策略。 JSON视图创建自定义策略:可以在
事件是符合特定规范的数据。事件源发布到事件网格的事件必须符合CloudEvents规范。 事件网格支持的事件如下。 华为云服务事件:华为云服务事件源产生的事件。 自定义事件:您自定义的事件源接入事件网格产生的事件。您需要自行使用SDK接入事件网格。 事件示例 事件源发布到事件网格的事件示例如下:
计算)”,规则配置参数需为JSON格式,示例如下: {"name": "test01"} test01 说明: 当事件目标为“FunctionGraph(函数计算)”,转换后的事件结果如下: {"name": "test01"} 其他示例 在创建事件订阅-配置事件源为“分布式消息
基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 方案概述 资源和成本规划 操作流程 实施步骤
更新事件订阅 √ × × √ 删除事件订阅 √ × × √ 查看事件订阅 √ × √ √ 创建自定义事件源 √ × × √ 更新自定义事件源 √ × × √ 删除自定义事件源 √ × × √ 查看事件源 √ × √ √ 创建事件通道 √ × × √ 更新事件通道 √ × × √ 删除事件通道
已开通事件网格服务并授权。 已创建虚拟私有云和子网。 已创建安全组。 实践流程 创建事件订阅和事件路由流程如下图所示: 父主题: 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版
单击待编辑自定义事件模型后的“编辑”,弹出“编辑自定义事件模型”对话框。 单击待编辑自定义事件模型的标识,进入自定义事件模型详情页。单击“编辑”,弹出“编辑自定义事件模型”对话框。 根据实际需求,修改自定义事件模型的描述信息、版本兼容方法和版本内容,单击“确定”。 父主题: 自定义事件模型
删除自定义事件模型 本章节指导您在控制台里删除自定义事件模型。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件模型”,进入“事件模型”页面。 在“自定义事件模型”页签中,通过以下任意一种方式删除自定义事件模型。 单击待删除自定义事件模型后的“删除”,弹出“删除事件模型”对话框。
管理自定义事件模型版本 自定义事件模型创建成功后,您可以为自定义事件模型创建新的版本、查看版本列表、查看版本内容和删除版本。 创建新版本 登录事件网格控制台。 在左侧导航栏选择“事件模型”,进入“事件模型”页面。 在“自定义事件模型”页签中,通过以下任意一种方式创建新版本。 单击
S应用事件源产生的事件路由至分布式消息服务Kafka版。 方案架构 本实践事件订阅架构图如下所示: 当前事件网格服务仅支持华北-北京四、华北-乌兰察布一、华东-上海一、华东-上海二、华南-广州、亚太-新加坡、拉美-墨西哥城二。 父主题: 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版