基于 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 官网了解更多信息~

相关文章
|
5月前
|
机器学习/深度学习 算法 物联网
面向能效和低延迟的语音控制智能家居:离线语音识别与物联网集成方案——论文阅读
本文提出一种面向能效与低延迟的离线语音控制智能家居方案,通过将关键词识别(KWS)集成至终端设备,结合去中心化Mesh网络与CoAP协议,实现本地化语音处理。相较云端方案,系统能耗降低98%,延迟减少75%以上,显著提升响应速度与能源效率,为绿色智能家居提供可行路径。(236字)
444 17
面向能效和低延迟的语音控制智能家居:离线语音识别与物联网集成方案——论文阅读
编解码 算法 vr&ar
392 0
|
6月前
|
自然语言处理 负载均衡 算法
推理速度提升300%:LLaMA4-MoE的FlashAttention-2集成与量化部署方案
本文详解LLaMA4-MoE模型架构与实现全流程,涵盖语料预处理、MoE核心技术、模型搭建、训练优化及推理策略,并提供完整代码与技术文档,助你掌握大模型MoE技术原理与落地实践。
391 6
|
7月前
|
缓存 人工智能 监控
MCP资源管理深度实践:动态数据源集成方案
作为一名深耕AI技术领域多年的开发者,我见证了从传统API集成到现代化协议标准的演进历程。今天要和大家分享的MCP(Model Context Protocol)资源管理实践,是我在实际项目中积累的宝贵经验。MCP作为Anthropic推出的革命性AI连接标准,其资源管理机制为我们提供了前所未有的灵活性和扩展性。在过去的几个月里,我深度参与了多个企业级MCP项目的架构设计和实施,从最初的概念验证到生产环境的大规模部署,每一个环节都让我对MCP资源管理有了更深刻的理解。本文将从资源生命周期管理的角度出发,详细探讨文件系统、数据库、API等多种数据源的适配策略,深入分析实时数据更新与缓存的最佳实践
262 0
|
7月前
|
人工智能 安全 API
MCP vs 传统集成方案:REST API、GraphQL、gRPC的终极对比
作为一名长期关注AI技术发展的博主摘星,我深刻感受到了当前AI应用集成领域正在经历的巨大变革。随着Anthropic推出的Model Context Protocol(MCP,模型上下文协议)逐渐成熟,我们不得不重新审视传统的系统集成方案。在过去的几年中,REST API凭借其简单易用的特性成为了Web服务的标准选择,GraphQL以其灵活的数据查询能力赢得了前端开发者的青睐,而gRPC则以其高性能的特点在微服务架构中占据了重要地位。然而,当我们将视角转向AI应用场景时,这些传统方案都暴露出了一些局限性:REST API的静态接口设计难以适应AI模型的动态需求,GraphQL的复杂查询机制在处
470 0
MCP vs 传统集成方案:REST API、GraphQL、gRPC的终极对比
|
7月前
|
JSON API 开发者
Django集成Swagger全指南:两种实用方案详解
本文介绍了在 Django 项目中集成 Swagger 的两种主流方案 —— drf-yasg 和 drf-spectacular,涵盖安装配置、效果展示及高级用法,助力开发者高效构建交互式 API 文档系统,提升前后端协作效率。
329 5
|
8月前
|
存储 Kubernetes 监控
Docker与Kubernetes集成挑战及方案
面对这些挑战,并不存在一键解决方案。如同搭建灌溉系统需要考虑多种因素,集成Docker与Kubernetes也需要深思熟虑的规划、相当的技术知识和不断的调试。只有这样,才能建立起一个稳定、健康、高效的Docker-Kubernetes生态,让你的应用像花园中的植物一样繁荣生长。
373 63
|
消息中间件 监控 Java
您是否已集成 Spring Boot 与 ActiveMQ?
您是否已集成 Spring Boot 与 ActiveMQ?
477 0
|
Java Maven Docker
gitlab-ci 集成 k3s 部署spring boot 应用
gitlab-ci 集成 k3s 部署spring boot 应用
|
监控 druid Java
spring boot 集成配置阿里 Druid监控配置
spring boot 集成配置阿里 Druid监控配置
1331 6