如何在客户端应用程序中订阅 AWS Event Bus 事件

如何解决如何在客户端应用程序中订阅 AWS Event Bus 事件

如何从客户端应用程序订阅 AWS Event Bus 事件,例如:NodeJS 应用程序、Angular 客户端或移动客户端应用程序?

2020 年 12 月,来自 AWS Marketing 的一封电子邮件介绍了使用事件驱动架构的优势。按照文档和教程,很快我就发现找不到从客户端应用程序订阅此事件的方法。

电子邮件指出:

关注事件驱动架构的 4 个理由

您是否希望在没有延迟和依赖的情况下扩展和构建强大的应用程序?我们分解了事件驱动架构的基础知识及其工作原理,并向您展示了入门方法。了解事件驱动的架构如何为您提供帮助:

  • 独立扩展和失败 - 不再依赖
  • 敏捷开发 - 无自定义轮询代码
  • 轻松审核 - 使用事件路由器定义策略
  • 削减成本 - 停止为连续投票付费

令人失望的部分是,没有将库示例集成到客户端代码中以订阅这些事件。谷歌搜索不会返回任何重要的结果和节点的唯一当前库:@aws-sdk/client-eventbridge-node 只公开发送和销毁方法。

解决方法

无法直接订阅 Amazon EventBridge 总线,因为它不提供发布/订阅功能。为了处理 EventBridge 中的事件,您create event rules 可以过滤匹配事件并将其发送到目标。您可以在此列表中找到 EventBridge 规则可用的所有目标:Amazon EventBridge Targets

其中一个目标可能是 Amazon SNS 主题,它提供发布/订阅功能,即您的客户端应用程序可以subscribe to the topic自动接收相应的事件。

这听起来可能很复杂,但其实现严格遵循分离关注点的原则。它提供了简单的构建块(例如乐高积木),您可以将它们组合在一起以创建真正松散耦合的架构。

This diagram 展示了 Amazon Event Bridge 范围内的功能以及它如何与其他服务和应用程序通信。

,

允许您根据需要订阅(通过 websocket 等 tcp 连接直接将订阅的消息传递给您的代码)的服务是:

  • AppSync - websocket
  • 物联网核心 - websocket、mqtt
  • SQS - 长轮询
  • 卡夫卡

(来自我的头顶)

因此,一个简单的无服务器解决方案可能是:

事件桥接 —> SQS —> 你的代码

为此我经常使用 AppSync。但 eventbridge 也很酷。

,

如果您想避免轮询并且不能/想要使用 AWS Lambda,那么您可以解决问题并使用规则从 EventBridge 调用应用程序上的 API。

您可以在 EventBridge 中创建 API 目标:

API destination

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


使用本地python环境可以成功执行 import pandas as pd import matplotlib.pyplot as plt # 设置字体 plt.rcParams['font.sans-serif'] = ['SimHei'] # 能正确显示负号 p
错误1:Request method ‘DELETE‘ not supported 错误还原:controller层有一个接口,访问该接口时报错:Request method ‘DELETE‘ not supported 错误原因:没有接收到前端传入的参数,修改为如下 参考 错误2:cannot r
错误1:启动docker镜像时报错:Error response from daemon: driver failed programming external connectivity on endpoint quirky_allen 解决方法:重启docker -> systemctl r
错误1:private field ‘xxx‘ is never assigned 按Altʾnter快捷键,选择第2项 参考:https://blog.csdn.net/shi_hong_fei_hei/article/details/88814070 错误2:启动时报错,不能找到主启动类 #
报错如下,通过源不能下载,最后警告pip需升级版本 Requirement already satisfied: pip in c:\users\ychen\appdata\local\programs\python\python310\lib\site-packages (22.0.4) Coll
错误1:maven打包报错 错误还原:使用maven打包项目时报错如下 [ERROR] Failed to execute goal org.apache.maven.plugins:maven-resources-plugin:3.2.0:resources (default-resources)
错误1:服务调用时报错 服务消费者模块assess通过openFeign调用服务提供者模块hires 如下为服务提供者模块hires的控制层接口 @RestController @RequestMapping("/hires") public class FeignControl
错误1:运行项目后报如下错误 解决方案 报错2:Failed to execute goal org.apache.maven.plugins:maven-compiler-plugin:3.8.1:compile (default-compile) on project sb 解决方案:在pom.
参考 错误原因 过滤器或拦截器在生效时,redisTemplate还没有注入 解决方案:在注入容器时就生效 @Component //项目运行时就注入Spring容器 public class RedisBean { @Resource private RedisTemplate<String
使用vite构建项目报错 C:\Users\ychen\work>npm init @vitejs/app @vitejs/create-app is deprecated, use npm init vite instead C:\Users\ychen\AppData\Local\npm-
参考1 参考2 解决方案 # 点击安装源 协议选择 http:// 路径填写 mirrors.aliyun.com/centos/8.3.2011/BaseOS/x86_64/os URL类型 软件库URL 其他路径 # 版本 7 mirrors.aliyun.com/centos/7/os/x86
报错1 [root@slave1 data_mocker]# kafka-console-consumer.sh --bootstrap-server slave1:9092 --topic topic_db [2023-12-19 18:31:12,770] WARN [Consumer clie
错误1 # 重写数据 hive (edu)> insert overwrite table dwd_trade_cart_add_inc > select data.id, > data.user_id, > data.course_id, > date_format(
错误1 hive (edu)> insert into huanhuan values(1,'haoge'); Query ID = root_20240110071417_fe1517ad-3607-41f4-bdcf-d00b98ac443e Total jobs = 1
报错1:执行到如下就不执行了,没有显示Successfully registered new MBean. [root@slave1 bin]# /usr/local/software/flume-1.9.0/bin/flume-ng agent -n a1 -c /usr/local/softwa
虚拟及没有启动任何服务器查看jps会显示jps,如果没有显示任何东西 [root@slave2 ~]# jps 9647 Jps 解决方案 # 进入/tmp查看 [root@slave1 dfs]# cd /tmp [root@slave1 tmp]# ll 总用量 48 drwxr-xr-x. 2
报错1 hive> show databases; OK Failed with exception java.io.IOException:java.lang.RuntimeException: Error in configuring object Time taken: 0.474 se
报错1 [root@localhost ~]# vim -bash: vim: 未找到命令 安装vim yum -y install vim* # 查看是否安装成功 [root@hadoop01 hadoop]# rpm -qa |grep vim vim-X11-7.4.629-8.el7_9.x
修改hadoop配置 vi /usr/local/software/hadoop-2.9.2/etc/hadoop/yarn-site.xml # 添加如下 <configuration> <property> <name>yarn.nodemanager.res