Amazon EventBridge Pipes logo

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.

1 APIs 5 Features
Amazon Web ServicesEvent-DrivenIntegrationMessagingServerless

APIs

Amazon EventBridge Pipes API

API for creating and managing pipes that connect event sources to targets with optional filtering, enrichment, and transformation capabilities.

Features

Point-to-Point Integration

Connect event sources directly to targets with minimal code

Event Filtering

Filter events before processing to reduce costs and noise

Event Enrichment

Enrich events with data from Lambda, Step Functions, or API destinations

Event Transformation

Transform event payloads using input transformers

Batching Support

Process events in batches for improved throughput

Use Cases

Database Change Data Capture

Stream DynamoDB or Aurora changes to downstream systems

Queue Processing

Connect SQS queues to Lambda or Step Functions for message processing

Stream Analytics

Process Kinesis or Kafka streams with filtering and enrichment

SaaS Integration

Connect SaaS event sources to AWS targets without custom code

Semantic Vocabularies

Amazon Eventbridge Pipes Context

83 classes · 130 properties

JSON-LD

API Governance Rules

Amazon EventBridge Pipes API Rules

20 rules · 10 errors 9 warnings 1 info

SPECTRAL

Resources

🔗
PostmanWorkspace
PostmanWorkspace
🔗
ArazzoWorkflows
ArazzoWorkflows
🌐
Portal
Portal
🌐
DeveloperPortal
DeveloperPortal
🔗
Documentation
Documentation
📰
Blog
Blog
👥
GitHubOrganization
GitHubOrganization
🌐
Console
Console
📝
SignUp
SignUp
🔗
Login
Login
🟢
StatusPage
StatusPage
💬
Support
Support
💬
FAQ
FAQ
📜
TermsOfService
TermsOfService
📜
PrivacyPolicy
PrivacyPolicy
🔗
Compliance
Compliance
🔗
Security
Security
👥
YouTube
YouTube
👥
StackOverflow
StackOverflow
🔗
KnowledgeCenter
KnowledgeCenter
🔗
Contact
Contact
🔗
SpectralRules
SpectralRules
🔗
Vocabulary
Vocabulary

Sources

Raw ↑
name: Amazon EventBridge Pipes
description: >-
  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.
image: https://a0.awsstatic.com/libra-css/images/logos/aws_logo_smile_1200x630.png
url: https://aws.amazon.com/eventbridge/pipes/
created: '2024-01-15'
modified: '2026-05-19'
specificationVersion: '0.19'
tags:
  - Amazon Web Services
  - AWS
  - Event-Driven
  - Integration
  - Messaging
  - Serverless
apis:
  - name: Amazon EventBridge Pipes API
    description: >-
      API for creating and managing pipes that connect event sources to targets with optional filtering, enrichment, and
      transformation capabilities.
    humanURL: https://aws.amazon.com/eventbridge/pipes/
    baseURL: https://pipes.amazonaws.com
    tags:
      - Event-Driven
      - Integration
      - Messaging
      - Serverless
    properties:
      - type: Documentation
        url: https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes.html
      - type: OpenAPI
        url: openapi/amazon-eventbridge-pipes-openapi.yml
      - type: APIReference
        url: https://docs.aws.amazon.com/eventbridge/latest/pipes-reference/
      - type: GettingStarted
        url: https://aws.amazon.com/eventbridge/pipes/
      - type: Pricing
        url: https://aws.amazon.com/eventbridge/pricing/
      - type: FAQ
        url: https://aws.amazon.com/eventbridge/faqs/
      - type: JSONSchema
        url: json-schema/amazon-eventbridge-pipes-arn-or-json-path-schema.json
      - type: JSONSchema
        url: json-schema/amazon-eventbridge-pipes-arn-or-url-schema.json
      - type: JSONSchema
        url: json-schema/amazon-eventbridge-pipes-arn-schema.json
      - type: JSONLD
        url: json-ld/amazon-eventbridge-pipes-context.jsonld
