检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
云搜索服务 CSS 视频分析服务 VAS 数据管理服务 DAS 裸金属服务器 BMS 云测 CloudTest VPC终端节点 VPCEP 云存储网关服务 CSG 虚拟专用网络 VPN 企业路由器 ER 推荐系统 RES 云服务器备份服务 CSBS 内容分发网络服务 CDN 容器安全服务 CGS
已开通事件网格服务并授权。 已开通函数服务并授权。 已开通OBS服务并授权。 已在OBS开通白名单(联系OBS服务)。 实践流程 创建事件订阅和事件路由流程如下图所示: 图1 流程图 父主题: 基于EventGrid事件订阅和Function实现OBS桶数据同步
透传:事件网格不对事件进行转换,将CloudEvents标准事件直接路由到事件目标。 变量:从CloudEvents标准事件中获取变量值,将变量值路由到事件目标。 常量:事件只能触发事件目标,但是不会传送事件内容到事件目标,事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。
事件流作为一种更为实时、轻量和高效的端到端的流式数据处理通道,对事件源产生的事件实时拉取、过滤及转换,并路由至事件目标。源端分布式消息Kafka版生产的消息可以通过事件流这个通道被路由到目标端的分布式消息Kafka版,无需定义事件网格。详情请参见事件流概述。 父主题: 基于Serve
如何过滤最终传输到事件目标的事件? 您可以在事件订阅中通过配置事件过滤规则来筛选最终路由到事件目标的事件。 事件源产生的事件与过滤规则进行匹配,匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 关于事件过滤规则的更多信息,请参见过滤规则参数说明。
透传:事件网格不对事件进行转换,将CloudEvents标准事件直接路由到事件目标。 变量:从CloudEvents标准事件中获取变量值,将变量值路由到事件目标。 常量:事件只能触发事件目标,但是不会传送事件内容到事件目标,事件网格将您设置的常量路由到事件目标。 如果需要了解更多转换类型的信息,请参考事件内容转换。
网格对事件进行校验、过滤、路由和转化,然后推送给已经订阅事件的函数,触发函数执行业务处理逻辑。 图1 函数触发器 场景二:云服务事件流转 事件网格作为华为云的标准事件中心,可以实现各个云服务之间的联动。 云服务作为事件源或者事件目标部署在华为云的无服务器(Serverless)应
Serverless版事件流概述 事件流对事件源产生的事件实时拉取、过滤及转换,并路由至事件目标,是一种更为实时、轻量和高效的端到端的流式数据处理场景。 图1 事件流示意图 EG事件流目前处于公测阶段,欢迎您试用和体验相关的功能。 父主题: 事件流
oudEvents协议在这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。 本文介绍事件网格服务的常见实践,帮助您更好的使用事件网格服务。 表1 入门实践 实践 描述 基于事件订阅将OBS应用事件源消息路由至分布式消息服务Kafka版 基于事件网格服务的
事件的处理终端,负责消费事件。 事件通道 事件的中转站,负责接收来自事件源的事件。 事件规则 事件发送到事件网格后,会根据事件规则进行过滤,满足规则的事件才会被路由发送到对应的事件目标。
这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。 图1 事件网格总体架构示意图 事件源:将华为云服务、自定义应用、SaaS应用等应用程序产生的事件消息发布到事件订阅。 事件订阅:存储接收到的事件消息,并根据事件规则将事件消息路由到事件目标。 事件模型:
支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格,通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。 本文档提供了事件网格API的描述、语法、参数说明及样例等内容。 事件网格持续增加新的功
支持华为云服务、自定义应用、SaaS应用以标准化、中心化的方式接入事件网格,通过标准化的CloudEvents协议在这些应用之间以灵活方式路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。 使用条件 已注册华为账号并开通华为云。 当前登录账号拥有使用事件网格的权限。账号权限授
事件规则对事件进行过滤,然后将过滤后的事件路由到事件目标。华为云支持的云服务事件源列表,请参见云服务事件源。 自定义事件源 您自定义的应用作为事件源,通过自定义的事件通道发布事件到事件网格,事件规则对事件进行过滤,然后将过滤后的事件路由到事件目标。 支持分布式消息服务Rabbit
事件目标 路由到函数工作流 路由到分布式消息服务Kafka版 路由到对象存储服务OBS 父主题: 事件流
当数据发送到死信队列后,您可以参考以下方法,来处理死信数据。 登录函数工作流控制台,在左侧的导航栏选择“函数 > 函数列表”。 单击右上方的“创建函数”,进入“创建函数”页面,具体创建步骤请参考创建事件函数。 图2 函数列表 选择创建的函数,单击进入函数详情页。 选择“设置 > 触发器”,单击“
按需计费是一种先使用再付费的计费模式,适用于无需任何预付款或长期承诺的用户。本文将介绍按需计费EG的计费规则。 适用场景 按需计费适用于事件网格对事件进行过滤、路由和转化。 适用计费项 事件网格实际费用是由事件流入的数量构成,计费项按需计费说明请参见表1。 表1 计费项说明 计费项 说明 请求次数 在
事件规则概述 事件规则用于过滤和转换事件。 过滤:事件网格在事件订阅中通过配置过滤规则过滤事件,并将过滤后的事件路由到事件目标。关于过滤规则的更多信息,请参考过滤规则参数说明和过滤规则示例。 转换:事件网格在事件订阅中通过配置类型对事件内容进行转换,将CloudEvents标准事
过滤规则参数说明 事件源产生的事件与过滤规则进行匹配,匹配成功后事件才会被路由到与过滤规则关联的事件目标。过滤规则必须和匹配的事件具有相同的结构。 本章节介绍过滤规则和事件匹配时的规则,以及构成过滤规则的参数:运算操作符、条件表达式和匹配字段。 匹配规则 过滤规则和事件匹配时,需要遵循以下规则:
生产顺序性和消费顺序性组合 生产顺序 消费顺序 顺序性效果 设置消息组,保证消息顺序发送。 顺序消费 按照消息组粒度,严格保证消息顺序。 同一消息组内的消息的消费顺序和发送顺序完全一致。 设置消息组,保证消息顺序发送。 并发消费 并发消费,尽可能按时间顺序处理。 未设置消息组,消息乱序发送。 顺序消费 按队列存储粒度,严格顺序。