检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
图说ECS 立即使用 立即使用 成长地图 由浅入深,带您玩转EG 01 了解 了解事件网格的产品功能、业务使用场景和基本概念,有助于您系统性的掌握事件网格概况。 产品介绍 什么是事件网格 产品功能 应用场景 配额说明 计费说明 相关概念 02 入门 从0到1,带您快速了解事件发送流程,开启您的事件网格使用之旅。
您可以在事件订阅中通过配置事件过滤规则来筛选最终路由到事件目标的事件。 事件源产生的事件与过滤规则进行匹配,匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 关于事件过滤规则的更多信息,请参见过滤规则参数说明。
编辑自定义事件模型 自定义事件模型创建成功后,您可以根据实际需求修改自定义事件的描述信息、版本兼容方式和版本内容。 操作步骤 登录事件网格控制台。 在左侧导航栏选择“事件模型”,进入“事件模型”页面。 在“自定义事件模型”页签中,通过以下任意一种方式编辑自定义事件模型。 单击待编
获取项目ID的接口为“GET https://{Endpoint}/v3/projects”,其中{Endpoint}为IAM的终端节点,可以从地区和终端节点获取。接口的认证鉴权请参见认证鉴权。 响应示例如下,其中projects下的“id”即为项目ID。 { "projects":
String 主题 specversion 否 String 规格版本 id 是 String Id source 是 String 事件源 time 是 String 时间 type 是 String 事件类型 ttl 是 String 超时时间 dataschema 否 String 数据架构
管理自定义事件模型版本 自定义事件模型创建成功后,您可以为自定义事件模型创建新的版本、查看版本列表、查看版本内容和删除版本。 创建新版本 登录事件网格控制台。 在左侧导航栏选择“事件模型”,进入“事件模型”页面。 在“自定义事件模型”页签中,通过以下任意一种方式创建新版本。 单击
D信息找到具体的资源,然后将其删除。具体操作如下: 登录管理控制台,在顶部菜单栏中选择“费用 > 费用账单”。 图1 费用账单 选择“流水和明细账单 > 明细账单”,在如下图2所示红框位置复制资源名称。 图2 明细账单 在管理控制台左侧导航栏,选择“应用中间件 > 事件网格EG”,选择资源所在区域,然后进入资源列表。
参数类型 描述 type 是 String 队列类型 枚举值: KAFKA instance_id 是 String 实例id 最小长度:1 最大长度:128 connection_id 是 String 目标连接id 最小长度:1 最大长度:128 topic 是 String 主题
{region}.myhuaweicloud.com/kafka-certs.zip。 其中“bucketname”是桶名称,“region”是区域名称,具体地域请参考地区和终端节点。
project_id 是 String 租户项目ID subscription_id 是 String 事件订阅ID target_id 是 String 事件订阅目标ID 请求参数 表2 请求Header参数 参数 是否必选 参数类型 描述 X-Auth-Token 是 String
流服务提供SaaS应用事件或云服务事件的标准化接入。 SaaS应用/云服务将产生的事件发送到事件网格中,事件网格对事件进行校验、过滤、路由和转化,然后推送给已经订阅事件的函数,触发函数执行业务处理逻辑。 图1 函数触发器 场景二:云服务事件流转 事件网格作为华为云的标准事件中心,可以实现各个云服务之间的联动。
自定义事件发送流程 本章节介绍自定义事件发送的整个流程。 将自定义事件源产生的自定义事件发送到事件网格,事件规则对自定义事件进行过滤和转换,通过转换后的事件触发事件目标(即函数工作流服务中的函数)。 前提条件 已开通事件网格服务并授权。 已获取函数工作流的权限。 步骤一:创建自定义通道
参数类型 描述 type 是 String 队列类型 枚举值: KAFKA instance_id 是 String 实例id 最小长度:1 最大长度:128 connection_id 是 String 目标连接id 最小长度:1 最大长度:128 topic 是 String 主题
参数类型 描述 type 是 String 队列类型 枚举值: KAFKA instance_id 是 String 实例id 最小长度:1 最大长度:128 connection_id 是 String 目标连接id 最小长度:1 最大长度:128 topic 是 String 主题
ken也就是调用获取用户Token接口的响应值,该接口是唯一不需要认证的接口。 API同时支持使用AK/SK认证,AK/SK认证是使用SDK对请求进行签名,签名过程会自动往请求中添加Authorization(签名认证信息)和X-Sdk-Date(请求发送的时间)请求头。 AK/
参数类型 描述 agency_name 是 String 委托名称 id 是 String 需要翻新的触发器id transform 是 TransForm object 规则配置 表4 TransForm 参数 是否必选 参数类型 描述 type 是 String 转换规则类型 枚举值:
描述 name 是 String 目标连接名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须以字母或数字开头,不能为default 最小长度:1 最大长度:128 description 否 String 目标连接描述 最大长度:255 vpc_id 是 String 待连接的VPC
参数类型 描述 name 是 String 事件模型名称,租户下唯一,由字母、数字、点、下划线和中划线组成,必须字母或数字开头 最小长度:1 最大长度:128 description 否 String 事件模型描述 最大长度:255 compatibility 是 String 事件模型兼容性
instance_id 否 String RocketMQ实例ID group 是 String 消费组 topic 是 String Topic access_key 是 String 用户名 secret_key 是 String 密钥 vpc_id 否 String 虚拟私有云 subnet_id
Serverless版事件流”,进入“Serverless版事件流”页面。 单击“创建Serverless版事件流”,然后单击左上角图标,输入事件流名称和描述,完成后单击“确定”。 请参考配置分布式消息服务 Kafka版,配置事件源。 配置事件目标。 单击“事件目标”,右侧弹出“事件目标”弹窗。