AWS Event Fork Pipelines helps you build event-driven serverless applications by providing pipelines for common event-handling requirements, such as event backup, analytics, and replay. The pipelines are based on AWS SAM, and can be deployed directly from AWS SAR into your AWS account.
AWS Event Fork Pipelines is an architectural pattern where an event source, such as an Amazon SNS topic, is used to send events to multiple processing pipelines. The high-level architecture looks like this:
Each processing pipeline creates a separate subscription to the Amazon SNS topic. SNS Subscription Filter Policies can be applied for each subscription to ensure each pipeline only receives the messages they want to process.
This repository implements AWS Event Fork Pipelines as a suite of Serverless applications. Each application implements general purpose, reusable event processing pipelines. All of the apps have been published to the AWS Serverless Application Repository (SAR) and can easily be integrated into an existing AWS SAM application using Nested Applications. An example application is also included that demonstrates composing the different event processing pipeline apps together using nested apps.
This repository showcases the following AWS Event Fork Pipelines serverless applications:
This repository also contains the following example applications to demonstrate the AWS Event Fork Pipelines:
This sample code is made available under a modified MIT license. See the LICENSE file.