aws-lambda-stream:使用AWS Lambda函数创建流处理器

aws-lambda-stream 使用AWS Lambda函数创建流处理器。 许多Lambda函数的事件签名是一个数组，其中包含微批的event.Records 。 函数式React性编程（FRP）是处理这些流的最干净的方法。 该库提供了用于创建这些流处理器的轻量级框架。 底层的流媒体库是 ，具有很多功能，例如过滤器，映射，减少，反压，批处理，并行处理等。 提供了对AWS EventBridge，Kinesis，DynamoDB Streams等的支持。 注意：原始代码库已在生产中使用多年。 该特定的开源版本位于BETA中，同时移植并记录了各种功能。 安装 npm install aws-lambda-stream --save 典型场景 下图描述了使用此库来实现事件源和cqrs模式的典型情况。 服务X数据库中的状态更改触发域事件的发布，服务Y使用事件并在实例化视图中缓存所需的