我正在尝试学习一些事件驱动编程的基础知识。因此，为了练习，我正在尝试编写一个程序，读取一个大型二进制文件，并对其执行某些操作，但不会进行任何阻塞调用。我想出了以下解决方案： var fs = require('fs'); var BUFFER_SIZE = 1024; var path_of...

我们有一个数据处理管道，可以从不同的来源接收数据。整个管道是使用事件驱动架构和微服务实现的。其中一个服务有三个独立的任务。其中两个在不同数据来源之间完全相同，但第三个任务的范围可能会根据我们的数据来源略有变化。例如，对于一个数据源，唯一的签名可能基于field1和field2计算，而对于另一个...

我们正在引入SNS+SQS来处理微服务架构中的事件生产和传播，目前我们一直依赖HTTPS调用来相互通信。我们考虑将多个SQS队列连接到一个SNS主题上。然后在EC2中运行的lambda或服务将消耗队列中的事件。 我的问题是，主题应该有多通用呢？什么时候应该创建新主题？ 例如，我们有一个需要发布...