基于 EventBridge API Destination 构建 SaaS 集成实践方案

简介: 本次新增集成中心(Integration Center)是负责 EventBridge 与外界系统对接的模块,通过抽象与配置快速获取第三方事件并将事件集成到第三方系统。并且优化现有 HTTP Sink 集成方案,为用户下游集成创造更多适配场景。

作者:赵海


引言

事件总线 EventBridge 是阿里云提供的一款无服务器事件总线服务,支持阿里云服务、自定义应用、SaaS 应用以标准化、中心化的方式接入,并能够以标准化的 CloudEvents 1.0 协议在这些应用之间路由事件,帮助您轻松构建松耦合、分布式的事件驱动架构。事件驱动架构是一种松耦合、分布式的驱动架构,收集到某应用产生的事件后实时对事件采取必要的处理后路由至下游系统,无需等待系统响应。使用事件总线 EventBridge 可以构建各种简单或复杂的事件驱动架构,以标准化的 CloudEvents 1.0 协议连接云产品和应用、应用和应用等。


目前 HTTP 的不足有以下几点:


  • HTTP 的能力较弱,比如:授权方式单一、只支持 Body 传参、网络互通能力未对齐。只能满足客户最简单的场景。
  • 用户无法基于 API 来统一管理(修改/下线)Target,用户体验交叉口;
  • 对于基于 HTTP 实现的 SaaS API,无法简单快捷的引入到 EB 中,作为 Target 给用户使用。


本次新增集成中心(Integration Center)是负责 EventBridge 与外界系统对接的模块,通过抽象与配置快速获取第三方事件并将事件集成到第三方系统。并且优化现有 HTTP Sink 集成方案,为用户下游集成创造更多适配场景。


集成中心重点服务对象包括但不限于 SaaS 系统,对标 IPaaS 平台的能力提供完整的全面的通用系统集成方案。


  • 集成源(Integration Source):指集成到 EventBridge 的第三方源;
  • API 端点(API Destination ):指被集成到 EventBridge 的第三方 API 端点;
  • 连接配置(Connection):是 API 端点模块的子集,与API 端点的平级资源,主要负责记录连接及配置信息,连接配置可被任意 API 端点复用。


针对市场上其他云厂商服务,EventBridge 发布了 API 端点 Sink 能力,主要作用在于承接 EventBridge 下游端数据,帮助用户快速完成下游数据集成。提供简单且易于集成的三方事件推送 ,帮助客户更加高效、便捷地实现业务上云。


1.png


API 端点 Sink 概述

接入 EventBridge 应用有多种情况:用户自定义应用、阿里云服务、其他云厂商服务或者其他 DB 产品。


具体而言,API 端点 Sink 事件目标是 EventBridge 支持的事件目标的一种,是通过 EventBridge 将数据投递至指定 Web Server 中。


2.png


API 端点 Sink 基本使用

首先现阶段 API 端点的 Sink 支持三种鉴权方式:


同时网络支持公网和专有网络(后续支持)。


1、创建 Connection


添加连接配置基本信息,并配置鉴权。


链接配置支持三种鉴权方式 :


3.png


Basic 鉴权方式 :


4.png


OAuth 2.0 鉴权方式:


添加授权接入点、授权请求方式、Client ID、ClientSecret 和授权相关的 Http 请求参数。


5.png


API Key 鉴权方式:


6.png


2、创建 ApiDestination


API 端点配置 :配置需要访问 API 的 URL 地址和 HTTP 调用类型。


添加请求地址和请求方式:


7.png


在创建 API 端点时可以直接创建连接配置也可以选择已有的连接配置,例如上面已经创建成功的连接配置。


8.png


3、创建 Rule


创建事件规则,用于将事件投递到具体的 API 端点中。


步骤一 :点击事件规则并创建事件规则

9.png


步骤二 :是选择事件源,可以选择阿里云官方的或者选择自定义事件源,这里选择的是自定义事件源


10.png


步骤三 :第三步是选择 API 端点事件目标


支持自定义创建和使用已有,同时可以添加请求 HTTP 参数。


11.png


使用已有


使用选择已有的以后只需要添加请求 HTTP 参数即可:


12.png


选择已有的 API 端点来自于集成中心下面的 API 端点:


13.png


最佳实践


常见场景案例,比如:


  • 用户可以把 RocketMQ 或者 RabbitMQ 的消息产品的消息动态投递到不同的 Web Server 中,这样可以让不同的 web 平台处理消息数据,实现了跨平台或者跨语言的消息流通。

  • 用户可以把日志服务 SLS 数据投递到指定的 Web Server 或者 ELK 中,方便业务部门或者大数据平台对日志数据处理,可以更好的完善用户画像和用户行为分析,方便给用户打标签,从而可以进一步完善大数据个性化用户推荐系统。


例如下面是访问的国内外 SaaS 生态:


典型场景 :与 Buildkite 集成


场景介绍 :利用 EventBridge 丰富的云产品事件源和目标集成能力,快速与 Buildkite 的持续集成和持续交付(CI / CD)平台进行集成。


集成产品背景描述 :Buildkite 是大型持续集成和持续交付(CI / CD)平台会有各种管理的变更、构建和作业等任务,运维人员需要快速感知、处理这些变更,以便决赛风险。


用户痛点 :构建的事件收集困难,需要手动触发构建和手动创建管道。


方案优势 :EventBridge 支持集成 Buildkite 的持续集成和持续交付平台,用户只需要简单配置即可创建和处理平台的事件。


14.png


举例介绍:可以通过 API 文档中提供的接口实现动态的创建管道、创建构建和重试作业等。


文档地址 :

