AWSEventFork管道AWSEventForkPipelines是一种架构模式,其中事件源(例如,AmazonSNS主题)用于将事件发送到多个处理管道。
高级架构如下所示:每个处理管道都会为AmazonSNS主题创建一个单独的订阅。
可以将SNS应用于每个订阅,以确保每个管道仅接收它们要处理的消息。
该存储库将AWSEventFork管道实现为一组无服务器应用程序。
每个应用程序都实现通用,可重用的事件处理管道。
所有应用程序均已发布到并可以使用程序轻松集成到现有的AWSSAM应用。
还包括一个示例应用程序,该应用程序演示了如何使用嵌套应用程序将不同的事件处理管道应用程序组合在一起。
无服务器应用该存储库展示了以下AWSEventForkPipelines无服务器应用程序:-处理管道,将主题消息保存到AmazonS3存储桶以用作备份或其他目的,例如,通过AmazonAthena查询。
-处理管道,将主题消息保存到AWSElasticsearch集群以进行搜索和分析。
-将主题消息保存到重播缓冲区SQS队列的处理管道。
在灾难恢复