PIPES

Suggest Edits
docs.aws.amazon.com
AWS documentation

CreatePipe

enum_AssignPublicIp := [ "ENABLED", "DISABLED" ]
enum_BatchJobDependencyType := [ "N_TO_N", "SEQUENTIAL" ]
enum_BatchResourceRequirementType := [ "GPU", "MEMORY", "VCPU" ]
enum_DynamoDBStreamStartPosition := [ "TRIM_HORIZON", "LATEST" ]
enum_EcsEnvironmentFileType := [ "s3" ]
enum_EcsResourceRequirementType := [ "GPU", "InferenceAccelerator" ]
enum_IncludeExecutionDataOption := [ "ALL" ]
enum_KinesisStreamStartPosition := [ "TRIM_HORIZON", "LATEST", "AT_TIMESTAMP" ]
enum_LaunchType := [ "EC2", "FARGATE", "EXTERNAL" ]
enum_LogLevel := [ "OFF", "ERROR", "INFO", "TRACE" ]
enum_MSKStartPosition := [ "TRIM_HORIZON", "LATEST" ]
enum_OnPartialBatchItemFailureStreams := [ "AUTOMATIC_BISECT" ]
enum_PipeTargetInvocationType := [ "REQUEST_RESPONSE", "FIRE_AND_FORGET" ]
enum_PlacementConstraintType := [ "distinctInstance", "memberOf" ]
enum_PlacementStrategyType := [ "random", "spread", "binpack" ]
enum_PropagateTags := [ "TASK_DEFINITION" ]
enum_RequestedPipeState := [ "RUNNING", "STOPPED" ]
enum_S3OutputFormat := [ "json", "plain", "w3c" ]
enum_SelfManagedKafkaStartPosition := [ "TRIM_HORIZON", "LATEST" ]

