SourceParameters

class aws_cdk.aws_pipes_alpha.SourceParameters(*, active_mq_broker_parameters=None, dynamo_db_stream_parameters=None, kinesis_stream_parameters=None, managed_streaming_kafka_parameters=None, rabbit_mq_broker_parameters=None, self_managed_kafka_parameters=None, sqs_queue_parameters=None)

Bases: object

(experimental) Source properties.

Parameters:

active_mq_broker_parameters (Union[PipeSourceActiveMQBrokerParametersProperty, Dict[str, Any], None]) – (experimental) ActiveMQBroker configuration parameters. Default: - none
dynamo_db_stream_parameters (Union[PipeSourceDynamoDBStreamParametersProperty, Dict[str, Any], None]) – (experimental) DynamoDB stream configuration parameters. Default: - none
kinesis_stream_parameters (Union[PipeSourceKinesisStreamParametersProperty, Dict[str, Any], None]) – (experimental) Kinesis stream configuration parameters. Default: - none
managed_streaming_kafka_parameters (Union[PipeSourceManagedStreamingKafkaParametersProperty, Dict[str, Any], None]) – (experimental) Managed streaming Kafka configuration parameters. Default: - none
rabbit_mq_broker_parameters (Union[PipeSourceRabbitMQBrokerParametersProperty, Dict[str, Any], None]) – (experimental) RabbitMQ broker configuration parameters. Default: - none
self_managed_kafka_parameters (Union[PipeSourceSelfManagedKafkaParametersProperty, Dict[str, Any], None]) – (experimental) Self-managed Kafka configuration parameters. Default: - none
sqs_queue_parameters (Union[PipeSourceSqsQueueParametersProperty, Dict[str, Any], None]) – (experimental) SQS queue configuration parameters. Default: - none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-event-source.html

Stability:

experimental

ExampleMetadata:

infused

Example:

# source_queue: sqs.Queue
# target_queue: sqs.Queue


target_input_transformation = pipes.InputTransformation.from_event_path("$.body.payload")

pipe = pipes.Pipe(self, "Pipe",
    source=SqsSource(source_queue),
    target=SqsTarget(target_queue, {
        "input_transformation": target_input_transformation
    })
)

Attributes

active_mq_broker_parameters

(experimental) ActiveMQBroker configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-mq.html

Stability:

experimental

dynamo_db_stream_parameters

(experimental) DynamoDB stream configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-dynamodb.html

Stability:

experimental

kinesis_stream_parameters

(experimental) Kinesis stream configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kinesis.html

Stability:

experimental

managed_streaming_kafka_parameters

(experimental) Managed streaming Kafka configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-msk.html

Stability:

experimental

rabbit_mq_broker_parameters

(experimental) RabbitMQ broker configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-mq.html

Stability:

experimental

self_managed_kafka_parameters

(experimental) Self-managed Kafka configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-kafka.html

Stability:

experimental

sqs_queue_parameters

(experimental) SQS queue configuration parameters.

Default:

none

See:

https://docs.aws.amazon.com/eventbridge/latest/userguide/eb-pipes-sqs.html

Stability:

experimental