interface SourceConfig 🔹

Language	Type name
.NET	Amazon.CDK.AWS.Pipes.Alpha.SourceConfig
Go	github.com/aws/aws-cdk-go/awscdkpipesalpha/v2#SourceConfig
Java	software.amazon.awscdk.services.pipes.alpha.SourceConfig
Python	aws_cdk.aws_pipes_alpha.SourceConfig
TypeScript (source)	@aws-cdk/aws-pipes-alpha » SourceConfig

Obtainable from SourceWithDeadLetterTarget.bind(), DynamoDBSource.bind(), KinesisSource.bind(), SqsSource.bind()

Source properties.

Example

// The code below shows an example of how to instantiate this type.
// The values are placeholders you should change.
import * as pipes_alpha from '@aws-cdk/aws-pipes-alpha';
const sourceConfig: pipes_alpha.SourceConfig = {
  sourceParameters: {
    activeMqBrokerParameters: {
      credentials: {
        basicAuth: 'basicAuth',
      },
      queueName: 'queueName',

      // the properties below are optional
      batchSize: 123,
      maximumBatchingWindowInSeconds: 123,
    },
    dynamoDbStreamParameters: {
      startingPosition: 'startingPosition',

      // the properties below are optional
      batchSize: 123,
      deadLetterConfig: {
        arn: 'arn',
      },
      maximumBatchingWindowInSeconds: 123,
      maximumRecordAgeInSeconds: 123,
      maximumRetryAttempts: 123,
      onPartialBatchItemFailure: 'onPartialBatchItemFailure',
      parallelizationFactor: 123,
    },
    kinesisStreamParameters: {
      startingPosition: 'startingPosition',

      // the properties below are optional
      batchSize: 123,
      deadLetterConfig: {
        arn: 'arn',
      },
      maximumBatchingWindowInSeconds: 123,
      maximumRecordAgeInSeconds: 123,
      maximumRetryAttempts: 123,
      onPartialBatchItemFailure: 'onPartialBatchItemFailure',
      parallelizationFactor: 123,
      startingPositionTimestamp: 'startingPositionTimestamp',
    },
    managedStreamingKafkaParameters: {
      topicName: 'topicName',

      // the properties below are optional
      batchSize: 123,
      consumerGroupId: 'consumerGroupId',
      credentials: {
        clientCertificateTlsAuth: 'clientCertificateTlsAuth',
        saslScram512Auth: 'saslScram512Auth',
      },
      maximumBatchingWindowInSeconds: 123,
      startingPosition: 'startingPosition',
    },
    rabbitMqBrokerParameters: {
      credentials: {
        basicAuth: 'basicAuth',
      },
      queueName: 'queueName',

      // the properties below are optional
      batchSize: 123,
      maximumBatchingWindowInSeconds: 123,
      virtualHost: 'virtualHost',
    },
    selfManagedKafkaParameters: {
      topicName: 'topicName',

      // the properties below are optional
      additionalBootstrapServers: ['additionalBootstrapServers'],
      batchSize: 123,
      consumerGroupId: 'consumerGroupId',
      credentials: {
        basicAuth: 'basicAuth',
        clientCertificateTlsAuth: 'clientCertificateTlsAuth',
        saslScram256Auth: 'saslScram256Auth',
        saslScram512Auth: 'saslScram512Auth',
      },
      maximumBatchingWindowInSeconds: 123,
      serverRootCaCertificate: 'serverRootCaCertificate',
      startingPosition: 'startingPosition',
      vpc: {
        securityGroup: ['securityGroup'],
        subnets: ['subnets'],
      },
    },
    sqsQueueParameters: {
      batchSize: 123,
      maximumBatchingWindowInSeconds: 123,
    },
  },
};

Properties

Name	Type	Description
sourceParameters?🔹	SourceParameters	The parameters required to set up a source for your pipe.

---

sourceParameters?🔹

Type: SourceParameters (optional, default: none)

The parameters required to set up a source for your pipe.