CreateApplication - Amazon Managed Service per Apache Flink (precedentemente Amazon Kinesis Data Analytics per Apache Flink)

Le traduzioni sono generate tramite traduzione automatica. In caso di conflitto tra il contenuto di una traduzione e la versione originale in Inglese, quest'ultima prevarrà.

CreateApplication

Crea un servizio gestito per l'applicazione Apache Flink. Per informazioni sulla creazione di un servizio gestito per l'applicazione Apache Flink, vedere Creazione di un'applicazione.

Sintassi della richiesta

{ "ApplicationConfiguration": { "ApplicationCodeConfiguration": { "CodeContent": { "S3ContentLocation": { "BucketARN": "string", "FileKey": "string", "ObjectVersion": "string" }, "TextContent": "string", "ZipFileContent": blob }, "CodeContentType": "string" }, "ApplicationSnapshotConfiguration": { "SnapshotsEnabled": boolean }, "ApplicationSystemRollbackConfiguration": { "RollbackEnabled": boolean }, "EnvironmentProperties": { "PropertyGroups": [ { "PropertyGroupId": "string", "PropertyMap": { "string" : "string" } } ] }, "FlinkApplicationConfiguration": { "CheckpointConfiguration": { "CheckpointingEnabled": boolean, "CheckpointInterval": number, "ConfigurationType": "string", "MinPauseBetweenCheckpoints": number }, "MonitoringConfiguration": { "ConfigurationType": "string", "LogLevel": "string", "MetricsLevel": "string" }, "ParallelismConfiguration": { "AutoScalingEnabled": boolean, "ConfigurationType": "string", "Parallelism": number, "ParallelismPerKPU": number } }, "SqlApplicationConfiguration": { "Inputs": [ { "InputParallelism": { "Count": number }, "InputProcessingConfiguration": { "InputLambdaProcessor": { "ResourceARN": "string" } }, "InputSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "KinesisFirehoseInput": { "ResourceARN": "string" }, "KinesisStreamsInput": { "ResourceARN": "string" }, "NamePrefix": "string" } ], "Outputs": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutput": { "ResourceARN": "string" }, "KinesisStreamsOutput": { "ResourceARN": "string" }, "LambdaOutput": { "ResourceARN": "string" }, "Name": "string" } ], "ReferenceDataSources": [ { "ReferenceSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "S3ReferenceDataSource": { "BucketARN": "string", "FileKey": "string" }, "TableName": "string" } ] }, "VpcConfigurations": [ { "SecurityGroupIds": [ "string" ], "SubnetIds": [ "string" ] } ], "ZeppelinApplicationConfiguration": { "CatalogConfiguration": { "GlueDataCatalogConfiguration": { "DatabaseARN": "string" } }, "CustomArtifactsConfiguration": [ { "ArtifactType": "string", "MavenReference": { "ArtifactId": "string", "GroupId": "string", "Version": "string" }, "S3ContentLocation": { "BucketARN": "string", "FileKey": "string", "ObjectVersion": "string" } } ], "DeployAsApplicationConfiguration": { "S3ContentLocation": { "BasePath": "string", "BucketARN": "string" } }, "MonitoringConfiguration": { "LogLevel": "string" } } }, "ApplicationDescription": "string", "ApplicationMode": "string", "ApplicationName": "string", "CloudWatchLoggingOptions": [ { "LogStreamARN": "string" } ], "RuntimeEnvironment": "string", "ServiceExecutionRole": "string", "Tags": [ { "Key": "string", "Value": "string" } ] }

Parametri della richiesta

La richiesta accetta i seguenti dati in formato JSON.

ApplicationConfiguration

Utilizza questo parametro per configurare l'applicazione.

Tipo: oggetto ApplicationConfiguration

Campo obbligatorio: no

ApplicationDescription

Una descrizione riassuntiva dell'applicazione.

▬Tipo: stringa

Limitazioni di lunghezza: lunghezza minima di 0. La lunghezza massima è 1024 caratteri.

Campo obbligatorio: no

ApplicationMode

Utilizzate la STREAMING modalità per creare un servizio gestito per l'applicazione Apache Flink. Per creare un servizio gestito per il notebook Apache Flink Studio, utilizzate la modalità. INTERACTIVE

▬Tipo: stringa

Valori validi: STREAMING | INTERACTIVE

Campo obbligatorio: no

ApplicationName

Il nome dell'applicazione (ad esempio,sample-app).

▬Tipo: stringa

Limitazioni di lunghezza: lunghezza minima pari a 1. La lunghezza massima è 128 caratteri.

Modello: [a-zA-Z0-9_.-]+

Campo obbligatorio: sì

CloudWatchLoggingOptions

Utilizza questo parametro per configurare un flusso di CloudWatch log di Amazon per monitorare gli errori di configurazione delle applicazioni.

Tipo: matrice di oggetti CloudWatchLoggingOption

Campo obbligatorio: no

RuntimeEnvironment

L'ambiente di runtime per l'applicazione.

▬Tipo: stringa

Valori validi: SQL-1_0 | FLINK-1_6 | FLINK-1_8 | ZEPPELIN-FLINK-1_0 | FLINK-1_11 | FLINK-1_13 | ZEPPELIN-FLINK-2_0 | FLINK-1_15 | ZEPPELIN-FLINK-3_0 | FLINK-1_18 | FLINK-1_19

Campo obbligatorio: sì

ServiceExecutionRole

Il ruolo IAM utilizzato dall'applicazione per accedere ai flussi di dati Kinesis, ai flussi di distribuzione di Kinesis Data Firehose, agli oggetti Amazon S3 e ad altre risorse esterne.

▬Tipo: stringa

Limitazioni di lunghezza: lunghezza minima di 1. La lunghezza massima è 2048 caratteri.

Modello: arn:.*

Campo obbligatorio: sì

Tags

Un elenco di uno o più tag da assegnare all'applicazione. Un tag è una coppia chiave-valore che identifica un'applicazione. Tieni presente che il numero massimo di tag delle applicazioni include i tag di sistema. Il numero massimo di tag delle applicazioni definiti dall'utente è 50. Per ulteriori informazioni, consulta Utilizzo del tagging.

Tipo: matrice di oggetti Tag

Membri dell’array: numero minimo di 1 elemento. Numero massimo di 200 elementi.

Campo obbligatorio: no

Sintassi della risposta

{ "ApplicationDetail": { "ApplicationARN": "string", "ApplicationConfigurationDescription": { "ApplicationCodeConfigurationDescription": { "CodeContentDescription": { "CodeMD5": "string", "CodeSize": number, "S3ApplicationCodeLocationDescription": { "BucketARN": "string", "FileKey": "string", "ObjectVersion": "string" }, "TextContent": "string" }, "CodeContentType": "string" }, "ApplicationSnapshotConfigurationDescription": { "SnapshotsEnabled": boolean }, "ApplicationSystemRollbackConfigurationDescription": { "RollbackEnabled": boolean }, "EnvironmentPropertyDescriptions": { "PropertyGroupDescriptions": [ { "PropertyGroupId": "string", "PropertyMap": { "string" : "string" } } ] }, "FlinkApplicationConfigurationDescription": { "CheckpointConfigurationDescription": { "CheckpointingEnabled": boolean, "CheckpointInterval": number, "ConfigurationType": "string", "MinPauseBetweenCheckpoints": number }, "JobPlanDescription": "string", "MonitoringConfigurationDescription": { "ConfigurationType": "string", "LogLevel": "string", "MetricsLevel": "string" }, "ParallelismConfigurationDescription": { "AutoScalingEnabled": boolean, "ConfigurationType": "string", "CurrentParallelism": number, "Parallelism": number, "ParallelismPerKPU": number } }, "RunConfigurationDescription": { "ApplicationRestoreConfigurationDescription": { "ApplicationRestoreType": "string", "SnapshotName": "string" }, "FlinkRunConfigurationDescription": { "AllowNonRestoredState": boolean } }, "SqlApplicationConfigurationDescription": { "InputDescriptions": [ { "InAppStreamNames": [ "string" ], "InputId": "string", "InputParallelism": { "Count": number }, "InputProcessingConfigurationDescription": { "InputLambdaProcessorDescription": { "ResourceARN": "string", "RoleARN": "string" } }, "InputSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "InputStartingPositionConfiguration": { "InputStartingPosition": "string" }, "KinesisFirehoseInputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "KinesisStreamsInputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "NamePrefix": "string" } ], "OutputDescriptions": [ { "DestinationSchema": { "RecordFormatType": "string" }, "KinesisFirehoseOutputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "KinesisStreamsOutputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "LambdaOutputDescription": { "ResourceARN": "string", "RoleARN": "string" }, "Name": "string", "OutputId": "string" } ], "ReferenceDataSourceDescriptions": [ { "ReferenceId": "string", "ReferenceSchema": { "RecordColumns": [ { "Mapping": "string", "Name": "string", "SqlType": "string" } ], "RecordEncoding": "string", "RecordFormat": { "MappingParameters": { "CSVMappingParameters": { "RecordColumnDelimiter": "string", "RecordRowDelimiter": "string" }, "JSONMappingParameters": { "RecordRowPath": "string" } }, "RecordFormatType": "string" } }, "S3ReferenceDataSourceDescription": { "BucketARN": "string", "FileKey": "string", "ReferenceRoleARN": "string" }, "TableName": "string" } ] }, "VpcConfigurationDescriptions": [ { "SecurityGroupIds": [ "string" ], "SubnetIds": [ "string" ], "VpcConfigurationId": "string", "VpcId": "string" } ], "ZeppelinApplicationConfigurationDescription": { "CatalogConfigurationDescription": { "GlueDataCatalogConfigurationDescription": { "DatabaseARN": "string" } }, "CustomArtifactsConfigurationDescription": [ { "ArtifactType": "string", "MavenReferenceDescription": { "ArtifactId": "string", "GroupId": "string", "Version": "string" }, "S3ContentLocationDescription": { "BucketARN": "string", "FileKey": "string", "ObjectVersion": "string" } } ], "DeployAsApplicationConfigurationDescription": { "S3ContentLocationDescription": { "BasePath": "string", "BucketARN": "string" } }, "MonitoringConfigurationDescription": { "LogLevel": "string" } } }, "ApplicationDescription": "string", "ApplicationMaintenanceConfigurationDescription": { "ApplicationMaintenanceWindowEndTime": "string", "ApplicationMaintenanceWindowStartTime": "string" }, "ApplicationMode": "string", "ApplicationName": "string", "ApplicationStatus": "string", "ApplicationVersionCreateTimestamp": number, "ApplicationVersionId": number, "ApplicationVersionRolledBackFrom": number, "ApplicationVersionRolledBackTo": number, "ApplicationVersionUpdatedFrom": number, "CloudWatchLoggingOptionDescriptions": [ { "CloudWatchLoggingOptionId": "string", "LogStreamARN": "string", "RoleARN": "string" } ], "ConditionalToken": "string", "CreateTimestamp": number, "LastUpdateTimestamp": number, "RuntimeEnvironment": "string", "ServiceExecutionRole": "string" } }

Elementi di risposta

Se l'operazione riesce, il servizio restituisce una risposta HTTP 200.

I dati seguenti vengono restituiti in formato JSON mediante il servizio.

ApplicationDetail

In risposta alla CreateApplication richiesta, Managed Service for Apache Flink restituisce una risposta con i dettagli dell'applicazione creata.

Tipo: oggetto ApplicationDetail

Errori

CodeValidationException

Il codice dell'applicazione (query) fornito dall'utente non è valido. Può trattarsi di un semplice errore di sintassi.

Codice di stato HTTP: 400

ConcurrentModificationException

Eccezione generata a seguito di modifiche simultanee a un'applicazione. Questo errore può essere il risultato del tentativo di modificare un'applicazione senza utilizzare l'ID dell'applicazione corrente.

Codice di stato HTTP: 400

InvalidArgumentException

Il valore del parametro di input specificato non è valido.

Codice di stato HTTP: 400

InvalidRequestException

La richiesta JSON non è valida per l'operazione.

Codice di stato HTTP: 400

LimitExceededException

Il numero di risorse consentite è stato superato.

Codice di stato HTTP: 400

ResourceInUseException

L'applicazione non è disponibile per questa operazione.

Codice di stato HTTP: 400

TooManyTagsException

Applicazione creata con troppi tag o troppi tag aggiunti a un'applicazione. Tieni presente che il numero massimo di tag delle applicazioni include i tag di sistema. Il numero massimo di tag delle applicazioni definiti dall'utente è 50.

Codice di stato HTTP: 400

UnsupportedOperationException

La richiesta è stata rifiutata perché un parametro specificato non è supportato o una risorsa specificata non è valida per questa operazione.

Codice di stato HTTP: 400

Vedi anche

Per ulteriori informazioni sull'utilizzo di questa API in uno degli AWS SDK specifici della lingua, consulta quanto segue: