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