@aws-cdk/aws-pipes-targets-alpha.KinesisTargetParameters

Experimental

@aws-cdk/aws-pipes-targets-alpha is an experimental (alpha) package: its API may change in any release, without a major version bump.

KinesisTargetParameters Struct

Kinesis target properties.

KinesisTargetParameters

used as props by

• KinesisTarget

Stability

Experimental

Source

lib/kinesis.ts

Example

declare const sourceQueue: sqs.Queue;
declare const targetStream: kinesis.Stream;

const streamTarget = new targets.KinesisTarget(targetStream, {
    partitionKey: 'pk',
});

const pipe = new pipes.Pipe(this, 'Pipe', {
    source: new SqsSource(sourceQueue),
    target: streamTarget,
});

Properties

inputTransformation?optionalIInputTransformationinput_transformation?optionalIInputTransformationinputTransformation?optionalIInputTransformationInputTransformation?optionalIInputTransformationInputTransformation?optionalIInputTransformation= none#

The input transformation to apply to the message before sending it to the target.

partitionKeystringpartition_keystrpartitionKeyStringPartitionKeystringPartitionKey*stringrequired#

Determines which shard in the stream the data record is assigned to.