KINESISANALYTICS
AddApplicationCloudWatchLoggingOption
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.CloudWatchLoggingOption.LogStreamARN == STRING
input.Body.CloudWatchLoggingOption.RoleARN == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
AddApplicationInput
enum_RecordFormatType := [ "JSON", "CSV" ]
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.Input.NamePrefix == STRING
input.Body.Input.InputProcessingConfiguration.InputLambdaProcessor.ResourceARN == STRING
input.Body.Input.InputProcessingConfiguration.InputLambdaProcessor.RoleARN == STRING
input.Body.Input.KinesisStreamsInput.ResourceARN == STRING
input.Body.Input.KinesisStreamsInput.RoleARN == STRING
input.Body.Input.KinesisFirehoseInput.ResourceARN == STRING
input.Body.Input.KinesisFirehoseInput.RoleARN == STRING
input.Body.Input.InputParallelism.Count == INTEGER
input.Body.Input.InputSchema.RecordFormat.RecordFormatType == enum_RecordFormatType[_]
input.Body.Input.InputSchema.RecordFormat.MappingParameters.JSONMappingParameters.RecordRowPath == STRING
input.Body.Input.InputSchema.RecordFormat.MappingParameters.CSVMappingParameters.RecordRowDelimiter == STRING
input.Body.Input.InputSchema.RecordFormat.MappingParameters.CSVMappingParameters.RecordColumnDelimiter == STRING
input.Body.Input.InputSchema.RecordEncoding == STRING
input.Body.Input.InputSchema.RecordColumns[_].Name == STRING
input.Body.Input.InputSchema.RecordColumns[_].Mapping == STRING
input.Body.Input.InputSchema.RecordColumns[_].SqlType == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
AddApplicationInputProcessingConfiguration
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.InputId == STRING
input.Body.InputProcessingConfiguration.InputLambdaProcessor.ResourceARN == STRING
input.Body.InputProcessingConfiguration.InputLambdaProcessor.RoleARN == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
AddApplicationOutput
enum_RecordFormatType := [ "JSON", "CSV" ]
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.Output.Name == STRING
input.Body.Output.KinesisStreamsOutput.ResourceARN == STRING
input.Body.Output.KinesisStreamsOutput.RoleARN == STRING
input.Body.Output.KinesisFirehoseOutput.ResourceARN == STRING
input.Body.Output.KinesisFirehoseOutput.RoleARN == STRING
input.Body.Output.LambdaOutput.ResourceARN == STRING
input.Body.Output.LambdaOutput.RoleARN == STRING
input.Body.Output.DestinationSchema.RecordFormatType == enum_RecordFormatType[_]
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
AddApplicationReferenceDataSource
enum_RecordFormatType := [ "JSON", "CSV" ]
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.ReferenceDataSource.TableName == STRING
input.Body.ReferenceDataSource.S3ReferenceDataSource.BucketARN == STRING
input.Body.ReferenceDataSource.S3ReferenceDataSource.FileKey == STRING
input.Body.ReferenceDataSource.S3ReferenceDataSource.ReferenceRoleARN == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordFormat.RecordFormatType == enum_RecordFormatType[_]
input.Body.ReferenceDataSource.ReferenceSchema.RecordFormat.MappingParameters.JSONMappingParameters.RecordRowPath == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordFormat.MappingParameters.CSVMappingParameters.RecordRowDelimiter == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordFormat.MappingParameters.CSVMappingParameters.RecordColumnDelimiter == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordEncoding == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordColumns[_].Name == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordColumns[_].Mapping == STRING
input.Body.ReferenceDataSource.ReferenceSchema.RecordColumns[_].SqlType == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
CreateApplication
enum_RecordFormatType := [ "JSON", "CSV" ]
valid {
input.Body.ApplicationName == STRING
input.Body.ApplicationDescription == STRING
input.Body.Inputs[_].NamePrefix == STRING
input.Body.Inputs[_].InputProcessingConfiguration.InputLambdaProcessor.ResourceARN == STRING
input.Body.Inputs[_].InputProcessingConfiguration.InputLambdaProcessor.RoleARN == STRING
input.Body.Inputs[_].KinesisStreamsInput.ResourceARN == STRING
input.Body.Inputs[_].KinesisStreamsInput.RoleARN == STRING
input.Body.Inputs[_].KinesisFirehoseInput.ResourceARN == STRING
input.Body.Inputs[_].KinesisFirehoseInput.RoleARN == STRING
input.Body.Inputs[_].InputParallelism.Count == INTEGER
input.Body.Inputs[_].InputSchema.RecordFormat.RecordFormatType == enum_RecordFormatType[_]
input.Body.Inputs[_].InputSchema.RecordFormat.MappingParameters.JSONMappingParameters.RecordRowPath == STRING
input.Body.Inputs[_].InputSchema.RecordFormat.MappingParameters.CSVMappingParameters.RecordRowDelimiter == STRING
input.Body.Inputs[_].InputSchema.RecordFormat.MappingParameters.CSVMappingParameters.RecordColumnDelimiter == STRING
input.Body.Inputs[_].InputSchema.RecordEncoding == STRING
input.Body.Inputs[_].InputSchema.RecordColumns[_].Name == STRING
input.Body.Inputs[_].InputSchema.RecordColumns[_].Mapping == STRING
input.Body.Inputs[_].InputSchema.RecordColumns[_].SqlType == STRING
input.Body.Outputs[_].Name == STRING
input.Body.Outputs[_].KinesisStreamsOutput.ResourceARN == STRING
input.Body.Outputs[_].KinesisStreamsOutput.RoleARN == STRING
input.Body.Outputs[_].KinesisFirehoseOutput.ResourceARN == STRING
input.Body.Outputs[_].KinesisFirehoseOutput.RoleARN == STRING
input.Body.Outputs[_].LambdaOutput.ResourceARN == STRING
input.Body.Outputs[_].LambdaOutput.RoleARN == STRING
input.Body.Outputs[_].DestinationSchema.RecordFormatType == enum_RecordFormatType[_]
input.Body.CloudWatchLoggingOptions[_].LogStreamARN == STRING
input.Body.CloudWatchLoggingOptions[_].RoleARN == STRING
input.Body.ApplicationCode == STRING
input.Body.Tags[_].Key == STRING
input.Body.Tags[_].Value == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DeleteApplication
valid {
input.Body.ApplicationName == STRING
input.Body.CreateTimestamp == TIMESTAMP
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DeleteApplicationCloudWatchLoggingOption
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.CloudWatchLoggingOptionId == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DeleteApplicationInputProcessingConfiguration
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.InputId == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DeleteApplicationOutput
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.OutputId == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DeleteApplicationReferenceDataSource
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.ReferenceId == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DescribeApplication
valid {
input.Body.ApplicationName == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
DiscoverInputSchema
enum_InputStartingPosition := [ "NOW", "TRIM_HORIZON", "LAST_STOPPED_POINT" ]
valid {
input.Body.ResourceARN == STRING
input.Body.RoleARN == STRING
input.Body.InputStartingPositionConfiguration.InputStartingPosition == enum_InputStartingPosition[_]
input.Body.S3Configuration.RoleARN == STRING
input.Body.S3Configuration.BucketARN == STRING
input.Body.S3Configuration.FileKey == STRING
input.Body.InputProcessingConfiguration.InputLambdaProcessor.ResourceARN == STRING
input.Body.InputProcessingConfiguration.InputLambdaProcessor.RoleARN == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
ListApplications
valid {
input.Body.Limit == INTEGER
input.Body.ExclusiveStartApplicationName == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
ListTagsForResource
valid {
input.Body.ResourceARN == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
StartApplication
enum_InputStartingPosition := [ "NOW", "TRIM_HORIZON", "LAST_STOPPED_POINT" ]
valid {
input.Body.ApplicationName == STRING
input.Body.InputConfigurations[_].Id == STRING
input.Body.InputConfigurations[_].InputStartingPositionConfiguration.InputStartingPosition == enum_InputStartingPosition[_]
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
StopApplication
valid {
input.Body.ApplicationName == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
TagResource
valid {
input.Body.ResourceARN == STRING
input.Body.Tags[_].Key == STRING
input.Body.Tags[_].Value == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
UntagResource
valid {
input.Body.ResourceARN == STRING
input.Body.TagKeys[_] == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
UpdateApplication
enum_RecordFormatType := [ "JSON", "CSV" ]
valid {
input.Body.ApplicationName == STRING
input.Body.CurrentApplicationVersionId == LONG
input.Body.ApplicationUpdate.InputUpdates[_].InputId == STRING
input.Body.ApplicationUpdate.InputUpdates[_].NamePrefixUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputProcessingConfigurationUpdate.InputLambdaProcessorUpdate.ResourceARNUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputProcessingConfigurationUpdate.InputLambdaProcessorUpdate.RoleARNUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].KinesisStreamsInputUpdate.ResourceARNUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].KinesisStreamsInputUpdate.RoleARNUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].KinesisFirehoseInputUpdate.ResourceARNUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].KinesisFirehoseInputUpdate.RoleARNUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordFormatUpdate.RecordFormatType == enum_RecordFormatType[_]
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordFormatUpdate.MappingParameters.JSONMappingParameters.RecordRowPath == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordFormatUpdate.MappingParameters.CSVMappingParameters.RecordRowDelimiter == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordFormatUpdate.MappingParameters.CSVMappingParameters.RecordColumnDelimiter == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordEncodingUpdate == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordColumnUpdates[_].Name == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordColumnUpdates[_].Mapping == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputSchemaUpdate.RecordColumnUpdates[_].SqlType == STRING
input.Body.ApplicationUpdate.InputUpdates[_].InputParallelismUpdate.CountUpdate == INTEGER
input.Body.ApplicationUpdate.ApplicationCodeUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].OutputId == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].NameUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].KinesisStreamsOutputUpdate.ResourceARNUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].KinesisStreamsOutputUpdate.RoleARNUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].KinesisFirehoseOutputUpdate.ResourceARNUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].KinesisFirehoseOutputUpdate.RoleARNUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].LambdaOutputUpdate.ResourceARNUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].LambdaOutputUpdate.RoleARNUpdate == STRING
input.Body.ApplicationUpdate.OutputUpdates[_].DestinationSchemaUpdate.RecordFormatType == enum_RecordFormatType[_]
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceId == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].TableNameUpdate == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].S3ReferenceDataSourceUpdate.BucketARNUpdate == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].S3ReferenceDataSourceUpdate.FileKeyUpdate == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].S3ReferenceDataSourceUpdate.ReferenceRoleARNUpdate == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordFormat.RecordFormatType == enum_RecordFormatType[_]
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordFormat.MappingParameters.JSONMappingParameters.RecordRowPath == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordFormat.MappingParameters.CSVMappingParameters.RecordRowDelimiter == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordFormat.MappingParameters.CSVMappingParameters.RecordColumnDelimiter == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordEncoding == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordColumns[_].Name == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordColumns[_].Mapping == STRING
input.Body.ApplicationUpdate.ReferenceDataSourceUpdates[_].ReferenceSchemaUpdate.RecordColumns[_].SqlType == STRING
input.Body.ApplicationUpdate.CloudWatchLoggingOptionUpdates[_].CloudWatchLoggingOptionId == STRING
input.Body.ApplicationUpdate.CloudWatchLoggingOptionUpdates[_].LogStreamARNUpdate == STRING
input.Body.ApplicationUpdate.CloudWatchLoggingOptionUpdates[_].RoleARNUpdate == STRING
input.ProviderMetadata.Account == STRING
input.ProviderMetadata.AccessKeyId == STRING
input.ProviderMetadata.Region == STRING
}
Updated 12 days ago