valid {
    input.Body.Description == STRING
    input.Body.DesiredState == enum_RequestedPipeState[_]
    input.Body.Enrichment == STRING
    input.Body.EnrichmentParameters.HttpParameters.HeaderParameters.STRING == STRING
    input.Body.EnrichmentParameters.HttpParameters.PathParameterValues[_] == STRING
    input.Body.EnrichmentParameters.HttpParameters.QueryStringParameters.STRING == STRING
    input.Body.EnrichmentParameters.InputTemplate == STRING
    input.Body.LogConfiguration.CloudwatchLogsLogDestination.LogGroupArn == STRING
    input.Body.LogConfiguration.FirehoseLogDestination.DeliveryStreamArn == STRING
    input.Body.LogConfiguration.IncludeExecutionData[_] == enum_IncludeExecutionDataOption[_]
    input.Body.LogConfiguration.Level == enum_LogLevel[_]
    input.Body.LogConfiguration.S3LogDestination.BucketName == STRING
    input.Body.LogConfiguration.S3LogDestination.BucketOwner == STRING
    input.Body.LogConfiguration.S3LogDestination.OutputFormat == enum_S3OutputFormat[_]
    input.Body.LogConfiguration.S3LogDestination.Prefix == STRING
    input.Body.RoleArn == STRING
    input.Body.Source == STRING
    input.Body.SourceParameters.ActiveMQBrokerParameters.BatchSize == INTEGER
    input.Body.SourceParameters.ActiveMQBrokerParameters.Credentials.BasicAuth == STRING
    input.Body.SourceParameters.ActiveMQBrokerParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.ActiveMQBrokerParameters.QueueName == STRING
    input.Body.SourceParameters.DynamoDBStreamParameters.BatchSize == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.DeadLetterConfig.Arn == STRING
    input.Body.SourceParameters.DynamoDBStreamParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.MaximumRecordAgeInSeconds == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.MaximumRetryAttempts == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.OnPartialBatchItemFailure == enum_OnPartialBatchItemFailureStreams[_]
    input.Body.SourceParameters.DynamoDBStreamParameters.ParallelizationFactor == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.StartingPosition == enum_DynamoDBStreamStartPosition[_]
    input.Body.SourceParameters.FilterCriteria.Filters[_].Pattern == STRING
    input.Body.SourceParameters.KinesisStreamParameters.BatchSize == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.DeadLetterConfig.Arn == STRING
    input.Body.SourceParameters.KinesisStreamParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.MaximumRecordAgeInSeconds == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.MaximumRetryAttempts == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.OnPartialBatchItemFailure == enum_OnPartialBatchItemFailureStreams[_]
    input.Body.SourceParameters.KinesisStreamParameters.ParallelizationFactor == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.StartingPosition == enum_KinesisStreamStartPosition[_]
    input.Body.SourceParameters.KinesisStreamParameters.StartingPositionTimestamp == TIMESTAMP
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.BatchSize == INTEGER
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.ConsumerGroupID == STRING
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.Credentials.ClientCertificateTlsAuth == STRING
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.Credentials.SaslScram512Auth == STRING
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.StartingPosition == enum_MSKStartPosition[_]
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.TopicName == STRING
    input.Body.SourceParameters.RabbitMQBrokerParameters.BatchSize == INTEGER
    input.Body.SourceParameters.RabbitMQBrokerParameters.Credentials.BasicAuth == STRING
    input.Body.SourceParameters.RabbitMQBrokerParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.RabbitMQBrokerParameters.QueueName == STRING
    input.Body.SourceParameters.RabbitMQBrokerParameters.VirtualHost == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.AdditionalBootstrapServers[_] == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.BatchSize == INTEGER
    input.Body.SourceParameters.SelfManagedKafkaParameters.ConsumerGroupID == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.BasicAuth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.ClientCertificateTlsAuth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.SaslScram256Auth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.SaslScram512Auth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.SelfManagedKafkaParameters.ServerRootCaCertificate == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.StartingPosition == enum_SelfManagedKafkaStartPosition[_]
    input.Body.SourceParameters.SelfManagedKafkaParameters.TopicName == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Vpc.SecurityGroup[_] == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Vpc.Subnets[_] == STRING
    input.Body.SourceParameters.SqsQueueParameters.BatchSize == INTEGER
    input.Body.SourceParameters.SqsQueueParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.Tags.STRING == STRING
    input.Body.Target == STRING
    input.Body.TargetParameters.BatchJobParameters.ArrayProperties.Size == INTEGER
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.Command[_] == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.Environment[_].Name == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.Environment[_].Value == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.InstanceType == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.ResourceRequirements[_].Type == enum_BatchResourceRequirementType[_]
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.ResourceRequirements[_].Value == STRING
    input.Body.TargetParameters.BatchJobParameters.DependsOn[_].JobId == STRING
    input.Body.TargetParameters.BatchJobParameters.DependsOn[_].Type == enum_BatchJobDependencyType[_]
    input.Body.TargetParameters.BatchJobParameters.JobDefinition == STRING
    input.Body.TargetParameters.BatchJobParameters.JobName == STRING
    input.Body.TargetParameters.BatchJobParameters.Parameters.STRING == STRING
    input.Body.TargetParameters.BatchJobParameters.RetryStrategy.Attempts == INTEGER
    input.Body.TargetParameters.CloudWatchLogsParameters.LogStreamName == STRING
    input.Body.TargetParameters.CloudWatchLogsParameters.Timestamp == STRING
    input.Body.TargetParameters.EcsTaskParameters.CapacityProviderStrategy[_].base == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.CapacityProviderStrategy[_].capacityProvider == STRING
    input.Body.TargetParameters.EcsTaskParameters.CapacityProviderStrategy[_].weight == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.EnableECSManagedTags == BOOLEAN
    input.Body.TargetParameters.EcsTaskParameters.EnableExecuteCommand == BOOLEAN
    input.Body.TargetParameters.EcsTaskParameters.Group == STRING
    input.Body.TargetParameters.EcsTaskParameters.LaunchType == enum_LaunchType[_]
    input.Body.TargetParameters.EcsTaskParameters.NetworkConfiguration.awsvpcConfiguration.AssignPublicIp == enum_AssignPublicIp[_]
    input.Body.TargetParameters.EcsTaskParameters.NetworkConfiguration.awsvpcConfiguration.SecurityGroups[_] == STRING
    input.Body.TargetParameters.EcsTaskParameters.NetworkConfiguration.awsvpcConfiguration.Subnets[_] == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Command[_] == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Cpu == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Environment[_].name == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Environment[_].value == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].EnvironmentFiles[_].type == enum_EcsEnvironmentFileType[_]
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].EnvironmentFiles[_].value == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Memory == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].MemoryReservation == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Name == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].ResourceRequirements[_].type == enum_EcsResourceRequirementType[_]
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].ResourceRequirements[_].value == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.Cpu == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.EphemeralStorage.sizeInGiB == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ExecutionRoleArn == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.InferenceAcceleratorOverrides[_].deviceName == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.InferenceAcceleratorOverrides[_].deviceType == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.Memory == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.TaskRoleArn == STRING
    input.Body.TargetParameters.EcsTaskParameters.PlacementConstraints[_].expression == STRING
    input.Body.TargetParameters.EcsTaskParameters.PlacementConstraints[_].type == enum_PlacementConstraintType[_]
    input.Body.TargetParameters.EcsTaskParameters.PlacementStrategy[_].field == STRING
    input.Body.TargetParameters.EcsTaskParameters.PlacementStrategy[_].type == enum_PlacementStrategyType[_]
    input.Body.TargetParameters.EcsTaskParameters.PlatformVersion == STRING
    input.Body.TargetParameters.EcsTaskParameters.PropagateTags == enum_PropagateTags[_]
    input.Body.TargetParameters.EcsTaskParameters.ReferenceId == STRING
    input.Body.TargetParameters.EcsTaskParameters.Tags[_].Key == STRING
    input.Body.TargetParameters.EcsTaskParameters.Tags[_].Value == STRING
    input.Body.TargetParameters.EcsTaskParameters.TaskCount == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.TaskDefinitionArn == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.DetailType == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.EndpointId == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.Resources[_] == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.Source == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.Time == STRING
    input.Body.TargetParameters.HttpParameters.HeaderParameters.STRING == STRING
    input.Body.TargetParameters.HttpParameters.PathParameterValues[_] == STRING
    input.Body.TargetParameters.HttpParameters.QueryStringParameters.STRING == STRING
    input.Body.TargetParameters.InputTemplate == STRING
    input.Body.TargetParameters.KinesisStreamParameters.PartitionKey == STRING
    input.Body.TargetParameters.LambdaFunctionParameters.InvocationType == enum_PipeTargetInvocationType[_]
    input.Body.TargetParameters.RedshiftDataParameters.Database == STRING
    input.Body.TargetParameters.RedshiftDataParameters.DbUser == STRING
    input.Body.TargetParameters.RedshiftDataParameters.SecretManagerArn == STRING
    input.Body.TargetParameters.RedshiftDataParameters.Sqls[_] == STRING
    input.Body.TargetParameters.RedshiftDataParameters.StatementName == STRING
    input.Body.TargetParameters.RedshiftDataParameters.WithEvent == BOOLEAN
    input.Body.TargetParameters.SageMakerPipelineParameters.PipelineParameterList[_].Name == STRING
    input.Body.TargetParameters.SageMakerPipelineParameters.PipelineParameterList[_].Value == STRING
    input.Body.TargetParameters.SqsQueueParameters.MessageDeduplicationId == STRING
    input.Body.TargetParameters.SqsQueueParameters.MessageGroupId == STRING
    input.Body.TargetParameters.StepFunctionStateMachineParameters.InvocationType == enum_PipeTargetInvocationType[_]
    input.ReqMap.Name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DeletePipe

