检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
事件通道概述 事件通道负责接收来自事件源的事件。 事件网格支持的事件通道如下: 云服务事件通道:由事件网格自动创建、且不可修改的一条默认的云服务事件通道,用于接收云服务事件源产生的事件。云服务事件源产生的事件只能发布到云服务事件通道。 自定义事件通道:您自行创建的事件通道,用于接收自定义事件源产生的事件。
路由到函数工作流 本章节介绍在创建事件流时如何配置函数工作流 FunctionGraph为事件目标。 前提条件 已开通FunctionGraph并创建函数作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”,进入“Serverless版事件流”页面。
事件订阅将事件源、事件通道和事件目标绑定在一起,通过事件规则将事件源发出的事件路由到事件目标。 约束与限制 一个订阅最多关联五个事件目标。 同一个事件在EG通道内传递的次数不能超过三次。 前提条件 (可选)已创建自定义事件源。 已设置事件目标。 已创建企业项目,如何创建请参见管理项目和企业项目。
息。 登录事件网格控制台。 在左侧导航栏选择“网络管理>访问端点”,进入“访问端点”页面。 在待修改描述信息的访问端点所在行,单击“编辑”,进入“编辑访问端点”对话框。 修改描述信息,单击“确定”,完成修改。 删除私网访问端点 登录事件网格控制台。 在左侧导航栏选择“网络管理>访问端点”,进入“访问端点”页面。
可视化视图创建自定义策略:无需了解策略语法,按可视化视图导航栏选择云服务、操作、资源、条件等策略内容,可自动生成策略。 JSON视图创建自定义策略:可以在选择策略模板后,根据具体需求编辑策略内容;也可以直接在编辑框内编写JSON格式的策略内容。 具体创建步骤请参见创建自定义策略。本章为您介绍常用的EG自定义策略样例。
路由到对象存储服务OBS 本章节介绍在创建事件流时如何配置对象存储服务OBS为事件目标。 前提条件 已开通对象存储服务OBS作为事件目标。 事件源选择为“分布式消息服务 Kafka版”。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverless版事件流”
事件通道后的“编辑”,在弹出的对话框中编辑描述信息。 如果需要查看自定义事件通道的信息,单击待查看信息的事件通道名称,在弹出的对话框中查看自定义事件通道信息。 删除自定义事件通道 登录事件网格控制台。 在左侧导航栏选择“事件通道”,进入“事件通道”页面。 在待删除的自定义事件通道
路由到分布式消息服务Kafka版 本章节介绍在创建事件流时如何配置分布式消息Kafka为事件目标。 约束与限制 事件目标kafka不支持自定义证书。 前提条件 已开通分布式消息Kafka作为事件目标。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件流 > Serverle
分布式消息服务Kafka版 本章节介绍在创建事件流时,如何配置分布式消息服务Kafka版实例为事件源。 前提条件 已在分布式消息服务Kafka版中购买Kafka实例,详情请参见购买Kafka实例。 Kafka实例中的安全组在“入方向规则”中放开Kafka实例的子网网段和端口,详情
而得到Schema。 这两种事件模型都存储在Schema注册表中,事件目标可以从Schema注册表中获取事件Schema的定义,实现快速访问事件。 事件网格的Schema遵循OpenSchema规范。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件模型”,进入“事件模型”页面。
分布式消息服务RocketMQ版 本章节介绍在事件流里添加分布式消息服务RocketMQ版事件源的方法。 前提条件 已在分布式消息服务RocketMQ版中购买RocketMQ实例。 当源端为分布式消息服务RocketMQ版时,目标端只支持选择FunctionGraph(函数计算)。
登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。 在待修改描述信息的订阅所在行,单击“配置”,进入订阅详情页。 单击订阅名称旁的编辑图标,弹出“修改订阅”弹窗。 修改描述信息,单击“确定”,完成修改。 修改订阅的状态 登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。
事件 事件是符合特定规范的数据。事件源发布到事件网格的事件必须符合CloudEvents规范。 事件网格支持的事件如下。 华为云服务事件:华为云服务事件源产生的事件。 自定义事件:您自定义的事件源接入事件网格产生的事件。您需要自行使用SDK接入事件网格。 约束与限制 单事件大小限制:64K。
启用死信队列后EG会把处理失败的事件发送到配置的队列中,若不启用则处理失败的事件将被丢弃。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件订阅”,进入“事件订阅”页面。 单击“创建事件订阅”。 单击“事件目标”。 在弹窗中选择“事件目标”。 启用“死信队列”,并配置参数。 图1 配置死信队列 表1 死信队列参数说明
单击“立即购买”,完成Kafka实例的创建。 创建Topic 登录分布式消息服务Kafka版控制台,选择Kafka实例所在的区域。 在“Kafka专享版”页面,单击已创建的Kafka实例的名称,进入实例详情页面。 在“Topic管理”页签,单击“创建Topic”,弹出“创建Topic”对话框。 参考图1配置Top
当前登录账号拥有使用事件网格的权限。账号权限授权与绑定,请参考创建用户并授权使用EG。 登录事件网格控制台 登录华为云控制台。 单击,选择区域。 单击左上角,在服务列表选择“事件网格 EG”,进入事件网格服务控制台。 图1 事件网格服务控制台
计费说明 约束与限制 华为云服务事件源自身产生发布的事件(任意事件状态变化 )免费,事件消费免费。 计费项 事件网格根据自定义事件或三方事件流入的事件数量进行计费。具体收费介绍,请参考价格详情。 表1 EG计费项 计费项 计费说明 自定义(包含云服务租户侧事件产生 )或三方事件流入的事件数量
s Java SDK发布事件。 前提条件 获取并安装IntelliJ IDEA,如果未安装,请至IntelliJ IDEA官方网站下载。 在pom.xml中加入依赖。如何在Java环境中集成API请求签名的SDK请参考AK/SK签名认证操作指导。 <dependency>
户就可以基于被授予的权限对云服务进行操作。 事件网格部署时通过物理区域划分,为项目级服务。授权时,“作用范围”需要选择“区域级项目”,然后在指定区域(如华北-北京1)对应的项目(cn-north-1)中设置相关权限,并且该权限仅对此项目生效;如果在“所有项目”中设置权限,则该权限
实施步骤 创建OBS源桶和目标桶 创建FG函数 创建EG事件订阅 发送OBS事件 在事件追踪中查看事件投递信息 在函数服务的监控中查看代码执行详情 在OBS目标桶查看对象是否已完成同步 父主题: 基于EventGrid事件订阅和Function实现OBS桶数据同步