AWS CDK Reference

Appearance

v2.275.0

Experimental

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

SourceParameters Struct ​

Source properties.

Stability
Experimental
Source
lib/source.ts

Example ​

ts
declare const sourceQueue: sqs.Queue;
declare const targetFunction: lambda.IFunction;

const pipeTarget = new targets.LambdaFunction(targetFunction, {
  invocationType: targets.LambdaFunctionInvocationType.FIRE_AND_FORGET,
});

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

Properties ​

activeMqBrokerParametersoptionalCfnPipe.PipeSourceActiveMQBrokerParametersPropertyactive_mq_broker_parametersoptionalPipeSourceActiveMQBrokerParametersPropertyactiveMqBrokerParametersoptionalPipeSourceActiveMQBrokerParametersPropertyActiveMqBrokerParametersoptionalPipeSourceActiveMQBrokerParametersPropertyActiveMqBrokerParametersoptionalPipeSourceActiveMQBrokerParametersProperty= none#
ActiveMQBroker configuration parameters.
dynamoDbStreamParametersoptionalCfnPipe.PipeSourceDynamoDBStreamParametersPropertydynamo_db_stream_parametersoptionalPipeSourceDynamoDBStreamParametersPropertydynamoDbStreamParametersoptionalPipeSourceDynamoDBStreamParametersPropertyDynamoDbStreamParametersoptionalPipeSourceDynamoDBStreamParametersPropertyDynamoDbStreamParametersoptionalPipeSourceDynamoDBStreamParametersProperty= none#
DynamoDB stream configuration parameters.
kinesisStreamParametersoptionalCfnPipe.PipeSourceKinesisStreamParametersPropertykinesis_stream_parametersoptionalPipeSourceKinesisStreamParametersPropertykinesisStreamParametersoptionalPipeSourceKinesisStreamParametersPropertyKinesisStreamParametersoptionalPipeSourceKinesisStreamParametersPropertyKinesisStreamParametersoptionalPipeSourceKinesisStreamParametersProperty= none#
Kinesis stream configuration parameters.
managedStreamingKafkaParametersoptionalCfnPipe.PipeSourceManagedStreamingKafkaParametersPropertymanaged_streaming_kafka_parametersoptionalPipeSourceManagedStreamingKafkaParametersPropertymanagedStreamingKafkaParametersoptionalPipeSourceManagedStreamingKafkaParametersPropertyManagedStreamingKafkaParametersoptionalPipeSourceManagedStreamingKafkaParametersPropertyManagedStreamingKafkaParametersoptionalPipeSourceManagedStreamingKafkaParametersProperty= none#
Managed streaming Kafka configuration parameters.
rabbitMqBrokerParametersoptionalCfnPipe.PipeSourceRabbitMQBrokerParametersPropertyrabbit_mq_broker_parametersoptionalPipeSourceRabbitMQBrokerParametersPropertyrabbitMqBrokerParametersoptionalPipeSourceRabbitMQBrokerParametersPropertyRabbitMqBrokerParametersoptionalPipeSourceRabbitMQBrokerParametersPropertyRabbitMqBrokerParametersoptionalPipeSourceRabbitMQBrokerParametersProperty= none#
RabbitMQ broker configuration parameters.
selfManagedKafkaParametersoptionalCfnPipe.PipeSourceSelfManagedKafkaParametersPropertyself_managed_kafka_parametersoptionalPipeSourceSelfManagedKafkaParametersPropertyselfManagedKafkaParametersoptionalPipeSourceSelfManagedKafkaParametersPropertySelfManagedKafkaParametersoptionalPipeSourceSelfManagedKafkaParametersPropertySelfManagedKafkaParametersoptionalPipeSourceSelfManagedKafkaParametersProperty= none#
Self-managed Kafka configuration parameters.
sqsQueueParametersoptionalCfnPipe.PipeSourceSqsQueueParametersPropertysqs_queue_parametersoptionalPipeSourceSqsQueueParametersPropertysqsQueueParametersoptionalPipeSourceSqsQueueParametersPropertySqsQueueParametersoptionalPipeSourceSqsQueueParametersPropertySqsQueueParametersoptionalPipeSourceSqsQueueParametersProperty= none#
SQS queue configuration parameters.