AwsEventbridgePipeSourceParametersArgs

interface AwsEventbridgePipeSourceParametersArgs {
activeMqBroker?: AwsEventbridgePipeSourceActiveMqBrokerArgs;
dynamodbStream?: AwsEventbridgePipeSourceDynamodbStreamArgs;
filterCriteria?: AwsEventbridgePipeSourceFilterCriteriaArgs;
kinesisStream?: AwsEventbridgePipeSourceKinesisStreamArgs;
managedStreamingKafka?: AwsEventbridgePipeSourceManagedStreamingKafkaArgs;
rabbitMqBroker?: AwsEventbridgePipeSourceRabbitMqBrokerArgs;
selfManagedKafka?: AwsEventbridgePipeSourceSelfManagedKafkaArgs;
sqsQueue?: AwsEventbridgePipeSourceSqsQueueArgs;
}

Source configuration for AwsEventbridgePipe.

Remarks

Use filterCriteria to drop unwanted events before they reach the enrichment step or target. Provide exactly one source-type-specific block that matches the source ARN type.

Example

CODE

const pipe = new AwsEventbridgePipe({
  name: 'myPipe',
  iamRole: pipeRole.arn,
  source: sourceQueue.arn,
  target: targetQueue.arn,
  sourceParameters: {
    filterCriteria: {
      filters: [{ pattern: JSON.stringify({ source: ['myapp'] }) }],
    },
    sqsQueue: { batchSize: 5 },
  },
});

Properties

`activeMqBroker: AwsEventbridgePipeSourceActiveMqBrokerArgs`

Parameters specific to an Amazon MQ ActiveMQ broker source.

`dynamodbStream: AwsEventbridgePipeSourceDynamodbStreamArgs`

Parameters specific to a DynamoDB Streams source.

`filterCriteria: AwsEventbridgePipeSourceFilterCriteriaArgs`

Event filter criteria applied before forwarding events downstream.

`kinesisStream: AwsEventbridgePipeSourceKinesisStreamArgs`

Parameters specific to a Kinesis Data Streams source.

`managedStreamingKafka: AwsEventbridgePipeSourceManagedStreamingKafkaArgs`

Parameters specific to an Amazon MSK source.

`rabbitMqBroker: AwsEventbridgePipeSourceRabbitMqBrokerArgs`

Parameters specific to an Amazon MQ RabbitMQ broker source.

`selfManagedKafka: AwsEventbridgePipeSourceSelfManagedKafkaArgs`

Parameters specific to a self-managed Apache Kafka source.

`sqsQueue: AwsEventbridgePipeSourceSqsQueueArgs`

Parameters specific to an SQS queue source.