Creates an Amazon Kinesis Data Analytics application. For information about creating a Kinesis Data Analytics application, see Creating an Application.
kinesisanalyticsv2_create_application(ApplicationName,
ApplicationDescription, RuntimeEnvironment, ServiceExecutionRole,
ApplicationConfiguration, CloudWatchLoggingOptions)
[required] The name of your application (for example, sample-app
).
A summary description of the application.
[required] The runtime environment for the application (SQL-1.0
or
JAVA-8-FLINK-1.5
).
[required] The IAM role used by the application to access Kinesis data streams, Kinesis Data Firehose delivery streams, Amazon S3 objects, and other external resources.
Use this parameter to configure the application.
Use this parameter to configure an Amazon CloudWatch log stream to monitor application configuration errors.
svc$create_application( ApplicationName = "string", ApplicationDescription = "string", RuntimeEnvironment = "SQL-1_0"|"FLINK-1_6", ServiceExecutionRole = "string", ApplicationConfiguration = list( SqlApplicationConfiguration = list( Inputs = list( list( NamePrefix = "string", InputProcessingConfiguration = list( InputLambdaProcessor = list( ResourceARN = "string" ) ), KinesisStreamsInput = list( ResourceARN = "string" ), KinesisFirehoseInput = list( ResourceARN = "string" ), InputParallelism = list( Count = 123 ), InputSchema = list( RecordFormat = list( RecordFormatType = "JSON"|"CSV", MappingParameters = list( JSONMappingParameters = list( RecordRowPath = "string" ), CSVMappingParameters = list( RecordRowDelimiter = "string", RecordColumnDelimiter = "string" ) ) ), RecordEncoding = "string", RecordColumns = list( list( Name = "string", Mapping = "string", SqlType = "string" ) ) ) ) ), Outputs = list( list( Name = "string", KinesisStreamsOutput = list( ResourceARN = "string" ), KinesisFirehoseOutput = list( ResourceARN = "string" ), LambdaOutput = list( ResourceARN = "string" ), DestinationSchema = list( RecordFormatType = "JSON"|"CSV" ) ) ), ReferenceDataSources = list( list( TableName = "string", S3ReferenceDataSource = list( BucketARN = "string", FileKey = "string" ), ReferenceSchema = list( RecordFormat = list( RecordFormatType = "JSON"|"CSV", MappingParameters = list( JSONMappingParameters = list( RecordRowPath = "string" ), CSVMappingParameters = list( RecordRowDelimiter = "string", RecordColumnDelimiter = "string" ) ) ), RecordEncoding = "string", RecordColumns = list( list( Name = "string", Mapping = "string", SqlType = "string" ) ) ) ) ) ), FlinkApplicationConfiguration = list( CheckpointConfiguration = list( ConfigurationType = "DEFAULT"|"CUSTOM", CheckpointingEnabled = TRUE|FALSE, CheckpointInterval = 123, MinPauseBetweenCheckpoints = 123 ), MonitoringConfiguration = list( ConfigurationType = "DEFAULT"|"CUSTOM", MetricsLevel = "APPLICATION"|"TASK"|"OPERATOR"|"PARALLELISM", LogLevel = "INFO"|"WARN"|"ERROR"|"DEBUG" ), ParallelismConfiguration = list( ConfigurationType = "DEFAULT"|"CUSTOM", Parallelism = 123, ParallelismPerKPU = 123, AutoScalingEnabled = TRUE|FALSE ) ), EnvironmentProperties = list( PropertyGroups = list( list( PropertyGroupId = "string", PropertyMap = list( "string" ) ) ) ), ApplicationCodeConfiguration = list( CodeContent = list( TextContent = "string", ZipFileContent = raw, S3ContentLocation = list( BucketARN = "string", FileKey = "string", ObjectVersion = "string" ) ), CodeContentType = "PLAINTEXT"|"ZIPFILE" ), ApplicationSnapshotConfiguration = list( SnapshotsEnabled = TRUE|FALSE ) ), CloudWatchLoggingOptions = list( list( LogStreamARN = "string" ) ) )
SQL is not enabled for this private beta release. Using SQL parameters (such as SqlApplicationConfiguration) will result in an error.