# @aws-cdk/aws-pipes-sources-alpha

> The CDK Construct Library for Amazon EventBridge Pipes Sources

Latest version **2.268.0-alpha.0** (published 2026-09-02) · Apache-2.0 license · 0 weekly downloads

## Install

```sh
npm install @aws-cdk/aws-pipes-sources-alpha
pnpm add @aws-cdk/aws-pipes-sources-alpha
yarn add @aws-cdk/aws-pipes-sources-alpha
bun add @aws-cdk/aws-pipes-sources-alpha
```

## Health

**Score 60/100 (C)** — status: active.

Positive: no vulnerabilities; recently updated; high maintenance score; popular repo.

Warnings: low downloads; no types; no esm support.

## Facts

| | |
|---|---|
| Version | 2.268.0-alpha.0 |
| Published | 2026-09-02 |
| First published | 2024-02-10 |
| Weekly downloads | 0 |
| License | Apache-2.0 |
| TypeScript types | none |
| Module format | CommonJS |
| Dependencies | 0 |
| Known vulnerabilities | 0 |
| Install scripts | no |
| GitHub stars | 12888 |
| Author | Amazon Web Services |
| Maintainers | amzn-oss, aws-cdk-team |
| Keywords | aws, cdk, constructs, aws-pipes |

## Links

- npm: https://www.npmjs.com/package/@aws-cdk/aws-pipes-sources-alpha
- Repository: https://github.com/aws/aws-cdk
- Issues: https://github.com/aws/aws-cdk/issues
- npm.io page: https://npm.io/package/@aws-cdk/aws-pipes-sources-alpha

## Alternatives

- [@opentelemetry/exporter-zipkin](https://npm.io/package/@opentelemetry/exporter-zipkin.md) — 14.8M weekly downloads
- [pusher-js](https://npm.io/package/pusher-js.md) — 2.0M weekly downloads
- [browserify](https://npm.io/package/browserify.md) — 1.7M weekly downloads
- [sqs-consumer](https://npm.io/package/sqs-consumer.md) — 1.7M weekly downloads
- [@sanity/eventsource](https://npm.io/package/@sanity/eventsource.md) — 930.8K weekly downloads

## Recent versions

- 2.268.0-alpha.0 (latest) — 2026-09-02
- 2.267.0-alpha.0 — 2026-08-27
- 2.266.0-alpha.0 — 2026-08-19
- 2.265.0-alpha.0 — 2026-08-13
- 2.264.0-alpha.0 — 2026-08-10
- 2.263.0-alpha.0 — 2026-07-31
- 2.262.2-alpha.0 — 2026-07-29
- 2.262.1-alpha.0 — 2026-07-24
- 2.262.0-alpha.0 — 2026-07-22
- 2.261.0-alpha.0 — 2026-07-02
- 2.260.0-alpha.0 — 2026-06-16
- 2.259.0-alpha.0 — 2026-06-12
- 2.258.1-alpha.0 — 2026-06-09
- 2.258.0-alpha.0 — 2026-06-04
- 2.257.0-alpha.0 — 2026-05-21
- … 175 more at https://npm.io/package/@aws-cdk/aws-pipes-sources-alpha/versions

## README

# Amazon EventBridge Pipes Sources Construct Library

<!--BEGIN STABILITY BANNER-->

---

![cdk-constructs: Experimental](https://img.shields.io/badge/cdk--constructs-experimental-important.svg?style=for-the-badge)

> The APIs of higher level constructs in this module are experimental and under active development.
> They are subject to non-backward compatible changes or removal in any future version. These are
> not subject to the [Semantic Versioning](https://semver.org/) model and breaking changes will be
> announced in the release notes. This means that while you may use them, you may need to update
> your source code when upgrading to a newer version of this package.

---

<!--END STABILITY BANNER-->


EventBridge Pipes Sources let you create a source for a EventBridge Pipe.


For more details see the service documentation:

[Documentation](https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-source.html)

## Pipe sources

Pipe sources are the starting point of a EventBridge Pipe. They are the source of the events that are sent to the pipe.

### Amazon SQS

A SQS message queue can be used as a source for a pipe. The queue will be polled for new messages and the messages will be sent to the pipe.

```ts
declare const sourceQueue: sqs.Queue;
declare const targetQueue: sqs.Queue;

const pipeSource = new sources.SqsSource(sourceQueue);

const pipe = new pipes.Pipe(this, 'Pipe', {
  source: pipeSource,
  target: new SqsTarget(targetQueue)
});
```

The polling configuration can be customized:

```ts
declare const sourceQueue: sqs.Queue;
declare const targetQueue: sqs.Queue;

const pipeSource = new sources.SqsSource(sourceQueue, {
  batchSize: 10,
  maximumBatchingWindow: cdk.Duration.seconds(10)
});

const pipe = new pipes.Pipe(this, 'Pipe', {
  source: pipeSource,
  target: new SqsTarget(targetQueue)
});
```

### Amazon Kinesis

A Kinesis stream can be used as a source for a pipe. The stream will be polled for new messages and the messages will be sent to the pipe.

```ts
declare const sourceStream: kinesis.Stream;
declare const targetQueue: sqs.Queue;

const pipeSource = new sources.KinesisSource(sourceStream, {
  startingPosition: sources.KinesisStartingPosition.LATEST,
});

const pipe = new pipes.Pipe(this, 'Pipe', {
  source: pipeSource,
  target: new SqsTarget(targetQueue)
});
```

### Amazon DynamoDB

A DynamoDB stream can be used as a source for a pipe. The stream will be polled for new messages and the messages will be sent to the pipe.

```ts
const table = new ddb.TableV2(this, 'MyTable', {
  partitionKey: {
    name: 'id',
    type: ddb.AttributeType.STRING,
  },
  dynamoStream: ddb.StreamViewType.NEW_IMAGE,
});
declare const targetQueue: sqs.Queue;

const pipeSource = new sources.DynamoDBSource(table, {
  startingPosition: sources.DynamoDBStartingPosition.LATEST,
});

const pipe = new pipes.Pipe(this, 'Pipe', {
  source: pipeSource,
  target: new SqsTarget(targetQueue)
});
```

---
_Source: https://npm.io/package/@aws-cdk/aws-pipes-sources-alpha · Machine-readable twin of the npm.io package page. Health data is recomputed on every publish._