common:
  - type: PostmanWorkspace
    url: https://www.postman.com/kinlaneapi/amazon-eventbridge-pipes/overview
  - type: ArazzoWorkflows
    url: arazzo/
    workflows:
      - url: arazzo/amazon-eventbridge-pipes-create-pipe-await-running-workflow.yml
        name: EventBridge Pipes Create Pipe and Await Running
        summary: Create a pipe with DesiredState RUNNING, then poll DescribePipe until it reports CurrentState RUNNING.
      - url: arazzo/amazon-eventbridge-pipes-create-start-describe-workflow.yml
        name: EventBridge Pipes Create, Start and Confirm
        summary: >-
          Create a pipe in the STOPPED state, explicitly start it, then describe it to confirm the running
          configuration.
      - url: arazzo/amazon-eventbridge-pipes-describe-update-await-workflow.yml
        name: EventBridge Pipes Describe, Update and Await
        summary: Read an existing pipe, apply a configuration update, then poll until the pipe settles back to a stable state.
      - url: arazzo/amazon-eventbridge-pipes-drain-and-delete-pipe-workflow.yml
        name: EventBridge Pipes Drain and Delete Pipe
        summary: Safely decommission a pipe by stopping it, polling until it is STOPPED, then deleting it.
      - url: arazzo/amazon-eventbridge-pipes-stop-pipe-await-stopped-workflow.yml
        name: EventBridge Pipes Stop Pipe and Await Stopped
        summary: Stop a running pipe, then poll DescribePipe until it confirms the pipe has fully reached the STOPPED state.
      - url: arazzo/amazon-eventbridge-pipes-tag-pipe-and-verify-workflow.yml
        name: EventBridge Pipes Tag Pipe and Verify
        summary: Resolve a pipe's ARN by name, apply tags to it, then list the resource tags to verify they were stored.
  - type: Portal
    url: https://aws.amazon.com/
  - type: DeveloperPortal
    url: https://aws.amazon.com/eventbridge/
  - type: Documentation
    url: https://docs.aws.amazon.com/eventbridge/
  - type: Blog
    url: https://aws.amazon.com/blogs/
  - type: GitHubOrganization
    url: https://github.com/aws
  - type: Console
    url: https://console.aws.amazon.com/events/
  - type: SignUp
    url: https://portal.aws.amazon.com/billing/signup
  - type: Login
    url: https://signin.aws.amazon.com/
  - type: StatusPage
    url: https://health.aws.amazon.com/health/status
  - type: Support
    url: https://aws.amazon.com/support/
  - type: FAQ
    url: https://aws.amazon.com/eventbridge/faqs/
  - type: TermsOfService
    url: https://aws.amazon.com/service-terms/
  - type: PrivacyPolicy
    url: https://aws.amazon.com/privacy/
  - type: Compliance
    url: https://aws.amazon.com/compliance/
  - type: Security
    url: https://aws.amazon.com/security/
  - type: YouTube
    url: https://www.youtube.com/user/AmazonWebServices
  - type: StackOverflow
    url: https://stackoverflow.com/questions/tagged/eventbridge
  - type: KnowledgeCenter
    url: https://repost.aws/knowledge-center
  - type: Contact
    url: https://aws.amazon.com/contact-us/
  - type: SpectralRules
    url: rules/amazon-eventbridge-pipes-spectral-rules.yml
  - type: Vocabulary
    url: vocabulary/amazon-eventbridge-pipes-vocabulary.yaml
  - type: Features
    data:
      - name: Point-to-Point Integration
        description: Connect event sources directly to targets with minimal code
      - name: Event Filtering
        description: Filter events before processing to reduce costs and noise
      - name: Event Enrichment
        description: Enrich events with data from Lambda, Step Functions, or API destinations
      - name: Event Transformation
        description: Transform event payloads using input transformers
      - name: Batching Support
        description: Process events in batches for improved throughput
  - type: UseCases
    data:
      - name: Database Change Data Capture
        description: Stream DynamoDB or Aurora changes to downstream systems
      - name: Queue Processing
        description: Connect SQS queues to Lambda or Step Functions for message processing
      - name: Stream Analytics
        description: Process Kinesis or Kafka streams with filtering and enrichment
      - name: SaaS Integration
        description: Connect SaaS event sources to AWS targets without custom code
  - type: Integrations
    data:
      - name: Amazon DynamoDB Streams
        description: Use DynamoDB Streams as an event source
      - name: Amazon SQS
        description: Connect SQS queues as event sources or targets
      - name: Amazon Kinesis
        description: Process Kinesis data stream events
      - name: AWS Lambda
        description: Use Lambda as enrichment or target for pipe events
      - name: Apache Kafka
        description: Connect Apache Kafka and Amazon MSK as event sources
  - type: Integrations
    url: https://aws.amazon.com/marketplace/
integrations:
  - name: Sign in
  - name: Agent Mode
  - name: Why AWS Marketplace?
  - name: Get started in AWS Marketplace
  - name: Industry
  - name: Resources
  - name: Become a Channel Partner
  - name: Sell in AWS Marketplace
  - name: Manage Your Account
maintainers:
  - FN: Kin Lane
    email: [email protected]