class KinesisStreamPutRecord
Language | Type name |
---|---|
![]() | Amazon.CDK.AWS.Scheduler.Targets.KinesisStreamPutRecord |
![]() | github.com/aws/aws-cdk-go/awscdk/v2/awsschedulertargets#KinesisStreamPutRecord |
![]() | software.amazon.awscdk.services.scheduler.targets.KinesisStreamPutRecord |
![]() | aws_cdk.aws_scheduler_targets.KinesisStreamPutRecord |
![]() | aws-cdk-lib » aws_scheduler_targets » KinesisStreamPutRecord |
Implements
ISchedule
Extends
Schedule
Use an Amazon Kinesis Data Streams as a target for AWS EventBridge Scheduler.
Example
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',
}),
});
Initializer
new KinesisStreamPutRecord(stream: IStream, props: KinesisStreamPutRecordProps)
Parameters
- stream
IStream
- props
Kinesis
Stream Put Record Props
Methods
Name | Description |
---|---|
bind(schedule) | Create a return a Schedule Target Configuration for the given schedule. |
protected add | |
protected bind |
bind(schedule)
public bind(schedule: ISchedule): ScheduleTargetConfig
Parameters
- schedule
ISchedule
Returns
Create a return a Schedule Target Configuration for the given schedule.
protected addTargetActionToRole(role)
protected addTargetActionToRole(role: IRole): void
Parameters
- role
IRole
protected bindBaseTargetConfig(_schedule)
protected bindBaseTargetConfig(_schedule: ISchedule): ScheduleTargetConfig
Parameters
- _schedule
ISchedule
Returns