valid {
    input.ReqMap.Name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

DescribePipe

valid {
    input.ReqMap.Name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListPipes

enum_PipeState := [ "RUNNING", "STOPPED", "CREATING", "UPDATING", "DELETING", "STARTING", "STOPPING", "CREATE_FAILED", "UPDATE_FAILED", "START_FAILED", "STOP_FAILED", "DELETE_FAILED", "CREATE_ROLLBACK_FAILED", "DELETE_ROLLBACK_FAILED", "UPDATE_ROLLBACK_FAILED" ]
enum_RequestedPipeState := [ "RUNNING", "STOPPED" ]

valid {
    input.Qs.CurrentState == enum_PipeState[_]
    input.Qs.DesiredState == enum_RequestedPipeState[_]
    input.Qs.Limit == INTEGER
    input.Qs.NamePrefix == STRING
    input.Qs.NextToken == STRING
    input.Qs.SourcePrefix == STRING
    input.Qs.TargetPrefix == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

ListTagsForResource

valid {
    input.ReqMap.resourceArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

StartPipe

valid {
    input.ReqMap.Name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

StopPipe

valid {
    input.ReqMap.Name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

TagResource

valid {
    input.Body.tags.STRING == STRING
    input.ReqMap.resourceArn == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

UntagResource

valid {
    input.ReqMap.resourceArn == STRING
    input.Qs.tagKeys[_] == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

UpdatePipe

enum_AssignPublicIp := [ "ENABLED", "DISABLED" ]
enum_BatchJobDependencyType := [ "N_TO_N", "SEQUENTIAL" ]
enum_BatchResourceRequirementType := [ "GPU", "MEMORY", "VCPU" ]
enum_EcsEnvironmentFileType := [ "s3" ]
enum_EcsResourceRequirementType := [ "GPU", "InferenceAccelerator" ]
enum_IncludeExecutionDataOption := [ "ALL" ]
enum_LaunchType := [ "EC2", "FARGATE", "EXTERNAL" ]
enum_LogLevel := [ "OFF", "ERROR", "INFO", "TRACE" ]
enum_OnPartialBatchItemFailureStreams := [ "AUTOMATIC_BISECT" ]
enum_PipeTargetInvocationType := [ "REQUEST_RESPONSE", "FIRE_AND_FORGET" ]
enum_PlacementConstraintType := [ "distinctInstance", "memberOf" ]
enum_PlacementStrategyType := [ "random", "spread", "binpack" ]
enum_PropagateTags := [ "TASK_DEFINITION" ]
enum_RequestedPipeState := [ "RUNNING", "STOPPED" ]
enum_S3OutputFormat := [ "json", "plain", "w3c" ]

valid {
    input.Body.Description == STRING
    input.Body.DesiredState == enum_RequestedPipeState[_]
    input.Body.Enrichment == STRING
    input.Body.EnrichmentParameters.HttpParameters.HeaderParameters.STRING == STRING
    input.Body.EnrichmentParameters.HttpParameters.PathParameterValues[_] == STRING
    input.Body.EnrichmentParameters.HttpParameters.QueryStringParameters.STRING == STRING
    input.Body.EnrichmentParameters.InputTemplate == STRING
    input.Body.LogConfiguration.CloudwatchLogsLogDestination.LogGroupArn == STRING
    input.Body.LogConfiguration.FirehoseLogDestination.DeliveryStreamArn == STRING
    input.Body.LogConfiguration.IncludeExecutionData[_] == enum_IncludeExecutionDataOption[_]
    input.Body.LogConfiguration.Level == enum_LogLevel[_]
    input.Body.LogConfiguration.S3LogDestination.BucketName == STRING
    input.Body.LogConfiguration.S3LogDestination.BucketOwner == STRING
    input.Body.LogConfiguration.S3LogDestination.OutputFormat == enum_S3OutputFormat[_]
    input.Body.LogConfiguration.S3LogDestination.Prefix == STRING
    input.Body.RoleArn == STRING
    input.Body.SourceParameters.ActiveMQBrokerParameters.BatchSize == INTEGER
    input.Body.SourceParameters.ActiveMQBrokerParameters.Credentials.BasicAuth == STRING
    input.Body.SourceParameters.ActiveMQBrokerParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.BatchSize == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.DeadLetterConfig.Arn == STRING
    input.Body.SourceParameters.DynamoDBStreamParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.MaximumRecordAgeInSeconds == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.MaximumRetryAttempts == INTEGER
    input.Body.SourceParameters.DynamoDBStreamParameters.OnPartialBatchItemFailure == enum_OnPartialBatchItemFailureStreams[_]
    input.Body.SourceParameters.DynamoDBStreamParameters.ParallelizationFactor == INTEGER
    input.Body.SourceParameters.FilterCriteria.Filters[_].Pattern == STRING
    input.Body.SourceParameters.KinesisStreamParameters.BatchSize == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.DeadLetterConfig.Arn == STRING
    input.Body.SourceParameters.KinesisStreamParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.MaximumRecordAgeInSeconds == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.MaximumRetryAttempts == INTEGER
    input.Body.SourceParameters.KinesisStreamParameters.OnPartialBatchItemFailure == enum_OnPartialBatchItemFailureStreams[_]
    input.Body.SourceParameters.KinesisStreamParameters.ParallelizationFactor == INTEGER
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.BatchSize == INTEGER
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.Credentials.ClientCertificateTlsAuth == STRING
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.Credentials.SaslScram512Auth == STRING
    input.Body.SourceParameters.ManagedStreamingKafkaParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.RabbitMQBrokerParameters.BatchSize == INTEGER
    input.Body.SourceParameters.RabbitMQBrokerParameters.Credentials.BasicAuth == STRING
    input.Body.SourceParameters.RabbitMQBrokerParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.SelfManagedKafkaParameters.BatchSize == INTEGER
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.BasicAuth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.ClientCertificateTlsAuth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.SaslScram256Auth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Credentials.SaslScram512Auth == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.SourceParameters.SelfManagedKafkaParameters.ServerRootCaCertificate == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Vpc.SecurityGroup[_] == STRING
    input.Body.SourceParameters.SelfManagedKafkaParameters.Vpc.Subnets[_] == STRING
    input.Body.SourceParameters.SqsQueueParameters.BatchSize == INTEGER
    input.Body.SourceParameters.SqsQueueParameters.MaximumBatchingWindowInSeconds == INTEGER
    input.Body.Target == STRING
    input.Body.TargetParameters.BatchJobParameters.ArrayProperties.Size == INTEGER
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.Command[_] == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.Environment[_].Name == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.Environment[_].Value == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.InstanceType == STRING
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.ResourceRequirements[_].Type == enum_BatchResourceRequirementType[_]
    input.Body.TargetParameters.BatchJobParameters.ContainerOverrides.ResourceRequirements[_].Value == STRING
    input.Body.TargetParameters.BatchJobParameters.DependsOn[_].JobId == STRING
    input.Body.TargetParameters.BatchJobParameters.DependsOn[_].Type == enum_BatchJobDependencyType[_]
    input.Body.TargetParameters.BatchJobParameters.JobDefinition == STRING
    input.Body.TargetParameters.BatchJobParameters.JobName == STRING
    input.Body.TargetParameters.BatchJobParameters.Parameters.STRING == STRING
    input.Body.TargetParameters.BatchJobParameters.RetryStrategy.Attempts == INTEGER
    input.Body.TargetParameters.CloudWatchLogsParameters.LogStreamName == STRING
    input.Body.TargetParameters.CloudWatchLogsParameters.Timestamp == STRING
    input.Body.TargetParameters.EcsTaskParameters.CapacityProviderStrategy[_].base == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.CapacityProviderStrategy[_].capacityProvider == STRING
    input.Body.TargetParameters.EcsTaskParameters.CapacityProviderStrategy[_].weight == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.EnableECSManagedTags == BOOLEAN
    input.Body.TargetParameters.EcsTaskParameters.EnableExecuteCommand == BOOLEAN
    input.Body.TargetParameters.EcsTaskParameters.Group == STRING
    input.Body.TargetParameters.EcsTaskParameters.LaunchType == enum_LaunchType[_]
    input.Body.TargetParameters.EcsTaskParameters.NetworkConfiguration.awsvpcConfiguration.AssignPublicIp == enum_AssignPublicIp[_]
    input.Body.TargetParameters.EcsTaskParameters.NetworkConfiguration.awsvpcConfiguration.SecurityGroups[_] == STRING
    input.Body.TargetParameters.EcsTaskParameters.NetworkConfiguration.awsvpcConfiguration.Subnets[_] == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Command[_] == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Cpu == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Environment[_].name == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Environment[_].value == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].EnvironmentFiles[_].type == enum_EcsEnvironmentFileType[_]
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].EnvironmentFiles[_].value == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Memory == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].MemoryReservation == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].Name == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].ResourceRequirements[_].type == enum_EcsResourceRequirementType[_]
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ContainerOverrides[_].ResourceRequirements[_].value == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.Cpu == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.EphemeralStorage.sizeInGiB == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.Overrides.ExecutionRoleArn == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.InferenceAcceleratorOverrides[_].deviceName == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.InferenceAcceleratorOverrides[_].deviceType == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.Memory == STRING
    input.Body.TargetParameters.EcsTaskParameters.Overrides.TaskRoleArn == STRING
    input.Body.TargetParameters.EcsTaskParameters.PlacementConstraints[_].expression == STRING
    input.Body.TargetParameters.EcsTaskParameters.PlacementConstraints[_].type == enum_PlacementConstraintType[_]
    input.Body.TargetParameters.EcsTaskParameters.PlacementStrategy[_].field == STRING
    input.Body.TargetParameters.EcsTaskParameters.PlacementStrategy[_].type == enum_PlacementStrategyType[_]
    input.Body.TargetParameters.EcsTaskParameters.PlatformVersion == STRING
    input.Body.TargetParameters.EcsTaskParameters.PropagateTags == enum_PropagateTags[_]
    input.Body.TargetParameters.EcsTaskParameters.ReferenceId == STRING
    input.Body.TargetParameters.EcsTaskParameters.Tags[_].Key == STRING
    input.Body.TargetParameters.EcsTaskParameters.Tags[_].Value == STRING
    input.Body.TargetParameters.EcsTaskParameters.TaskCount == INTEGER
    input.Body.TargetParameters.EcsTaskParameters.TaskDefinitionArn == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.DetailType == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.EndpointId == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.Resources[_] == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.Source == STRING
    input.Body.TargetParameters.EventBridgeEventBusParameters.Time == STRING
    input.Body.TargetParameters.HttpParameters.HeaderParameters.STRING == STRING
    input.Body.TargetParameters.HttpParameters.PathParameterValues[_] == STRING
    input.Body.TargetParameters.HttpParameters.QueryStringParameters.STRING == STRING
    input.Body.TargetParameters.InputTemplate == STRING
    input.Body.TargetParameters.KinesisStreamParameters.PartitionKey == STRING
    input.Body.TargetParameters.LambdaFunctionParameters.InvocationType == enum_PipeTargetInvocationType[_]
    input.Body.TargetParameters.RedshiftDataParameters.Database == STRING
    input.Body.TargetParameters.RedshiftDataParameters.DbUser == STRING
    input.Body.TargetParameters.RedshiftDataParameters.SecretManagerArn == STRING
    input.Body.TargetParameters.RedshiftDataParameters.Sqls[_] == STRING
    input.Body.TargetParameters.RedshiftDataParameters.StatementName == STRING
    input.Body.TargetParameters.RedshiftDataParameters.WithEvent == BOOLEAN
    input.Body.TargetParameters.SageMakerPipelineParameters.PipelineParameterList[_].Name == STRING
    input.Body.TargetParameters.SageMakerPipelineParameters.PipelineParameterList[_].Value == STRING
    input.Body.TargetParameters.SqsQueueParameters.MessageDeduplicationId == STRING
    input.Body.TargetParameters.SqsQueueParameters.MessageGroupId == STRING
    input.Body.TargetParameters.StepFunctionStateMachineParameters.InvocationType == enum_PipeTargetInvocationType[_]
    input.ReqMap.Name == STRING
    input.ProviderMetadata.Account == STRING
    input.ProviderMetadata.AccessKeyId == STRING
    input.ProviderMetadata.Region == STRING
}

Updated 1 day ago