Select your cookie preferences

We use essential cookies and similar tools that are necessary to provide our site and services. We use performance cookies to collect anonymous statistics, so we can understand how customers use our site and make improvements. Essential cookies cannot be deactivated, but you can choose “Customize” or “Decline” to decline performance cookies.

If you agree, AWS and approved third parties will also use cookies to provide useful site features, remember your preferences, and display relevant content, including relevant advertising. To accept or decline all non-essential cookies, choose “Accept” or “Decline.” To make more detailed choices, choose “Customize.”

Skip to main content

Amazon EventBridge Pipes

Integrate event producers and consumers in a simpler, consistent, and cost-effective way

Overview

Amazon EventBridge Pipes helps you create point-to-point integrations between event producers and consumers with optional transform, filter and enrich steps. EventBridge Pipes reduces the amount of integration code you need to write and maintain when building event-driven applications.

Use cases

Use EventBridge Pipes event filters to select specific high-value events from your Kinesis Data Streams, enabling you to only process the events you need.

Connect DynamoDB to over 14 AWS services, including Amazon Simple Notification Service (SNS) or EventBridge to easily propagate database changes to multiple applications.

Move data from your on-premises or self-hosted Kafka topics to AWS services such as Amazon Kinesis Data Firehose or Amazon Simple Queue Service (SQS).

Add more data to an event by making an API call to a third-party API before delivering the event to a target.

Features

Filter Events

Ensure your applications process only the necessary events, so that you consume only a subset of events.

Batch Events

Retrieve events from sources and deliver to targets in batches, making integrations more efficient.

Order Events

 Provide guaranteed ordering of events for applications where the ordering is critical.

High Concurrency

Support high concurrency, so you can process large volumes of events quickly.

Advanced Enrichment

Provide enrichment capabilities using AWS Lambda, AWS Step Functions, API Gateway, or an API call to a third-party API using API Destinations.