Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(scheduler-targets-alpha): KinesisStreamPutRecord Target #27845

Merged
merged 23 commits into from
Dec 4, 2023
Merged

feat(scheduler-targets-alpha): KinesisStreamPutRecord Target #27845

Changes from 1 commit
Commits
Show all changes
23 commits
Select commit Hold shift + click to select a range
6f7ad35
feat(scheduler-targets): KinesisStreamPutRecord Target
go-to-k Nov 5, 2023
f24b427
chore: rm default
go-to-k Nov 5, 2023
bb3b3f7
chore: index
go-to-k Nov 5, 2023
3289cc5
to IStream
go-to-k Nov 5, 2023
2d52200
unit tests
go-to-k Nov 5, 2023
40d4e14
README
go-to-k Nov 5, 2023
441bc6f
change docs
go-to-k Nov 5, 2023
c8fe724
WIP in integ tests
go-to-k Nov 5, 2023
e6f7934
an integ test
go-to-k Nov 6, 2023
f236b54
Revert "README"
go-to-k Nov 6, 2023
dbf8918
add to README
go-to-k Nov 6, 2023
5c6ada0
change import/order
go-to-k Nov 6, 2023
7d0450a
change docs in an integ test
go-to-k Nov 6, 2023
b963d7e
change order in index.ts and words in README
go-to-k Nov 7, 2023
945604f
change doc for KinesisStreamPutRecordProps
go-to-k Nov 9, 2023
8147258
fix fromStreamArn and add tests
go-to-k Nov 9, 2023
1c99fd6
fix stream.test.ts
go-to-k Nov 9, 2023
77e409e
Merge branch 'main' into scheduler-targets-kinesis-stream
go-to-k Nov 21, 2023
ed8b2dd
Merge branch 'main' of https://github.com/go-to-k/aws-cdk into schedu…
go-to-k Nov 30, 2023
1d67e36
Merge branch 'main' into scheduler-targets-kinesis-stream
vinayak-kukreja Nov 30, 2023
1659517
run integ test
vinayak-kukreja Nov 30, 2023
8498c8a
fix conflicts
go-to-k Dec 1, 2023
d47f958
Merge branch 'main' into scheduler-targets-kinesis-stream
vinayak-kukreja Dec 4, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
add to README
  • Loading branch information
@go-to-k
go-to-k committed Nov 6, 2023
commit dbf89189867bb49dd949de04b2be9901ea564ec8
21 changes: 21 additions & 0 deletions packages/@aws-cdk/aws-scheduler-targets-alpha/README.md
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -27,6 +27,7 @@ The following targets are supported:
1. `targets.LambdaInvoke`: [Invoke an AWS Lambda function](#invoke-a-lambda-function))
2. `targets.StepFunctionsStartExecution`: [Start an AWS Step Function](#start-an-aws-step-function)
3. `targets.CodeBuildStartBuild`: [Start a CodeBuild job](#start-a-codebuild-job)
4. `targets.KinesisStreamPutRecord`: [Put a record to an Amazon Kinesis Data Streams](#put-a-record-to-kinesis-data-streams)

## Invoke a Lambda function

Expand Down Expand Up @@ -121,3 +122,23 @@ new Schedule(this, 'Schedule', {
target: new targets.CodeBuildStartBuild(project),
});
```

## Put a record to Kinesis Data Streams

Use the `KinesisStreamPutRecord` target to put a record to a Kinesis Data Streams.

The code snippet below creates an event rule with a stream as target which is
called every hour by Event Bridge Scheduler.

```ts
import * as kinesis from 'aws-cdk-lib/aws-kinesis';

const stream = new kinesis.Stream(this, 'MyStream');

new Schedule(this, 'Schedule', {
schedule: ScheduleExpression.rate(Duration.minutes(60)),
target: new targets.KinesisStreamPutRecord(stream, {
partitionKey: 'key',
}),
});
```