class KinesisStreamPutRecord
Language | Type name |
---|---|
.NET | Amazon.CDK.AWS.Scheduler.Targets.Alpha.KinesisStreamPutRecord |
Go | github.com/aws/aws-cdk-go/awscdkschedulertargetsalpha/v2#KinesisStreamPutRecord |
Java | software.amazon.awscdk.services.scheduler.targets.alpha.KinesisStreamPutRecord |
Python | aws_cdk.aws_scheduler_targets_alpha.KinesisStreamPutRecord |
TypeScript (source) | @aws-cdk/aws-scheduler-targets-alpha » 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.
TargetActionToRole(schedule, role)
protected addprotected addTargetActionToRole(schedule: ISchedule, role: IRole): void
Parameters
BaseTargetConfig(_schedule)
protected bindprotected bindBaseTargetConfig(_schedule: ISchedule): ScheduleTargetConfig
Parameters
- _schedule
ISchedule
Returns