Amazon EventBridge Pipes
Amazon EventBridge Pipes helps you create point-to-point integrations between event producers and consumers with optional transform, filter, and enrich steps. It reduces the amount of integration code you need to write and maintain when building event-driven applications.
APIs
Amazon EventBridge Pipes API
API for creating and managing pipes that connect event sources to targets with optional filtering, enrichment, and transformation capabilities.
Collections
Amazon EventBridge Pipes
POSTMANArazzo Workflows
EventBridge Pipes Create Pipe and Await Running
Create a pipe with DesiredState RUNNING, then poll DescribePipe until it reports CurrentState RUNNING.
ARAZZOEventBridge Pipes Create, Start and Confirm
Create a pipe in the STOPPED state, explicitly start it, then describe it to confirm the running configuration.
ARAZZOEventBridge Pipes Describe, Update and Await
Read an existing pipe, apply a configuration update, then poll until the pipe settles back to a stable state.
ARAZZOEventBridge Pipes Drain and Delete Pipe
Safely decommission a pipe by stopping it, polling until it is STOPPED, then deleting it.
ARAZZOEventBridge Pipes Stop Pipe and Await Stopped
Stop a running pipe, then poll DescribePipe until it confirms the pipe has fully reached the STOPPED state.
ARAZZOEventBridge Pipes Tag Pipe and Verify
Resolve a pipe's ARN by name, apply tags to it, then list the resource tags to verify they were stored.
ARAZZOPricing Plans
Rate Limits
FinOps
Features
Connect event sources directly to targets with minimal code
Filter events before processing to reduce costs and noise
Enrich events with data from Lambda, Step Functions, or API destinations
Transform event payloads using input transformers
Process events in batches for improved throughput
Use Cases
Stream DynamoDB or Aurora changes to downstream systems
Connect SQS queues to Lambda or Step Functions for message processing
Process Kinesis or Kafka streams with filtering and enrichment
Connect SaaS event sources to AWS targets without custom code
Semantic Vocabularies
API Governance Rules
JSON Structure
Amazon Eventbridge Pipes Capacity Provider Strategy Item Weight Structure
0 properties
JSON STRUCTUREAmazon Eventbridge Pipes Ecs Inference Accelerator Override List Structure
0 properties
JSON STRUCTUREAmazon Eventbridge Pipes On Partial Batch Item Failure Streams Structure
0 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Source Active Mq Broker Parameters Structure
4 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Source Dynamo Db Stream Parameters Structure
8 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Source Kinesis Stream Parameters Structure
9 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Source Managed Streaming Kafka Parameters Structure
6 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Source Rabbit Mq Broker Parameters Structure
5 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Source Self Managed Kafka Parameters Structure
9 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Target Cloud Watch Logs Parameters Structure
2 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Target Event Bridge Event Bus Parameters Structure
5 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Target Kinesis Stream Parameters Structure
1 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Target Lambda Function Parameters Structure
1 properties
JSON STRUCTUREAmazon Eventbridge Pipes Pipe Target Sage Maker Pipeline Parameters Structure
1 properties
JSON STRUCTUREAmazon Eventbridge Pipes Requested Pipe State Describe Response Structure
0 properties
JSON STRUCTUREAmazon Eventbridge Pipes Self Managed Kafka Access Configuration Credentials Structure
4 properties
JSON STRUCTUREAmazon Eventbridge Pipes Self Managed Kafka Access Configuration Vpc Structure
2 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Active Mq Broker Parameters Structure
3 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Dynamo Db Stream Parameters Structure
7 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Kinesis Stream Parameters Structure
7 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Managed Streaming Kafka Parameters Structure
3 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Rabbit Mq Broker Parameters Structure
3 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Self Managed Kafka Parameters Structure
5 properties
JSON STRUCTUREAmazon Eventbridge Pipes Update Pipe Source Sqs Queue Parameters Structure
2 properties
JSON STRUCTUREExample Payloads
Amazon Eventbridge Pipes Self Managed Kafka Access Configuration Credentials Example
4 fields
EXAMPLE