https://buildkite.com/docs/apis/rest-api/organizations


创建 API 端点


15.png


创建规则


16.png


发布事件,发布完成以后可以到事件轨迹查询详情


17.png


典型场景 :与 Freshdesk 集成


场景介绍 :利用 EventBridge 丰富的云产品事件源和目标集成能力,快速与 CRM(Freshdesk)进行集成。


集成产品背景描述 :不同的平台都需要对接 CRM(Freshdesk)管理系统。


用户痛点 :不同的平台的事件收集困难,需要用户自定义实现。


方案优势 :EventBridge 支持集成 CRM(Freshdesk)平台,用户只需要简单配置即可实现动态的创建会话、创建联系人和创建技能等事件。

18.png


举例介绍:可以通过 API 文档中提供的接口实现动态的创建会话、创建联系人和创建技能等。


文档地址 :

https://developers.freshdesk.com/api/


创建 API 端点

19.png


创建事件规则


20.png


发布事件,发布完成以后可以到事件轨迹查询详情


21.png


典型场景 :与有成财务集成


场景介绍 :利用 EventBridge 丰富的云产品事件源和目标集成能力,快速与有成财务进行集成


集成产品背景描述 :不同的 HR 系统或者 OA 系统需要对接有成财务时


用户痛点 :不同的系统的事件收集困难,需要用户自定义实现


方案优势 :EventBridge 支持集成有成财务平台,用户只需要简单配置即可实现动态生成报销科目和财务凭证等事件


22.png


举例介绍:比如用户想把 mns 的消息或者其他消息产品,同步到钉钉产品等接口中,或者也可以利用消息生成报销单据,可以生成报销科目和财务凭证等


地址 :

https://yiqbopenapi.superboss.cc/#/share/awXPk8nW/K8Mg3rzl


创建 API 端点


23.png


创建规则


24.png


发布事件,发布完成以后可以到事件轨迹查询详情。


25.png


感兴趣的小伙伴们可以钉钉扫描下方二维码加入钉群讨论(群号:44552972)


26.png


点击此处,进入 EventBridge 官网了解更多信息~

相关文章
|
12天前
|
人工智能 数据可视化 JavaScript
NodeTool:AI 工作流可视化构建器,通过拖放节点设计复杂的工作流,集成 OpenAI 等多个平台
NodeTool 是一个开源的 AI 工作流可视化构建器,通过拖放节点的方式设计复杂的工作流,无需编码即可快速原型设计和测试。它支持本地 GPU 运行 AI 模型,并与 Hugging Face、OpenAI 等平台集成,提供模型访问能力。
80 14
NodeTool:AI 工作流可视化构建器,通过拖放节点设计复杂的工作流,集成 OpenAI 等多个平台
|
18天前
|
DataWorks 数据挖掘 大数据
方案实践测评 | DataWorks集成Hologres构建一站式高性能的OLAP数据分析
DataWorks在任务开发便捷性、任务运行速度、产品使用门槛等方面都表现出色。在数据处理场景方面仍有改进和扩展的空间,通过引入更多的智能技术、扩展数据源支持、优化任务调度和可视化功能以及提升团队协作效率,DataWorks将能够为企业提供更全面、更高效的数据处理解决方案。
|
1月前
|
机器学习/深度学习 算法 Python
随机森林算法是一种强大的集成学习方法,通过构建多个决策树并综合其结果进行预测。
随机森林算法是一种强大的集成学习方法,通过构建多个决策树并综合其结果进行预测。本文详细介绍了随机森林的工作原理、性能优势、影响因素及调优方法,并提供了Python实现示例。适用于分类、回归及特征选择等多种应用场景。
59 7
|
1月前
|
关系型数据库 MySQL PHP
PHP与MySQL的无缝集成:构建动态网站的艺术####
本文将深入探讨PHP与MySQL如何携手合作,为开发者提供一套强大的工具集,以构建高效、动态且用户友好的网站。不同于传统的摘要概述,本文将以一个生动的案例引入,逐步揭示两者结合的魅力所在,最终展示如何通过简单几步实现数据驱动的Web应用开发。 ####
|
1月前
|
消息中间件 Java Kafka
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
Spring Boot 与 Apache Kafka 集成详解:构建高效消息驱动应用
44 1
|
17天前
|
人工智能 自然语言处理 API
Multimodal Live API:谷歌推出新的 AI 接口,支持多模态交互和低延迟实时互动
谷歌推出的Multimodal Live API是一个支持多模态交互、低延迟实时互动的AI接口,能够处理文本、音频和视频输入,提供自然流畅的对话体验,适用于多种应用场景。
67 3
Multimodal Live API:谷歌推出新的 AI 接口,支持多模态交互和低延迟实时互动
|
4天前
|
JSON 安全 API
淘宝商品详情API接口(item get pro接口概述)
淘宝商品详情API接口旨在帮助开发者获取淘宝商品的详细信息,包括商品标题、描述、价格、库存、销量、评价等。这些信息对于电商企业而言具有极高的价值,可用于商品信息展示、市场分析、价格比较等多种应用场景。
|
12天前
|
前端开发 API 数据库
Next 编写接口api
Next 编写接口api
|
18天前
|
XML JSON 缓存
阿里巴巴商品详情数据接口(alibaba.item_get) 丨阿里巴巴 API 实时接口指南
阿里巴巴商品详情数据接口(alibaba.item_get)允许商家通过API获取商品的详细信息,包括标题、描述、价格、销量、评价等。主要参数为商品ID(num_iid),支持多种返回数据格式,如json、xml等,便于开发者根据需求选择。使用前需注册并获得App Key与App Secret,注意遵守使用规范。