我正在尝试学习一些事件驱动编程的基础知识。因此,为了练习,我正在尝试编写一个程序,读取一个大型二进制文件,并对其执行某些操作,但不会进行任何阻塞调用。我想出了以下解决方案: var fs = require('fs'); var BUFFER_SIZE = 1024; var path_of...
我们有一个数据处理管道,可以从不同的来源接收数据。整个管道是使用事件驱动架构和微服务实现的。其中一个服务有三个独立的任务。其中两个在不同数据来源之间完全相同,但第三个任务的范围可能会根据我们的数据来源略有变化。例如,对于一个数据源,唯一的签名可能基于field1和field2计算,而对于另一个...
我们正在引入SNS+SQS来处理微服务架构中的事件生产和传播,目前我们一直依赖HTTPS调用来相互通信。我们考虑将多个SQS队列连接到一个SNS主题上。然后在EC2中运行的lambda或服务将消耗队列中的事件。 我的问题是,主题应该有多通用呢?什么时候应该创建新主题? 例如,我们有一个需要发布...