EventBridge 集成云服务实践
简介:本篇文章主要向大家分享了通过 EventBridge 如何集成云产品事件源,如何集成云产品事件目标以及通过事件流如何集成消息产品。
作者:李凯(凯易)
EvenBridge 集成概述
EventBridge 是阿里云所推出了一款无服务器事件总线,其目标是拓展事件生态,打破系统间的数据孤岛,建立事件集成生态。提供统一的事件标准化接入及管理能力,完善集成与被集成通路,帮助客户快速实现事件驱动的核心原子功能,可将 EventBridge 快速集成至 BPM、RPA、CRM 等系统。
EventBridge 通过事件标准化,接入标准化,组件标准化三个方向作为支点拓展 EventBridge 事件生态:
- 事件标准化:拥抱 CloudEvents 1.0 开源社区标准协议,原生支持 CloudEvents 社区 SDK 和 API,全面拥抱开源社区事件标准生态;
- 接入标准化:提供标准事件推送协议 PutEvent,并支持 Pull 和 Push 两种事件接入模型,可有效降低事件接入难度,提供云上完善的事件接入标准化流程;
- 组件标准化:封装标准的事件下游组件工具链体系,包括 Schema 注册、事件分析、事件检索、事件仪表盘等。提供完善的事件工具链生态。
在集成领域 EventBridge 重点打造事件集成和数据集成两类核心场景,下面将围绕这两类场景具体展开描述。
事件集成
目前 EventBridge 已经拥有 80+ 云产品的事件源,800+ 种事件类型。整个事件生态还正在逐步丰富中。
那么,EventBridge 如何实现云产品的事件集成呢?
- 首先在 EventBridge 控制台可以看见一个名为 default 的事件总线,云产品的事件都会投递到这个总线;
- 然后点击创建规则,就可以选择所关心的云产品以及它的相关事件进行事件的监听和投递。
下面以两个例子为例,来看下 EventBridge 事件集成的方式。
OSS 事件集成
以 OSS 事件源为例,来讲解一下如何集成 OSS 事件。
OSS 事件现在主要分为 4 类,操作审计相关、云监控相关、配置审计相关、以及云产品相关的事件例如 PutObject 上传文件等等。其他的云产品的事件源也类似,基本都可以分为这几个类型的事件。
下面演示一下事件驱动的在线文件解压服务:
- 在 OSS Bucket 下面会有一个 zip 文件夹存放需要解压的文件,一个 unzip 文件夹存放解压后的文件;
- 当上传文件到 OSS Bucket 之后,会触发文件上传的事件并投递到 EventBridge 的云服务专用总线;
- 然后会使用一个事件规则过滤 zip 这个 bucket 的事件并投递到解压服务的 HTTP Endpoint;
- 解压服务会在收到事件之后,根据事件里面的文件路径从 OSS 下载文件解压,并在解压之后将文件传到 unzip 目录下;
- 同时,还会有一个事件规则,监听 unzip 目录的文件上传事件,并将事件转换后推送到钉钉群。
一起来看下是如何实现的:
前往下方链接查看视频:
《EventBridge 集成云服务实践》事件驱动的在线文件解压服务1_哔哩哔哩_bilibili
1)首先创建一个 bucket,下面有一个 zip 目录用于存放上传的压缩文件,一个 unzip 目录用于存放解压后的文件。
2) 部署解压服务,并且暴露公网访问的地址。
解压服务的源码地址为:
https://github.com/AliyunContainerService/serverless-k8s-examples/tree/master/oss-unzip?spm=a2c6h.12873639.article-detail.15.5a585d52apSWbk
也可以使用 ASK 直接部署,yaml 文件地址为:
https://github.com/AliyunContainerService/serverless-k8s-examples/blob/master/oss-unzip/hack/oss-unzip.yaml
3)创建一个事件规则监听 zip 目录下的上传文件的事件,并投递到解压服务的 HTTP Endpoint。
这里使用 subject,匹配 zip 目录。
4)再创建一个事件规则监听 unzip 目录的事件,投递解压事件到钉钉群。
这里同样使用 subject,匹配 unzip 目录。
对于变量和模板的配置可以参考官方文档 :
事件内容转换 - 事件总线EventBridge - 阿里云。
EventBridge 会通过 JSONPath 的方式从事件中提取参数,然后把这些值放到变量中,最后通过模板的定义渲染出最终的输出投递到事件目标。OSS 事件源的事件格式也可以参考官方文档 :
对象存储OSS事件 - 事件总线EventBridge - 阿里云 ,并根据实际的业务需要使用 JSONPath 定义变量。5)最后,通过 oss 控制台上传一个文件进行验证。
可以看到刚刚上传的 eventbridge.zip 已经解压到并上传上来了,也可以在钉钉群里面,收到解压完成的通知。此外,还可以在事件追踪这边查看事件的内容已经投递的轨迹。
可以看到有两个上传事件:一个是通过控制台上传的事件,一个是解压文件后上传的事件。
可以查看轨迹,都成功投递到了解压服务的 HTTP Endpoint 以及钉钉机器人。
以自定义事件源以及云产品事件目标的方式集成云产品
刚才演示的 demo 是集成云服务的事件源,下面再通过一个 demo 看一下如何通过以自定义事件源以及云产品事件目标的方式集成云产品。
前往下方链接查看视频:
《EventBridge 集成云服务实践》如何使用事件流,将 RocketMQ 的消息路由到 MNS Queue,将两个产品集成起来_哔哩哔哩_bilibili
这个 demo 的最终效果是通过 EventBridge 自动进行数据的清洗,并投递到 RDS 中去。事件内容是一个 JSON,拥有两个字段一个名字一个年龄,现在希望将把大于 10 岁的用户过滤出来并存储到 RDS 中。
整体的架构如图所示,使用一个 MNS Queue 作为自定义事件源,并通过 EventBridge 过滤并转换事件最终直接输出到 RDS 中去。
1)首先已经创建好了一个 MNS Queue,创建好一个 RDS 实例以及数据库表,表结构如下所示:
2)创建一个自定事件总线,选择事件提供方为 MNS,队列为提前创建好的队列;
创建好了之后,我们就可以在事件源这里看见一个已经正在运行中的事件源;
3)接下来创建规则投递到 RDS
配置的事件模式内容如下:
{"source": ["my.user"],"data": {"messageBody": {"age": [{"numeric": [">",10]}]}} }
数值匹配可以参考官方文档:
事件模式 - 事件总线EventBridge - 阿里云
4) 点击下一步,选择事件目标为数据库,填写数据库信息,配置转化规则,完成创建。
5)最后,先用 MNS Queue 发送一个消息,这个的 age 是大于 10 的。
可以看见这条事件就输出到了 RDS 里面了。
下面再发一个小于 10 的消息到 MNS Queue。
这条事件就被过滤掉了,没有输出到 RDS。
也可通过事件追踪查看事件:
可以看到一条事件成功投递到了 RDS,一条事件被过滤掉了,没有进行投递。
数据集成
事件流是 EventBridge 为数据集成提供的一个更为轻量化、实时的端到端的事件流试的通道,主要目标是将事件在两个端点之间进行数据同步,同时提供过滤和转换的功能。目前已经支持阿里云各消息产品之间的事件流转。
不同于事件总线模型,在事件流中,并不需要事件总线,其 1:1 的模型更加的轻量,直接到目标的方式也让事件更加的实时;通过事件流,我们可以实现不同系统之间的协议转换,数据同步,跨地域备份的能力。
下面将通过一个例子讲解如何使用事件流,将 RocketMQ 的消息路由到 MNS Queue,将两个产品集成起来。
整体的结构如图所示,通过EventBridge 将 RocketMQ 中 TAG 为 MNS 的消息路由到 MNQ Queue。
一起看下怎么实现:
前往下方链接查看视频:
《EventBridge 集成云服务实践》通过以自定义事件源以及云产品事件目标的方式集成云产品_哔哩哔哩_bilibili
- 首先创建一个事件流,选择源 RocketMQ 实例,填写 Tag 为 mns。
- 事件模式内容留空表示匹配所有。
- 目标选择 MNS,选择目标队列完成创建。
- 完成创建之后,点击启动,启动事件流任务。
事件流启动完成之后,我们就可以通过控制台或者 SDK 发送消息到源 RocketMQ Topic 里面。当有 Tag 为 mns 的时候,我们可以看见消息路由到了 mns;当有 Tag 不为 mns 的时候,消息就不会路由到 mns。
总结
本篇文章主要向大家分享了通过 EventBridge 如何集成云产品事件源,如何集成云产品事件目标以及通过事件流如何集成消息产品。
原文链接
本文为阿里云原创内容,未经允许不得转载。
EventBridge 集成云服务实践相关推荐
- 基于AWS的云服务架构最佳实践 #CSDN博文精选# #IT# #云服务实践#
大家好,小C将继续与你们见面,带来精选的CSDN博文~ 在这里,你将收获: 将系统化学习理论运用于实践,系统学习IT技术 学习内容涵盖数据库.软件测试.主流框架.领域驱动设计和第三方生态等,离全栈工程 ...
- 2019年微服务实践第一课,网易谐云蘑菇街奥思技术大咖深度分享
微服务的概念最早由Martin Fowler与James Lewis于2014年共同提出,核心思想是围绕业务能力组织服务,各个微服务可被独立部署,服务间是松耦合的关系,以及数据和治理的去中心化管理.微 ...
- 基于阿里云容器服务的微服务实践 - Part 1. 微服务与Docker
基于阿里云容器服务的微服务实践 基于阿里云容器服务的微服务实践 - Part 1. 微服务与Docker 作者:chszs,未经博主允许不得转载.经许可的转载需注明作者和博客主页:http://blo ...
- [转]在 Azure 云服务上设计大规模服务的最佳实践
本文转自:http://technet.microsoft.com/zh-cn/magazine/jj717232.aspx 英文版:http://msdn.microsoft.com/library ...
- 微服务实践 | 焱融云前端微服务架构的设计要点
什么是微服务 微服务是一种开发软件的架构和组织方法,其中软件由通过明确定义的 API 进行通信的小型独立服务组成,这些服务由各个小型独立团队负责,每个服务可被独立部署,服务之间是松耦合的,每个服务仅关 ...
- QCon北京2016:企业级云服务技术应用与实践
QCon北京2016全球软件开发大会已于4月23日在北京国际会议中心顺利闭幕.在21日进行的"基于云的IT系统升级部署"厂商共建专场活动中,来自才云.又拍云.逸创云客服.云络.白山 ...
- 腾讯云WAF服务再获国内权威研究机构认可,入选中国云WAF实践代表
上云步伐的加快,使得企业对云端Web应用安全防护的需求由附加项转为"关键信息基础设施",并带来了新的应用命题.8月18日,中国领先的行业和市场大数据库头豹研究院联合全球著名增长咨询 ...
- 基于AWS的云服务架构最佳实践
近年来,对于打造高度可扩展的应用程序,软件架构师们挖掘了若干相关理念,并以最佳实践的方式加以实施.在今天的"信息时代",这些理念更加适用于不断增长的数据集,不可预知的流量模式,以及 ...
- 华为消费者云背后的微服务实践经验
2018年6月27日,Apache ServiceComb在北京举办主题Workshop,当中,来自华为消费者云的架构师李林锋分享了<ServiceComb在华为消费者云的亿级用户微服务实践&g ...
最新文章
- LINUX-Shell第一课
- 图像处理opencv(一)
- (JAVA)格式化输出日期
- Windows上快速在指定目录打开cmd.exe命令行的方法
- 怎么在ASP.NET 2.0中使用Membership
- 基于JAVA+Servlet+JSP+MYSQL的在线答疑系统
- kafka性能高的影响因素
- 快排序和堆排序,最小堆、最大堆
- JAVA视频MP4文件加密,Html5播放器调用
- FileUtils工具类
- Eclipse插件开发
- 精挑41款,好用到爆的谷歌浏览器插件,每位程序员日常编程必备
- kill word out e ef en em
- 2022低压电工培训试题模拟考试平台操作
- 关系数据库——关系操作和关系完整性
- 使用Mac本打造你的高效率融合双系统(结尾附视频)
- MASM的Hello World
- JavaScript 播放多条音频与延迟播放
- 知乎上这个话题引起了我的兴趣:在实体经济一片下滑的大环境中,哪些行业还可以?
- 查看mysql缓存命中_【转】MySQL如何检查缓存命中