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
}